beego原生SQL查詢

2023-11-20 18:07 更新

使用SQL語句進(jìn)行查詢

  • 使用 Raw SQL 查詢,無需使用 ORM 表定義
  • 多數(shù)據(jù)庫,都可直接使用占位符號 ?,自動轉(zhuǎn)換
  • 查詢時的參數(shù),支持使用 Model Struct 和 Slice, Array
ids := []int{1, 2, 3}
p.Raw("SELECT name FROM user WHERE id IN (?, ?, ?)", ids)

創(chuàng)建一個 RawSeter

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

Exec

執(zhí)行 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)
from beego 1.1.0 取消了多個對象支持 ISSUE 384

QueryRows

QueryRows 支持的對象還有 map 規(guī)則是和 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)
}
from beego 1.1.0 取消了多個對象支持 ISSUE 384 ```

SetArgs

改變 Raw(sql, args...) 中的 args 參數(shù),返回一個新的 RawSeter

用于單條 sql 語句,重復(fù)利用,替換參數(shù)然后執(zhí)行。

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

Values / ValuesList / ValuesFlat

Raw SQL 查詢獲得的結(jié)果集 Value 為 string 類型,NULL 字段的值為空 ``

from beego 1.1.0 Values, ValuesList, ValuesFlat 的參數(shù),可以指定返回哪些 Columns 的數(shù)據(jù) 通常情況下,是無需指定的,因?yàn)?sql 語句中你可以自行設(shè)置 SELECT 的字段

Values

返回結(jié)果集的 key => value 值

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

返回結(jié)果集 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 數(shù)據(jù)

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

SQL 查詢結(jié)果是這樣

namevalue
total100
found200

查詢結(jié)果匹配到 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

SQL 查詢結(jié)果是這樣

namevalue
total100
found200

查詢結(jié)果匹配到 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
匹配支持的名稱轉(zhuǎn)換為 snake -> camel, eg: SELECT user_name ... 需要你的 struct 中定義有 UserName

Prepare

用于一次 prepare 多次 exec,以提高批量執(zhí)行的速度。

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() // 別忘記關(guān)閉 statement
以上內(nèi)容是否對您有幫助:
在線筆記
App下載
App下載

掃描二維碼

下載編程獅App

公眾號
微信公眾號

編程獅公眾號