接下来关于gf ORM
提供的模型关联实现,从GF v1.13.6
版本开始提供,目前属于实验性特性。
那么我们就使用一个例子来介绍gf ORM
提供的模型关联吧。
为简化示例,我们这里设计得表都尽可能简单,每张表仅包含3-4个字段,方便阐述关联关系即可。
CREATE TABLE `user_detail` (
uid int(10) unsigned NOT NULL AUTO_INCREMENT,
address varchar(45) NOT NULL,
PRIMARY KEY (uid)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
CREATE TABLE `user_scores` (
id int(10) unsigned NOT NULL AUTO_INCREMENT,
uid int(10) unsigned NOT NULL,
score int(10) unsigned NOT NULL,
course varchar(45) NOT NULL,
PRIMARY KEY (id)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
根据表定义,我们可以得知:
- 用户表与用户详情是
1:1
关系。 - 用户表与用户学分是
1:N
关系。 - 这里并没有演示
N:N
的关系,因为相比较于1:N
的查询只是多了一次关联、或者一次查询,最终处理方式和1:N
类似。
那么Golang
的模型可定义如下:
写入数据时涉及到简单的数据库事务即可。
err := db.Transaction(func(tx *gdb.TX) error {
r, err := tx.Table("user").Save(EntityUser{
Name: "john",
})
if err != nil {
return err
}
if err != nil {
return err
}
_, err = tx.Table("user_detail").Save(EntityUserDetail{
Uid: int(uid),
})
if err != nil {
return err
}
_, err = tx.Table("user_scores").Save(g.Slice{
EntityUserScores{Uid: int(uid), Score: 100, Course: "math"},
EntityUserScores{Uid: int(uid), Score: 99, Course: "physics"},
})
return err
})
// 定义用户列表
var user Entity
// 查询用户基础数据
// SELECT * FROM `user` WHERE `name`='john'
err := db.Table("user").Scan(&user.User, "name", "john")
if err != nil {
return err
}
// 查询用户详情数据
// SELECT * FROM `user_detail` WHERE `uid`=1
err := db.Table("user_detail").Scan(&user.UserDetail, "uid", user.User.Uid)
// 查询用户学分数据
// SELECT * FROM `user_scores` WHERE `uid`=1
err := db.Table("user_scores").Scan(&user.UserScores, "uid", user.User.Uid)
查询单条模型数据比较简单,直接使用Scan
方法即可,该方法会自动识别绑定查询结果到单个对象属性还是数组对象属性中。该方法在之前的章节中已经有介绍,因此这里不再赘述。
是不是比较简单。这其中涉及到两个比较重要的方法:
1. ScanList
方法定义:
// ScanList converts <r> to struct slice which contains other complex struct attributes.
// Note that the parameter <listPointer> should be type of *[]struct/*[]*struct.
//
// type Entity struct {
// User *EntityUser
// UserDetail *EntityUserDetail
// UserScores []*EntityUserScores
// }
// var users []*Entity
// or
// var users []Entity
//
// ScanList(&users, "User")
// ScanList(&users, "UserDetail", "User", "uid:Uid")
// ScanList(&users, "UserScores", "User", "uid:Uid")
// The parameters "User"/"UserDetail"/"UserScores" in the example codes specify the target attribute struct
// that current result will be bound to.
// The "uid" in the example codes is the table field name of the result, and the "Uid" is the relational
// struct attribute name. It automatically calculates the HasOne/HasMany relationship with given <relation>
// parameter.
func (m *Model) ScanList(listPointer interface{}, attributeName string, relation ...string) (err error)
该方法用于将查询到的数组数据绑定到指定的列表上,例如:
ScanList(&users, "User")
ScanList(&users, , "UserDetail", "User", "uid:Uid")
表示将查询到用户详情数组数据绑定到users
列表中每一项的UserDetail
属性上,并且和另一个User
对象属性通过uid:Uid
的字段:属性
关联,内部将会根据这一关联关系自动进行数据绑定。其中uid:Uid
前面的uid
表示查询结果字段中的uid
字段,后面的Uid
表示目标关联对象中的Uid
属性。
ScanList(&users, , "UserScores", "User", "uid:Uid")
表示将查询到用户详情数组数据绑定到users
列表中每一项的UserScores
属性上,并且和另一个User
对象属性通过uid:Uid
的字段:属性
关联,内部将会根据这一关联关系自动进行数据绑定。由于UserScores
是一个数组类型[]*EntityUserScores
,因此该方法内部可以自动识别到User
到UserScores
其实是1:N
的关系,自动完成数据绑定。
需要提醒的是,如果关联数据中对应的关联属性数据不存在,那么该属性不会被初始化并将保持nil
。
2. ListItemValues
方法定义:
// ListItemValues retrieves and returns the elements of all item struct/map with key <key>.
// Note that the parameter <list> should be type of slice which contains elements of map or struct,
// or else it returns an empty slice.
//
// The parameter <list> supports types like:
// []map[string]interface{}
// []map[string]sub-map
// []struct
// []struct:sub-struct
func ListItemValues(list interface{}, key interface{}, subKey ...interface{}) (values []interface{})
gdb.ListItemValues(users, "User", "Uid")
用于获取users
数组中,每一个User
属性项中的Uid
属性,构造成[]interface{}
数组返回。这里以便根据构造成SELECT...IN...
查询。