# 原生查询

大多数时候,你都不应该使用原生查询。只有在无可奈何的情况下才应该考虑原生查询。使用原生查询可以:

  • 无需使用 ORM 表定义
  • 多数据库,都可直接使用占位符号 ?,自动转换
  • 查询时的参数,支持使用 Model Struct 和 Slice, Array

例如:

o := orm.NewOrm()
ids := []int{1, 2, 3}
var r RawSter
r = o.Raw("SELECT name FROM user WHERE id IN (?, ?, ?)", ids)
1
2
3
4

这里得到一个RawSeter的实例,它包含极多的方法。

# Exec

执行 sql 语句,返回 sql.Result (opens new window) 对象。

res, err := o.Raw("UPDATE user SET name = ?", "your").Exec()
if err == nil {
	num, _ := res.RowsAffected()
	fmt.Println("mysql row affected nums: ", num)
}
1
2
3
4
5

一般来说,使用该方法的应该是非 SELECT 语句。

# QueryRow 和 QueryRows

这两个方法的定义是:

QueryRow(containers ...interface{}) error
QueryRows(containers ...interface{}) (int64, error)
1
2

这两个方法会把返回的数据赋值给container

例如:

var name string
var id int
// id==2 name=="slene"
dORM.Raw("SELECT 'id','name' FROM `user`").QueryRow(&id,&name)
1
2
3
4

在这个例子里面,QueryRow会查询得到两列,并且只有一行。在这种情况下,两列的值分别被赋值给idname

使用QueryRows的例子:

var ids []int
var names []int
query = "SELECT 'id','name' FROM `user`"
// ids=>{1,2},names=>{"nobody","slene"}
num, err = dORM.Raw(query).QueryRows(&ids,&names)
1
2
3
4
5

同样地,QueryRows也是按照列来返回,因此可以注意到在例子里面我们声明了两个切片,分别对应于idname两个列。

# SetArgs

该方法用于设置参数。注意的是,参数个数必须和占位符?的数量保持一致。其定义:

SetArgs(...interface{}) RawSeter
1

例如:

var name string
var id int
query := "SELECT 'id','name' FROM `user` WHERE `id`=?"
// id==2 name=="slene"
// 等效于"SELECT 'id','name' FROM `user` WHERE `id`=1"
dORM.Raw(query).SetArgs(1).QueryRow(&id,&name)
1
2
3
4
5
6

也可以用于单条 sql 语句,重复利用,替换参数然后执行。

res, err := r.SetArgs("arg1", "arg2").Exec()
res, err := r.SetArgs("arg1", "arg2").Exec()

1
2
3

# Values / ValuesList / ValuesFlat

	Values(container *[]Params, cols ...string) (int64, error)
	ValuesList(container *[]ParamsList, cols ...string) (int64, error)
	ValuesFlat(container *ParamsList, cols ...string) (int64, error)
1
2
3

参考QuerySeter中的:

# RowsToMap

RowsToMap(result *Params, keyCol, valueCol string) (int64, error)
1

SQL 查询结果是这样:

name value
total 100
found 200

查询结果匹配到 map 里

res := make(orm.Params)
nums, err := o.Raw("SELECT name, value FROM options_table").RowsToMap(&res, "name", "value")
// res is a map[string]interface{}{
//	"total": 100,
//	"found": 200,
// }
1
2
3
4
5
6

# RowsToStruct

RowsToStruct(ptrStruct interface{}, keyCol, valueCol string) (int64, error)
1

SQL 查询结果是这样

name value
total 100
found 200

查询结果匹配到 struct 里

type Options struct {
	Total int
	Found int
}

res := new(Options)
nums, err := o.Raw("SELECT name, value FROM options_table").RowsToStruct(res, "name", "value")
fmt.Println(res.Total) // 100
fmt.Println(res.Found) // 200
1
2
3
4
5
6
7
8
9

匹配支持的名称转换为 snake -> camel, eg: SELECT user_name ... 需要你的 struct 中定义有 UserName

# Prepare

Prepare() (RawPreparer, error)
1

用于一次 prepare 多次 exec,以提高批量执行的速度。

p, err := o.Raw("UPDATE user SET name = ? WHERE name = ?").Prepare()
res, err := p.Exec("testing", "slene")
res, err  = p.Exec("testing", "astaxie")
// ...
p.Close() // 别忘记关闭 statement
1
2
3
4
5