14.4 Go Xorm

14.4 Go Xorm

获取xorm

go get -u -v github.com/go-xorm/xorm

xorm增删改查

/**
 * 应用程序
 * 同目录下多文件引用的问题解决方法：
 * https://blog.csdn.net/pingD/article/details/79143235
 * 方法1 1 go build ./ 2 运行编译后的文件
 * 方法2 go run *.go
 */
package main

import (
    "log"
    "fmt"

    "github.com/go-xorm/xorm"
    _ "github.com/go-sql-driver/mysql"
    "time"
)

const DriverName = "mysql"
const MasterDataSourceName = "root:redhat@tcp(123.206.16.61:3306)/superstar?charset=utf8"

/**
CREATE TABLE `user_info` (
  `id` int(10) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键ID',
  `name` varchar(50) NOT NULL DEFAULT '' COMMENT '中文名',
  `sys_created` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '创建时间',
  `sys_updated` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '最后修改时间',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
 */
 //结构体对应数据库表字段
type UserInfo struct {
    Id           int     `xorm:"not null pk autoincr"`//不为空，主键，自增
    Name         string
    SysCreated   int
    SysUpdated   int
}

var engine *xorm.Engine

func main() {
    //初始化数据库引擎
    engine = newEngin()

    //execute()//执行原生sql
    //ormInsert()//orm插入
    //query()
    ormGet()
    //ormGetCols()
    //ormCount()
    //ormFindRows()
    //ormUpdate()
    //ormOmitUpdate()
    //ormMustColsUpdate()

}

// 连接到数据库
func newEngin() *xorm.Engine {
    engine, err := xorm.NewEngine(DriverName, MasterDataSourceName)
    if err != nil {
        log.Fatal(newEngin, err)
        return nil
    }
    // Debug模式，打印全部的SQL语句，帮助对比，看ORM与SQL执行的对照关系
    engine.ShowSQL(true)
    return engine
}

