本文主要介绍用数据库varchar字段存储序列化数据。
通过实现 database/sql/driver
的接口,实现Value() (driver.Value, error)
和Scan(interface{}) error
函数。
package xx import ( "database/sql/driver" "encoding/json" ) type IntArray []int // 入库。实现 driver.Valuer 接口,Value 返回 json value func (j IntArray) Value() (driver.Value, error) { if len(j) == 0 { return "", nil } bytes, err := json.Marshal(j) if err != nil { return "", nil } return string(bytes), nil } // 出库。实现 sql.Scanner 接口,Scan 将 value 扫描至 Jsonb func (j *IntArray) Scan(value interface{}) error { bytes, ok := value.([]byte) if !ok || len(bytes) == 0 { return nil } result := IntArray{} err := json.Unmarshal(bytes, &result) *j = IntArray(result) return err }
有个需求。根据类型字段type
, content
存储不同的结构体。 拿出来的时候对外暴露不同的结构体对象。隐藏content
。
我一开始的做法是把content
声明为string
, 然后拿出来的时候解析到不同的结构体。 倒也没啥毛病。但是总觉得别扭,要先转为[]byte
再判断解析。
package xx import ( "database/sql/driver" "encoding/json" ) type Json []byte // 入库,自动调用 func (j Json) Value() (driver.Value, error) { if len(j) <= 4 { return "", nil } return string(j), nil } // 出库,自动调用 func (j *Json) Scan(value interface{}) error { bytes, _ := value.([]byte) if len(bytes) > 4 { *j = Json(bytes) } return nil } // 解析到,手动调用 func (j Json) ParseAs(to interface{}) (err error) { if len(j) > 0 { err = json.Unmarshal([]byte(j), to) if err != nil { log.Println("ERROR JSON 解析错误", err) } } return }
布尔适用于数据库用tinyint存储两种状态。 我们默认1为true,0为false
type Boolean bool func (b Boolean) Value() (driver.Value, error) { var v int64 if b { v = 1 } return v, nil } func (b *Boolean) Scan(value interface{}) (err error) { *b = (value.(int64) != 0) return }