golang 使用xorm操做mysql

xorm

官方介紹：xorm是一個簡單而強大的Go語言ORM庫. 經過它可使數據庫操做很是簡便。xorm的目標並非讓你徹底不去學習SQL，咱們認爲SQL並不會爲ORM所替代，可是ORM將能夠解決絕大部分的簡單SQL需求。xorm支持兩種風格的混用。

xorm還提供了工具，經過reverse命令根據數據庫的表結構生成對應的struct，省去了人工組織代碼的工做，十分方便。
官方地址：https://xorm.io/
中文文檔：https://books.studygolang.com...

安裝

瀏覽xorm的github地址，咱們要下載2個包，https://github.com/go-xorm

一、xorm驅動包，咱們使用xorm的核心包
二、cmd工具包，用於使用reverse命令生成數據表對應的struct

經過go get命令分別下載2個包
go get github.com/go-xorm/xorm
go get github.com/go-xorm/cmd/xorm
下載完成後github.com文件夾下會出現go-xorm包

生成數據結構struct

本地數據庫test有2張數據表，doctor_tb和user_tb,數據結構以下:


咱們如今就來生成這2張數據表的結構模型。

一、在任意項目下新建一個文件夾xorm_models，文件名沒有規定，爲了存放生成的代碼文件。

二、拷貝cmd工具包中的摸板目錄到xorm_models下，在文件目錄github.com\go-xorm\cmd\xorm\templates\goxorm下

config是生成的配置信息,struct.go.tpl是數據摸板，容許自定義，能夠根據本身的項目需求，修改摸板。通常不須要修改。

三、打開cmd命令行窗口，進入xorm_models目錄下，執行reverse命令：xorm reverse [數據庫類型] [數據庫鏈接串] [模板目錄]

xorm reverse mysql root:112233@tcp(127.0.0.1:3305)/test?charset=utf8 templates/goxorm

四、數據結構代碼會自動生成在xorm_models/models目錄下.

咱們能看到生成了和表名同名的2個數據結構文件doctor_tb.go和user_tb.go

package models
import (
    "time"
)
type DoctorTb struct {
    Id      int       `xorm:"not null pk autoincr INT(11)"`
    Name    string    `xorm:"default '' comment('姓名') VARCHAR(50)"`
    Age     int       `xorm:"default 0 comment('年齡') INT(11)"`
    Sex     int       `xorm:"default 0 comment('性別') INT(11)"`
    Addtime time.Time `xorm:"DATETIME"`
}

使用xorm

xorm支持鏈式的寫法
engine.Where("age > ?", 40).Or("name like ?", "林%").OrderBy("Id desc").Find(&docList2)
也支持直接執行sql語句
engine.SQL("select * from doctor_tb where age > ?", 40).Find(&docList4)

附上增刪改查事務的demo例子，代碼裏都有註釋，很容易看懂。xorm的封裝比較友好，只要熟悉sql語句，即使不看文檔，也能順利的使用各類關鍵字。

package main

import (
    "fmt"
    _ "github.com/go-sql-driver/mysql"
    "github.com/go-xorm/xorm"
    "goShare/xorm_models/models"
    "time"
)

func main() {

    var engine *xorm.Engine
    //鏈接數據庫
    engine, err := xorm.NewEngine("mysql", "root:112233@tcp(127.0.0.1:3305)/test?charset=utf8")
    if err != nil {
        fmt.Println(err)
        return
    }
    //鏈接測試
    if err := engine.Ping(); err != nil {
        fmt.Println(err)
        return
    }
    defer engine.Close() //延遲關閉數據庫
    fmt.Println("數據庫連接成功")

    //查詢單條數據
    var doc models.DoctorTb
    b, _ := engine.Where("name = ?", "鍾南山").Get(&doc)
    if b {
        fmt.Println(doc)
    } else {
        fmt.Println("數據不存在")
    }

    //查詢單條數據方式2 會根據結構體的
    doc2 := models.DoctorTb{Name: "鍾南山"}
    b, _ = engine.Get(&doc2)
    fmt.Println(doc2)

    //新增數據
    doc3 := models.DoctorTb{0, "王醫生", 48, 1, time.Now()}
    i3, _ := engine.InsertOne(doc3)
    fmt.Println("新增結果：", i3)

    //查詢列表
    docList := make([]models.DoctorTb, 0)
    engine.Where("age > ? or name like ?", 40, "林%").Find(&docList)
    fmt.Println("docList：", docList)

    //查詢列表方式2
    docList2 := make([]models.DoctorTb, 0)
    engine.Where("age > ?", 40).Or("name like ?", "林%").OrderBy("Id desc").Find(&docList2)
    fmt.Println("docList2：", docList2)

    //查詢分頁
    docList3 := make([]models.DoctorTb, 0)
    page := 0     //頁索引
    pageSize := 2 //每頁數據
    limit := pageSize
    start := page * pageSize
    totalCount, err := engine.Where("age > ? or name like ?", 40, "林%").Limit(limit, start).FindAndCount(&docList3)
    fmt.Println("總記錄數：", totalCount, "docList3：", docList3)

    //直接用語句查詢
    docList4 := make([]models.DoctorTb, 0)
    engine.SQL("select * from doctor_tb where age > ?", 40).Find(&docList4)
    fmt.Println("docList4：", docList4)

    //刪除
    docDel := models.DoctorTb{Name: "王醫生"}
    iDel, _ := engine.Delete(&docDel)
    fmt.Println("刪除結果：", iDel)

    //刪除方式2
    engine.Exec("delete from doctor_tb where Id = ?", 3)

    //更新數據
    doc5 := models.DoctorTb{Name: "鍾醫生"}
    //更新數據ID爲2的記錄名字更改成「鍾醫生」
    iUpdate, _ := engine.Id(2).Update(&doc5)
    fmt.Println("更新結果：", iUpdate)

    //指定表名查詢.Table()
    user := models.UserTb{Id: 2}
    b, _ = engine.Table("user_tb").Get(&user)
    fmt.Println(user)

    //事務
    session := engine.NewSession()
    defer session.Close()
    err = session.Begin()
    _, err = session.Exec("delete from doctor_tb where Id = ?", 6)
    if err != nil {
        session.Rollback()
        return
    }
    _, err = session.Exec("delete from user_tb where Id = ?", 10)
    if err != nil {
        session.Rollback()
        return
    }
    err = session.Commit()
    if err != nil {
        return
    }
    fmt.Println("事務執行成功")
}

總結

概括下使用流程
一、下載xorm包和cmd工具包
二、複製cmd工具包裏的模板代碼文件夾至生成目錄底下
三、使用reverse生成數據結構代碼，省去苦力活
四、實例引擎xorm.NewEngine()
五、痛快的調用

demo裏提供了咱們開發業務上經常使用的增，刪，改，查單條數據，查列表，查分頁，事務等內容。若是文章對你有用，請點個贊。