// 通过query方法查询
func query() {
    sql := "SELECT * FROM user_info"
    //查询方式有三种
    //results, err := engine.Query(sql)
    //results, err := engine.QueryInterface(sql)
    results, err := engine.QueryString(sql)//返回一个map切片，可以for range遍历

    if err != nil {
        log.Fatal("query", sql, err)
        return
    }
    total := len(results)
    if total == 0 {
        fmt.Println("没有任何数据", sql)
    } else {
        for i, data := range results {
            fmt.Printf("%d = %v
", i, data)
        }
    }
}

// 通过execute方法执行更新
func execute() {
    sql := `INSERT INTO user_info values(NULL, 'oldboyy', 0, 0)`
    affected, err := engine.Exec(sql)
    if err != nil {
        log.Fatal("execute error", err)
    } else {
        id, _ := affected.LastInsertId()
        rows, _ := affected.RowsAffected()
        fmt.Println("execute id=", id, ", rows=", rows)
    }
}

// 根据models的结构映射数据表
func ormInsert() {
    UserInfo := &UserInfo{
        Id:           0,
        Name:         "梅西",
        SysCreated:   0,
        SysUpdated:   0,
    }
    //SQL转化
    //INSERT INTO `user_info` (`name`,`sys_created`,`sys_updated`) VALUES (?, ?, ?) []interface {}{"梅西", 0, 0}
    id, err := engine.Insert(UserInfo)
    if err != nil {
        log.Fatal("ormInsert error", err)
    } else {
        fmt.Println("ormInsert id=", id)
        fmt.Printf("%v
", *UserInfo)
    }
}

// 根据models的结构读取数据
func ormGet() {
    UserInfo := &UserInfo{Id:1}
    //Get转化sql
    //SELECT `id`, `name`, `sys_created`, `sys_updated` FROM `user_info` WHERE `id`=? LIMIT 1 []interface {}{1}
    ok, err := engine.Get(UserInfo)
    if ok {
        fmt.Printf("%v
", *UserInfo)
    } else if err != nil {
        log.Fatal("ormGet error", err)
    } else {
        fmt.Println("orgGet empty id=", UserInfo.Id)
    }
}

// 获取指定的字段
func ormGetCols() {
    UserInfo := &UserInfo{Id:2}
    ok, err := engine.Cols("name").Get(UserInfo)
    if ok {
        fmt.Printf("%v
", UserInfo)
    } else if err != nil {
        log.Fatal("ormGetCols error", err)
    } else {
        fmt.Println("ormGetCols empty id=2")
    }
}

// 统计
func ormCount() {
    //count, err := engine.Count(&UserInfo{})
    //count, err := engine.Where("name_zh=?", "梅西").Count(&UserInfo{})
    count, err := engine.Count(&UserInfo{Name:"梅西"})
    if err == nil {
        fmt.Printf("count=%v
", count)
    } else {
        log.Fatal("ormCount error", err)
    }
}

// 查找多行数据
func ormFindRows() {
    list := make([]UserInfo, 0)
    //list := make(map[int]UserInfo)
    //err := engine.Find(&list)
    //err := engine.Where("id>?", 1).Limit(100, 0).Find(&list)
    err := engine.Cols("id", "name").Where("id>?", 0).
        Limit(10).Asc("id", "sys_created").Find(&list)

    //list := make([]map[string]string, 0)
    //err := engine.Table("star_info").Cols("id", "name_zh", "name_en").
    // Where("id>?", 1).Find(&list)

    if err == nil {
        fmt.Printf("%v
", list)
    } else {
        log.Fatal("ormFindRows error", err)
    }
}

// 更新一个数据
func ormUpdate() {
    // 全部更新
    //UserInfo := &UserInfo{NameZh:"测试名"}
    //ok, err := engine.Update(UserInfo)
    // 指定ID更新
    UserInfo := &UserInfo{Name:"梅西"}
    ok, err := engine.ID(2).Update(UserInfo)
    fmt.Println(ok, err)
}

// 排除某字段
func ormOmitUpdate() {
    info := &UserInfo{Id:1}
    ok, _ := engine.Get(info)
    if ok {
        if info.SysCreated > 0 {
            ok, _ := engine.ID(info.Id).Omit("sys_created").
                Update(&UserInfo{SysCreated:0,
                    SysUpdated:int(time.Now().Unix())})
            fmt.Printf("ormOmitUpdate, rows=%d, " +
                "sys_created=%d
", ok, 0)
        } else {
            ok, _ := engine.ID(info.Id).Omit("sys_created").
                Update(&UserInfo{SysCreated:1,
                    SysUpdated:int(time.Now().Unix())})
            fmt.Printf("ormOmitUpdate, rows=%d, " +
                "sys_created=%d
", ok, 0)
        }
    }
}

// 字段为空也可以更新（0, 空字符串等）
func ormMustColsUpdate() {
    info := &UserInfo{Id:1}
    ok, _ := engine.Get(info)
    if ok {
        if info.SysCreated > 0 {
            ok, _ := engine.ID(info.Id).
                MustCols("sys_created").
                Update(&UserInfo{SysCreated:0,
                    SysUpdated:int(time.Now().Unix())})
            fmt.Printf("ormMustColsUpdate, rows=%d, " +
                "sys_created=%d
",
                ok, 0)
        } else {
            ok, _ := engine.ID(info.Id).
                MustCols("sys_created").
                Update(&UserInfo{SysCreated:1,
                    SysUpdated:int(time.Now().Unix())})
            fmt.Printf("ormMustColsUpdate, rows=%d, " +
                "sys_created=%d
",
                ok, 0)
        }
    }
}

xorm命令行工具

• 项目地址 https://github.com/go-xorm/cmd
• 设置及mysql数据表，执行xorm命令，生成models
• 生成的代码，项目中直接使用

1.1. 安装步骤

此处网络可能有问题，下载较慢

proxychains4 go get -u -v github.com/go-xorm/cmd
proxychains4 go get -u -v github.com/denisenkom/go-mssqldb
proxychains4 go get -u -v github.com/go-sql-driver/mysql
proxychains4 go get -u -v github.com/lib/pq
proxychains4 go get -u -v github.com/lunny/log
proxychains4 go get -u -v github.com/ziutek/mymysql/godrv

编译xorm命令

进入$GOPATH/src/github.com/go-xorm/cmd/xorm
go build .  
生成xorm命令