文档与附件存在多对多关联,用关系型数据库需要创建多个表,然后进行关联更新与查询,甚至是事务。所以考虑使用 mongodb,希望有更方便的操作方式。
过程中发现 mongodb 与 model、protobuff 对象整合起来非常别扭,同时 mongodb 的 golang 官方库 使用起来也是非常别扭。 mgo 还不错,可惜已经不再维护了。所以最终还是放弃在 golang 的微服务搭建中使用 mongodb。
mongo 的主键类型是 primitive.ObjectID
实际使用时需要 string
,所以需要来回转换类型
type Model struct { ID primitive.ObjectID `bson:"_id,omitempty"` // 唯一ID }
Find 到 documents
后 Decode 到 pb.Message 需要定义额外的 Tag 指定 bson 名,原生 protobuf 不支持,需要用 gogo 集成插件 moretags
message Model { string id = 1; // `bson:"_id"` }
context.Background() bson.D{{"_id", 1}}
var versions []*pb.NoteVersion cursor, err := d.mdb.Collection("notes").Find(context.TODO(), bson.D{}, options.Find().SetProjection(bson.D{ {"_id", 1}, {"version", 1}, {"md5_sum", 1}, })) defer cursor.Close(context.TODO())
继续使用关系型数据库 mysql 或 postgres
模型层通过 gorm Hook 实现数据类型的转换,在更新时把对象序列化成落地字符串,查询后做反序列化
type Note struct { ID int64 `gorm:"primary_key"` // 唯一ID Attachments pb.Attachments `gorm:"-"` // 附件 AttachmentsRaw string `gorm:"column:attachments;not null"` // 序列化 Tags pb.Tags `gorm:"-"` // 标签 TagsRaw string `gorm:"column:tags;not null"` // 序列化 } func (u *Note) BeforeSave() (err error) { u.AttachmentsRaw = u.Attachments.String() u.TagsRaw = u.Tags.String() return } func (u *Note) AfterFind() (err error) { err = proto.UnmarshalText(u.AttachmentsRaw, &u.Attachments) if err != nil { return } err = proto.UnmarshalText(u.TagsRaw, &u.Tags) return }