1. 程式人生 > >beego——原生SQL查詢

beego——原生SQL查詢

使用Raw SQL查詢,無需使用ORM表定義。

多資料庫,都可直接使用佔位符號?,自動轉換。

查詢時的引數,支援使用Model Struct和Slice,Array

ids := []int{1, 2, 3}
p.Raw("SELECT name FROM user WHERE id IN (?, ?, ?)", ids)

建立一個RawSeter

o := orm.NewOrm()
var r RawSeter
r = o.Raw("UPDATE user SET name = ? WHERE name = ?", "testing", "slene")

RawSeter介面中所包含的方法:

type RawSeter interface {

  • Exec() (sql.Result, error)
  • QueryRow(…interface{}) error
  • QueryRows(…interface{}) (int64, error)
  • SetArgs(…interface{}) RawSeter
  • Values(*[]Params, …string) (int64, error)
  • ValuesList(*[]ParamsList, …string) (int64, error)
  • ValuesFlat(*ParamsList, string) (int64, error)
  • RowsToMap(*Params, string, string) (int64, error)
  • RowsToStruct(interface{}, string, string) (int64, error)
  • Prepare() (RawPreparer, error)

}

 

Exec

執行sql語句,返回sql.Result物件

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

  

QueryRow

QueryRow和QueryRows提供高階sql mapper功能。

支援struct

type User struct {
    Id       int
    UserName string
}

var user User
err := o.Raw("SELECT id, user_name FROM user WHERE id = ?", 1).QueryRow(&user)

  

QueryRows

QueryRows支援的物件還有map規則和QueryRow一樣,但都是slice

type User struct {
    Id       int
    UserName string
}

var users []User
num, err := o.Raw("SELECT id, user_name FROM user WHERE id = ?", 1).QueryRows(&users)
if err == nil {
    fmt.Println("user nums: ", num)
}

  

SetArgs

改變Raw(sql,args)中的args引數,返回一個新的RawSeter。

用於單條sql語句,重複利用,替換引數然後執行。

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

  

Values / ValuesList / ValuesFlat

Raw SQL查詢獲得的結果集Value為string型別,NULL欄位的值為空。

Values

以鍵值對的方式返回結果集

var maps []orm.Params
num, err := o.Raw("SELECT user_name FROM user WHERE status = ?", 1).Values(&maps)
if err == nil && num > 0 {
    fmt.Println(maps[0]["user_name"]) // slene
}

valuesList

返回結果集slice

var lists []orm.ParamsList
num, err := o.Raw("SELECT user_name FROM user WHERE status = ?", 1).ValuesList(&lists)
if err == nil && num > 0 {
    fmt.Println(lists[0][0]) // slene
}

ValuesFlat

返回單一欄位的平鋪slice資料。

var list orm.ParamsList
num, err := o.Raw("SELECT id FROM user WHERE id < ?", 10).ValuesFlat(&list)
if err == nil && num > 0 {
    fmt.Println(list) // []{"1","2","3",...}
}

  

RowsToMap

查詢結果匹配到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,
// }

  

RowsToStruct

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

  

Prepare

用於一次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