title: Beego脫坑（十六）原生SQL查詢
tags: go，beego，orm
author : Clown95

如果你不習(xí)慣beego ORM為我們封裝好的方法，beego ORM還支持原生SQL語(yǔ)句，你可以直接使用Sql來(lái)完成操作。

Beego的ORM支持一下特性：

• 可以使用SQL 查詢，無(wú)需使用 ORM 表定義
• 使用多個(gè)數(shù)據(jù)的時(shí)候，可直接使用占位符號(hào)?，自動(dòng)轉(zhuǎn)換
• 查詢時(shí)的參數(shù)，支持使用 Model Struct 和 Slice, Array

我們依然通過(guò)student表來(lái)進(jìn)行演示。

image

Raw

Raw 返回原始sql語(yǔ)句的查詢集（Sql Seter），當(dāng)sql語(yǔ)句需要傳遞參數(shù)的時(shí)候，我們可以使用? 來(lái)進(jìn)行占位,然后在后面追加參數(shù)。

我們現(xiàn)在使用獲取stu_id =6 的查詢集 ：

orm1.Raw("select * from student where stu_id=?",6)

上面的代碼它不會(huì)執(zhí)行任何sql操作，只是用來(lái)獲取查詢集，如果想讓它執(zhí)行我們往下面看。

Exec

Exec它可以幫我們執(zhí)行 sql 語(yǔ)句，并返回 sql.Result 對(duì)象.

為了能夠直觀的看到Exec執(zhí)行了sql語(yǔ)句，我們把 name ="小新"的數(shù)據(jù)中的 hobby 改為 "動(dòng)感超人"

func (this *SqlController) GetRawAndExec() {
    orm1 := orm.NewOrm()
    res, err := orm1.Raw("update student set hobby = ? where name = ?", "動(dòng)感超人", "小新").Exec()
    if err != nil {
        this.Ctx.WriteString("查詢失敗!")
        return
    }
    n, err := res.RowsAffected()//受影響的行數(shù)
    if err != nil {
        this.Ctx.WriteString("查詢失敗!")
        return
    }
    this.Ctx.WriteString("mysql row affected nums = " + strconv.Itoa(int(n)))
}

image

SetArgs

如果某sql語(yǔ)句，需要重復(fù)使用，但是參數(shù)不相同，我們就可以使用SetArgs,它可以改變 Raw(sql, args…) 中的 args 參數(shù),返回一個(gè)新的 RawSeter。

比如說(shuō)我們上面的代碼我們簡(jiǎn)單修改下就可以復(fù)用：

func (this *SqlController) GetSetArgs() {
    orm1 := orm.NewOrm()
    r:= orm1.Raw("update student set hobby = ? where name = ?")
    res,err:=r.SetArgs("動(dòng)感超人","小新").Exec()
    if err == nil {
        res.RowsAffected()
        this.Ctx.WriteString("查詢成功!")
    }else{

        this.Ctx.WriteString("查詢失敗!")
    }
}

QueryRow

QueryRow 能夠把查詢的數(shù)據(jù)映射到結(jié)構(gòu)體或者map。

現(xiàn)在我們就通過(guò)它查詢下 name="小新" 的數(shù)據(jù) :

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("查詢出錯(cuò)!")
    }
}

image

QueryRows

QueryRows 和QueryRow一樣提供高級(jí) sql mapper 功能，能夠把執(zhí)行的Sql語(yǔ)句查詢數(shù)據(jù)映射到對(duì)象或者map中,區(qū)別在于QueryRows 能獲取多行數(shù)據(jù)，返回的是切片。

下面我們就使用它來(lái)獲取student 表中所有的數(shù)據(jù)：

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())
    }
}

通過(guò)代碼我們可以看到，ORM的Raw函數(shù)支持原生Sql語(yǔ)句傳參，我們可以通過(guò)?占位傳入變量，最終通過(guò)Exec來(lái)執(zhí)行語(yǔ)句。

image

RowsToMap

RowsToMap 通過(guò)名字我們也能猜到，它是把查詢結(jié)果匹配到 map 里面。

下面我們把 student 表中 name作為key ，hobby作為 value 存儲(chǔ)到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("查詢數(shù)據(jù)有：" + strconv.Itoa(int(n)) + "行 \n\n")
        for key, value := range res {
            this.Ctx.WriteString(key + "愛(ài)好是：" + value.(string) + "\n")
        }

    } else {
        this.Ctx.WriteString("查詢出錯(cuò)!")
    }
}

image

Prepare

sql語(yǔ)句在發(fā)送到服務(wù)器時(shí)會(huì)做語(yǔ)法檢查和編譯，然而我們多次執(zhí)行同一功能的sql語(yǔ)句，只是每次傳遞的參數(shù)不一致，所以我們可以通過(guò)Prepare進(jìn)行預(yù)處理，這樣服務(wù)器只需要做一次語(yǔ)法檢查和編譯，極大的提高了sql語(yǔ)句執(zhí)行的效率。

func (this *SqlController) GetPrepaer() {
    orm := orm.NewOrm()
    p, err := orm.Raw("update student set name = ? where name = ?").Prepare()
    if err != nil {
        this.Ctx.WriteString("查詢出錯(cuò)!")
        return
    }
    res, err := p.Exec("野原新之助", "小新")
    res.RowsAffected()
    if err != nil {
        this.Ctx.WriteString("錯(cuò)誤!")
        return
    }
    res, err = p.Exec("野原美伢", "美冴")
    res.RowsAffected()
    if err != nil {
        this.Ctx.WriteString("錯(cuò)誤!")
        return
    }
    res, err = p.Exec("野原廣志", "廣志")
    res.RowsAffected()
    if err != nil {
        this.Ctx.WriteString("錯(cuò)誤!")
        return
    }
    res, err = p.Exec("野原向日葵", "小葵")
    res.RowsAffected()
    if err != nil {
        this.Ctx.WriteString("錯(cuò)誤!")
        return
    }
    p.Close()

    this.Ctx.WriteString("更新成功!")
}

image

ValuesList

ValuesList 返回結(jié)果集 slice 。 Raw SQL 查詢獲得的結(jié)果集 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("查詢出錯(cuò)!")
    }
}

image

還有一些遺漏的方法，我這里就不在詳細(xì)介紹，如果需要了解可以去參考下官方文檔。