gorose, 最像 laravel's eloquent 的go數據庫操做orm, 風騷的鏈式調用, 讓你深深陷入不能自拔

時間 2019-12-09

標籤 gorose laravel's laravel eloquent 數據庫 orm 鏈式調用讓你深深陷入不能自拔欄目 SQL 简体版

原文原文鏈接

簡介

gorose(go orm), 一個小巧強悍的go語言數據庫操做orm, 靈感來源於laravel的數據庫操做orm, 也就是eloquent, php、python、ruby開發者, 都會喜歡上這個orm的操做方式, 主要是鏈式操做比較風騷php

github

https://github.com/gohouse/gorose

先睹爲快

db.Table("tablename").First()
db.Table("tablename").Distinct().Where("id", ">", 5).Get()
db.Table("tablename").Fields("id, name, age, job").Group("job").Limit(10).Offset(20).Order("id desc").Get()

安裝

安裝 gorose

go get github.com/gohouse/gorose

配置和示例

多個數據庫鏈接配置

import "github.com/gohouse/gorose"

var dbConfig = map[string]map[string]string {
    "mysql": {
        "host":     "localhost",
        "username": "root",
        "password": "",
        "port":     "3306",
        "database": "test",
        "charset":  "utf8",
        "protocol": "tcp",
    },
    "mysql_dev": {
        "host":     "localhost",
        "username": "root",
        "password": "",
        "port":     "3306",
        "database": "gorose",
        "charset":  "utf8",
        "protocol": "tcp",
    },
}

gorose.Open(dbConfig, "mysql")

var db gorose.Database

func main() {
    res := db.Table("users").First()
    
    fmt.Println(res)
}

簡單的但數據庫配置

gorose.Open(map[string]string {
                "host":     "localhost",
                "username": "root",
                "password": "",
                "port":     "3306",
                "database": "test",
                "charset":  "utf8",
                "protocol": "tcp",
            })

用法示例

查詢

原生sql語句查詢

db.Query("select * from user where id = 1")

鏈式調用查詢

db.Table("user").
    Field("id, name").  // field
    Where("id",">",1).  // simple where
    Where(map[string]interface{}{"name":"fizzday", "age":18}).  // where object
    Where([]map[string]interface{}{{"website", "like", "fizz"}, {"job", "it"}}).    // multi where
    Where("head = 3 or rate is not null").  // where string
    OrWhere("cash", "1000000"). // or where ...
    OrWhere("score", "between", []string{50, 80}).  // between
    OrWhere("role", "not in", []string{"admin", "read"}).   // in 
    Group("job").   // group
    Order("age asc").   // order 
    Limit(10).  // limit
    Offset(1).  // offset
    Get()   // fetch multi rows

獲得sql結果:python

select id,name from user 
    where (id>1) 
    and (name='fizzday' and age='18') 
    and ((website like '%fizz%') and (job='it'))
    and (head =3 or rate is not null)
    or (cash = '100000') 
    or (score between '50' and '100') 
    or (role not in ('admin', 'read'))
    group by job 
    order by age asc 
    limit 10 offset 1

join

db.Table("user")
    .Join("card","user.id","=","card.user_id")
    .Limit(10)
    .Get()

最終執行的sql爲:數據庫

select * from user inner join card on user.id=card.user_id limit 10

db.Table("user")
    .LeftJoin("card","user.id","=","card.user_id")
    .First()

最終執行的sql爲:json

select * from user left join card on user.id=card.user_id limit 1

RightJoin : right join

嵌套where的查詢 (where nested)

db.Table("user").Where("id", ">", 1).Where(func() {
        db.Where("name", "fizz").OrWhere(func() {
            db.Where("name", "fizz2").Where(func() {
                db.Where("name", "fizz3").OrWhere("website", "fizzday")
            })
        })
    }).Where("job", "it").First()

最終執行的sql爲:

SELECT  * FROM user  
    WHERE  id > '1' 
        and ( name = 'fizz' 
            or ( name = 'fizz2' 
                and ( name = 'fizz3' or website like '%fizzday%')
                )
            ) 
    and job = 'it' LIMIT 1

分塊獲取數據

db.JsonEncode(false)    // 若是在項目入口設置了返回json JsonEncode=true
db.Table("users").Fields("id, name").Where("id",">",2).Chunk(2, func(data []map[string]interface{}) {
    // for _,item := range data {
    //        fmt.Println(item)
    // }
    fmt.Println(data)
})

打印結果:

// map[id:3 name:gorose]
// map[id:4 name:fizzday]
// map[id:5 name:fizz3]
// map[id:6 name:gohouse]
[map[id:3 name:gorose] map[name:fizzday id:4]]
[map[id:5 name:fizz3] map[id:6 name:gohouse]]

增刪改操做

原生sql字符串

db.Execute("update user set job='it2' where id=3")

鏈式調用

db.Table("user").
    Data(map[string]interface{}{"age":17, "job":"it3"}).
    Where("id", 1).
    OrWhere("age",">",30).
    Update()

最終執行的sql爲: update user set age=17, job='ite3' where (id=1) or (age>30)

事務

標準用法

db.Begin()

res := db.Table("user").Where("id", 1).Data(map[string]interface{}{"age":18}).Update()
if (res == 0) {
    db.Rollback()
}

res2 := db.Table("user").Data(map[string]interface{}{"age":18}).Insert()
if (res2 == 0) {
    db.Rollback()
}

db.Commit()

簡單用法, 用閉包實現, 自動開始事務, 回滾或提交事務

db.Transaction(func() {
    db.Execute("update area set job='sadf' where id=14")
    db.Table("area").Data(map[string]interface{}{"names": "fizz3", "age": 3}).Insert()
    db.Table("area").Data(map[string]interface{}{"names": "fizz3", "age": 3}).Where("id",10).Update()
})

切換數據庫鏈接

// 鏈接最開始配置的第二個連接(mysql_dev是key)
db.Connect("mysql_dev").Table().First()
// 或者直接輸入鏈接配置
db.Connect(map[string]string {
                "host":     "localhost",
                "username": "root",
                "password": "",
                "port":     "3306",
                "database": "test",
                "charset":  "utf8",
                "protocol": "tcp",
            }).Table().First()