beego——原生SQL查詢
阿新 • • 發佈:2018-12-16
使用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