0

我正在使用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"`
    ...

当然，当我说“没有喧嚣”时，我的意思是将 DB 行无缝地提取到结构中。我可以添加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.Sku,
        custItem.Name,
        model.CustomizedComponentsIn(custItem.Skus)
...

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

4

1 回答 1

1

如果您可以更改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
于 2020-10-10T16:35:36.737 回答