title: Beego脱坑（十六）原生SQL查询
tags: go，beego，orm
author : Clown95
如果你不习惯beego ORM为我们封装好的方法，beego ORM还支持原生SQL语句，你可以直接使用Sql来完成操作。
Beego的ORM支持一下特性：
- 可以使用SQL 查询，无需使用 ORM 表定义
- 使用多个数据的时候，可直接使用占位符号
?，自动转换 - 查询时的参数，支持使用 Model Struct 和 Slice, Array
我们依然通过student表来进行演示。
Raw
Raw 返回原始sql语句的查询集（Sql Seter），当sql语句需要传递参数的时候，我们可以使用? 来进行占位,然后在后面追加参数。
我们现在使用获取stu_id =6 的查询集 ：
orm1.Raw("select * from student where stu_id=?",6)
上面的代码它不会执行任何sql操作，只是用来获取查询集，如果想让它执行我们往下面看。
Exec
Exec它可以帮我们执行 sql 语句，并返回 sql.Result 对象.
为了能够直观的看到Exec执行了sql语句，我们把 name ="小新"的数据中的 hobby 改为 "动感超人"
func (this *SqlController) GetRawAndExec() {
orm1 := orm.NewOrm()
res, err := orm1.Raw("update student set hobby = ? where name = ?", "动感超人", "小新").Exec()
if err != nil {
this.Ctx.WriteString("查询失败!")
return
}
n, err := res.RowsAffected()//受影响的行数
if err != nil {
this.Ctx.WriteString("查询失败!")
return
}
this.Ctx.WriteString("mysql row affected nums = " + strconv.Itoa(int(n)))
}
SetArgs
如果某sql语句，需要重复使用，但是参数不相同，我们就可以使用SetArgs,它可以改变 Raw(sql, args…) 中的 args 参数,返回一个新的 RawSeter。
比如说我们上面的代码我们简单修改下就可以复用：
func (this *SqlController) GetSetArgs() {
orm1 := orm.NewOrm()
r:= orm1.Raw("update student set hobby = ? where name = ?")
res,err:=r.SetArgs("动感超人","小新").Exec()
if err == nil {
res.RowsAffected()
this.Ctx.WriteString("查询成功!")
}else{
this.Ctx.WriteString("查询失败!")
}
}
QueryRow
QueryRow 能够把查询的数据映射到结构体或者map。
现在我们就通过它查询下 name="小新" 的数据 :
func (this *SqlController) GetQueryRow() {
var stu Student
orm := orm.NewOrm()
err := orm.Raw("select * from student where name = ?", "小新").QueryRow(&stu)
if err == nil {
this.Ctx.WriteString(strconv.Itoa(stu.StuId) + " " + stu.Name + " " + stu.Age + " " + stu.Hobby + "\n")
} else {
this.Ctx.WriteString("查询出错!")
}
}
QueryRows
QueryRows 和QueryRow一样提供高级 sql mapper 功能，能够把执行的Sql语句查询数据映射到对象或者map中,区别在于QueryRows 能获取多行数据，返回的是切片。
下面我们就使用它来获取student 表中所有的数据：
func (this *SqlController) GetQueryRows() {
orm1 := orm.NewOrm()
var stus []*Student
n,err := orm1.Raw("select * from student").QueryRows(&stus)
if err == nil &&n>0{
for _,v:=range stus {
this.Ctx.WriteString(strconv.Itoa(v.StuId) + " " + v.Name + " " + v.Age + " " + v.Hobby+"\n")
}
} else {
this.Ctx.WriteString("查询失败:\n" + err.Error())
}
}
通过代码我们可以看到，ORM的Raw函数支持原生Sql语句传参，我们可以通过?占位传入变量，最终通过Exec来执行语句。
RowsToMap
RowsToMap 通过名字我们也能猜到，它是把查询结果匹配到 map 里面。
下面我们把 student 表中 name作为key ，hobby作为 value 存储到map中：
func (this *SqlController) GetRawsToMap() {
res := orm.Params{}
orm := orm.NewOrm()
n, err := orm.Raw("select name, hobby from student").RowsToMap(&res, "name", "hobby")
if err == nil {
this.Ctx.WriteString("查询数据有：" + strconv.Itoa(int(n)) + "行 \n\n")
for key, value := range res {
this.Ctx.WriteString(key + "爱好是：" + value.(string) + "\n")
}
} else {
this.Ctx.WriteString("查询出错!")
}
}
Prepare
sql语句在发送到服务器时会做语法检查和编译，然而我们多次执行同一功能的sql语句，只是每次传递的参数不一致，所以我们可以通过Prepare进行预处理，这样服务器只需要做一次语法检查和编译，极大的提高了sql语句执行的效率。
func (this *SqlController) GetPrepaer() {
orm := orm.NewOrm()
p, err := orm.Raw("update student set name = ? where name = ?").Prepare()
if err != nil {
this.Ctx.WriteString("查询出错!")
return
}
res, err := p.Exec("野原新之助", "小新")
res.RowsAffected()
if err != nil {
this.Ctx.WriteString("错误!")
return
}
res, err = p.Exec("野原美伢", "美冴")
res.RowsAffected()
if err != nil {
this.Ctx.WriteString("错误!")
return
}
res, err = p.Exec("野原广志", "广志")
res.RowsAffected()
if err != nil {
this.Ctx.WriteString("错误!")
return
}
res, err = p.Exec("野原向日葵", "小葵")
res.RowsAffected()
if err != nil {
this.Ctx.WriteString("错误!")
return
}
p.Close()
this.Ctx.WriteString("更新成功!")
}
ValuesList
ValuesList 返回结果集 slice 。 Raw SQL 查询获得的结果集 Value 为 string 类型，NULL 字段的值为空 。
下面我们查询表中所有的name 并保存到 list中 ：
func (this *SqlController) GetValuesList() {
var lists []orm.ParamsList
orm := orm.NewOrm()
num, err := orm.Raw("SELECT name FROM student ").ValuesList(&lists)
if err == nil && num > 0 {
for _,v:=range lists{
this.Ctx.WriteString(v[0].(string)+"\n")
}
}else {
this.Ctx.WriteString("查询出错!")
}
}
还有一些遗漏的方法，我这里就不在详细介绍，如果需要了解可以去参考下官方文档。
