1. Gorm用法介绍

    1.1.2. 数据库连接

    1. import (
    2. "fmt"
    3. "github.com/jinzhu/gorm"
    4. _ "github.com/jinzhu/gorm/dialects/mysql"
    5. )
    6. // UserInfo 用户信息
    7. type UserInfo struct {
    8. ID uint
    9. Name string
    10. Gender string
    11. Hobby string
    12. }
    13. db, err := gorm.Open("mysql", "root:root@(127.0.0.1:3306)/db1?charset=utf8mb4&parseTime=True&loc=Local")
    14. if err!= nil{
    15. panic(err)
    16. }
    17. defer db.Close()
    18. // 自动迁移
    19. u1 := UserInfo{1, "枯藤", "男", "篮球"}
    20. u2 := UserInfo{2, "topgoer.com", "女", "足球"}
    21. // 创建记录
    22. db.Create(&u1)
    23. db.Create(&u2)
    24. // 查询
    25. var u = new(UserInfo)
    26. db.First(u)
    27. fmt.Printf("%#v\n", u)
    28. var uu UserInfo
    29. db.Find(&uu, "hobby=?", "足球")
    30. fmt.Printf("%#v\n", uu)
    31. // 更新
    32. db.Model(&u).Update("hobby", "双色球")
    33. // 删除
    34. db.Delete(&u)
    35. }

    连接比较简单,直接调用 gorm.Open 传入数据库地址即可 github.com/jinzhu/gorm/dialects/mysql 是 golang 的 mysql 驱动,实际上就是 github.com/go-sql-driver/mysql 作者这里为了好记,重新弄了个名字 这里我用的 mysql,实际上支持基本上所有主流的关系数据库,连接方式上略有不同

    1. db.DB().SetMaxIdleConns(10)

    还可以使用 db.DB() 对象设置连接池信息

    1.1.3. 表定义

    先来定义一个点赞表,这里面一条记录表示某个用户在某个时刻对某篇文章点了一个赞,用 ip + ua 来标识用户,title 标识文章标题

    gorm 用 tag 的方式来标识 mysql 里面的约束

    支持时间类型,直接使用 time.Time 即可

    1. if !db.HasTable(&Like{}) {
    2. if err := db.Set("gorm:table_options", "ENGINE=InnoDB DEFAULT CHARSET=utf8").CreateTable(&Like{}).Error; err != nil {
    3. panic(err)
    4. }

    直接通过 db.CreateTable 就可以创建表了,非常方便,还可以通过 db.Set 设置一些额外的表属性

    1.1.5. 插入

    1. like := &Like{
    2. Ip: ip,
    3. Ua: ua,
    4. Title: title,
    5. Hash: murmur3.Sum64([]byte(strings.Join([]string{ip, ua, title}, "-"))) >> 1,
    6. CreatedAt: time.Now(),
    7. }
    8. if err := db.Create(like).Error; err != nil {
    9. return err
    10. }

    先构造已给对象,直接调用 db.Create() 就可以插入一条记录了

    1.1.6. 删除

    先用 db.Where() 构造查询条件,再调用 db.Delete() 就可以删除

    1. var count int
    2. err := db.Model(&Like{}).Where(&Like{Ip: ip, Ua: ua, Title: title}).Count(&count).Error
    3. if err != nil {
    4. return false, err
    5. }

    1.1.8. 修改

    1. db.Model(&user).Update("name", "hello")
    2. db.Model(&user).Updates(User{Name: "hello", Age: 18})
    3. db.Model(&user).Updates(User{Name: "", Age: 0, Actived: false}) // nothing update

    我这个系统里面没有更新需求,这几个例子来自于官网,第一个是更新单条记录;第二个是更新整条记录,注意只有非空字段才会更新;第三个例子是不会更新的,在系统设计的时候要尽量避免这些空值有特殊的含义,如果一定要更新,可以使用第一种方式,设置单个值

    1.1.9. 错误处理

    其实你已经看到了,这里基本上所有的函数都是链式的,全部都返回 db 对象,任何时候调用 db.Error 就能获取到错误信息,非常方便

    事务的处理也很简单,用 db.Begin() 声明开启事务,结束的时候调用 tx.Commit(),异常的时候调用 tx.Rollback()

    1.1.11. 其他

    还可以使用如下方式设置日志输出级别以及改变日志输出地方

    1. db.LogMode(true)
    2. db.SetLogger(gorm.Logger{revel.TRACE})
    3. db.SetLogger(log.New(os.Stdout, "\r\n", 0))