将json数组解组为结构数组

问题描述

我正在使用Mysql 8。我还利用99designs/gqlgen来基于GraphQL模式自动生成结构。 扫描MySql响应时，我将重用相同的结构。最重要的是，在进行原型制作时，我想在表中包含一些JSON。 所以结构是：

type CustomizedItemInput struct {
    Sku              string                 `json:"sku"`
    Name             string                 `json:"name"`
    Skus             []*CustomizedComponent `json:"skus"`
    ...

由于存储（提供Value()）比较简单，因此我成功地将Skus作为顶级JSON存储到数据库中。看起来像这样：

[{"sku": "123","position": "LEFT"},{"sku": "456","position": "RIGHT"}]

现在，如何在不费吹灰之力的情况下从DB中获取此值并返回到结构内部的指针数组中？ 当然，理想情况下，它应该在不更改基础结构的情况下完成，因为它是自动生成的。

更新： 添加调试信息。我需要将DB行读入CustomizedItemView，该行基本上从上面镜像了CustomizedItemInput：

type CustomizedItemView struct {
    Sku              string                     `json:"sku"`
    Name             string                     `json:"name"`
    Skus             []*CustomizedComponentView `json:"skus"`
    ...

当然，当我说“没有烦恼”时，我的意思是让数据库行无缝地提取到结构中。我可以将map[string]interface{}{}与所有的钟声一起添加并获取值。但我想让它整洁，例如：

    var storedCustItem = model.CustomizedItemView{}
    err := udb.Get(&storedCustItem,database.SelectCustomizationQuery,userID,custItem.Sku,createdAt)

我得到的错误是：

2020/10/10 20:38:24 sql: Scan error on column index 8,name "skus": unsupported Scan,storing driver.Value type []uint8 into type *[]*model.CustomizedComponentView

（8，因为我删除了该示例的某些字段）。 主要问题是我无法为未命名类型创建Scan()。我为Value()创建了包装器，因为我的插入内容更加冗长，并且我使用其中的包装器类型进行类型转换：

type CustomizedComponentsIn []*CustomizedComponent
...
func (customizedComponents CustomizedComponentsIn) Value() (driver.Value,error)
...
tx.MustExec(database.SaveCustomizationCommand,custItem.Name,model.CustomizedComponentsIn(custItem.Skus)
...

，对于插入来说是可以的，因为会有一些不属于输入结构的值。 但我希望至少可以将值自动扫描到View结构中。

解决方法

如果您可以更改Skus字段的类型，通常的方法是声明一个实现sql.Scanner和driver.Valuer接口的切片类型，并使用该切片类型代替未命名的[]*CustomizedComponent类型。

例如：

type CustomizedItemInput struct {
    Sku  string                   `json:"sku"`
    Name string                   `json:"name"`
    Skus CustomizedComponentSlice `json:"skus"`
    // ...
}

type CustomizedComponentSlice []*CustomizedComponent

// Value implements driver.Valuer interface.
func (s CustomizedComponentSlice) Value() (driver.Value,error) {
    return json.Marshal(s)
}

// Scan implements sql.Scanner interface.
func (s *CustomizedComponentSlice) Scan(src interface{}) error {
    var data []byte
    switch v := src.(type) {
    case string:
        data = []byte(v)
    case []byte:
        data = v
    default:
        return nil
    }
    return json.Unmarshal(data,s)
}

---

如果不能更改Skus字段的类型，则必须在扫描期间显式转换该字段。

例如，给定上述命名的切片类型，您可以执行以下操作：

v := new(CustomizedItemView)
row := db.QueryRow("SELECT sku,name,skus FROM customized_item_view WHERE sku = ? LIMIT 1",sku)
err := row.Scan(
    &v.Sku,&v.Name,// do the conversion here,and any other place where you're scanning Skus... 
    (*CustomizedComponentSlice)(&v.Skus),)
if err != nil {
   return err
}
fmt.Println(v.Skus) // result