Go 使用 xorm 操作 MySQL

时间：2022-08-29 20:40:03

Go 使用 xorm 操作 MySQL

本文介绍了 golang orm 库 xorm 的使用和项目结构。

xorm

  1. 官方介绍：xorm是一个简单而强大的Go语言ORM库。
  2. 通过它可以使数据库操作非常简便。xorm的目标并不是让你完全不去学习SQL，
  3. 我们认为SQL并不会为ORM所替代，但是ORM将可以解决绝大部分的简单SQL需求。
  4. xorm支持两种风格的混用。

xorm 还提供了工具，通过 reverse 命令根据数据库的表结构生成对应的 struct，省去了人工组织代码的工作，十分方便。官方地址：https://xorm.io/

安装

浏览 xorm 的 github 地址，我们要下载 2 个包，https://github.com/go-xorm

Go 使用 xorm 操作 MySQL

1、xorm 驱动包，我们使用 xorm 的核心包

2、cmd 工具包，用于使用 reverse 命令生成数据表对应的 struct

通过 go get 命令分别下载 2 个包go get github.com/go-xorm/xormgo get github.com/go-xorm/cmd/xorm下载完成后 github.com 文件夹下会出现 go-xorm 包

Go 使用 xorm 操作 MySQL

生成数据结构 struct

本地数据库 test 有 2 张数据表，doctor_tb 和 user_tb, 数据结构如下：

Go 使用 xorm 操作 MySQL

Go 使用 xorm 操作 MySQL

我们现在就来生成这 2 张数据表的结构模型。

1、在任意项目下新建一个文件夹 xorm_models，文件名没有规定，为了存放生成的代码文件。

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

Go 使用 xorm 操作 MySQL

config 是生成的配置信息，struct.go.tpl 是数据摸板，允许自定义，可以根据自己的项目需求，修改摸板。一般不需要修改。

Go 使用 xorm 操作 MySQL

3、打开 cmd 命令行窗口，进入 xorm_models 目录下，执行 reverse 命令：xorm reverse [数据库类型] [数据库连接串] [模板目录]

  1. xormreversemysqlroot:112233@tcp(127.0.0.1:3305)/test?charset=utf8templates/goxorm

Go 使用 xorm 操作 MySQL

4、数据结构代码会自动生成在 xorm_models/models 目录下。

Go 使用 xorm 操作 MySQL

我们能看到生成了和表名同名的 2 个数据结构文件 doctor_tb.go 和 user_tb.go

  1. packagemodels
  2. import(
  3. "time"
  4. )
  5. typeDoctorTbstruct{
  6. Idint`xorm:"notnullpkautoincrINT(11)"`
  7. Namestring`xorm:"default''comment('姓名')VARCHAR(50)"`
  8. Ageint`xorm:"default0comment('年龄')INT(11)"`
  9. Sexint`xorm:"default0comment('性别')INT(11)"`
  10. Addtimetime.Time`xorm:"DATETIME"`
  11. }

使用 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 语句，即便不看文档，也能顺利的使用各种关键字。

  1. packagemain
  2. import(
  3. "fmt"
  4. _"github.com/go-sql-driver/mysql"
  5. "github.com/go-xorm/xorm"
  6. "goShare/xorm_models/models"
  7. "time"
  8. )
  9. funcmain(){
  10. varengine*xorm.Engine
  11. //连接数据库
  12. engine,err:=xorm.NewEngine("mysql","root:112233@tcp(127.0.0.1:3305)/test?charset=utf8")
  13. iferr!=nil{
  14. fmt.Println(err)
  15. return
  16. }
  17. //连接测试
  18. iferr:=engine.Ping();err!=nil{
  19. fmt.Println(err)
  20. return
  21. }
  22. deferengine.Close()//延迟关闭数据库
  23. fmt.Println("数据库链接成功")
  24. //查询单条数据
  25. vardocmodels.DoctorTb
  26. b,_:=engine.Where("name=?","钟南山").Get(&doc)
  27. ifb{
  28. fmt.Println(doc)
  29. }else{
  30. fmt.Println("数据不存在")
  31. }
  32. //查询单条数据方式2会根据结构体的
  33. doc2:=models.DoctorTb{Name:"钟南山"}
  34. b,_=engine.Get(&doc2)
  35. fmt.Println(doc2)
  36. //新增数据
  37. doc3:=models.DoctorTb{0,"王医生",48,1,time.Now()}
  38. i3,_:=engine.InsertOne(doc3)
  39. fmt.Println("新增结果：",i3)
  40. //查询列表
  41. docList:=make([]models.DoctorTb,0)
  42. engine.Where("age>?ornamelike?",40,"林%").Find(&docList)
  43. fmt.Println("docList：",docList)
  44. //查询列表方式2
  45. docList2:=make([]models.DoctorTb,0)
  46. engine.Where("age>?",40).Or("namelike?","林%").OrderBy("Iddesc").Find(&docList2)
  47. fmt.Println("docList2：",docList2)
  48. //查询分页
  49. docList3:=make([]models.DoctorTb,0)
  50. page:=0//页索引
  51. pageSize:=2//每页数据
  52. limit:=pageSize
  53. start:=page*pageSize
  54. totalCount,err:=engine.Where("age>?ornamelike?",40,"林%").Limit(limit,start).FindAndCount(&docList3)
  55. fmt.Println("总记录数：",totalCount,"docList3：",docList3)
  56. //直接用语句查询
  57. docList4:=make([]models.DoctorTb,0)
  58. engine.SQL("select*fromdoctor_tbwhereage>?",40).Find(&docList4)
  59. fmt.Println("docList4：",docList4)
  60. //删除
  61. docDel:=models.DoctorTb{Name:"王医生"}
  62. iDel,_:=engine.Delete(&docDel)
  63. fmt.Println("删除结果：",iDel)
  64. //删除方式2
  65. engine.Exec("deletefromdoctor_tbwhereId=?",3)
  66. //更新数据
  67. doc5:=models.DoctorTb{Name:"钟医生"}
  68. //更新数据ID为2的记录名字更改为“钟医生”
  69. iUpdate,_:=engine.Id(2).Update(&doc5)
  70. fmt.Println("更新结果：",iUpdate)
  71. //指定表名查询。Table()
  72. user:=models.UserTb{Id:2}
  73. b,_=engine.Table("user_tb").Get(&user)
  74. fmt.Println(user)
  75. //事务
  76. session:=engine.NewSession()
  77. defersession.Close()
  78. err=session.Begin()
  79. _,err=session.Exec("deletefromdoctor_tbwhereId=?",6)
  80. iferr!=nil{
  81. session.Rollback()
  82. return
  83. }
  84. _,err=session.Exec("deletefromuser_tbwhereId=?",10)
  85. iferr!=nil{
  86. session.Rollback()
  87. return
  88. }
  89. err=session.Commit()
  90. iferr!=nil{
  91. return
  92. }
  93. fmt.Println("事务执行成功")
  94. }

总结

归纳下使用流程：

1、下载 xorm 包和 cmd 工具包

2、复制 cmd 工具包里的模板代码文件夹至生成目录底下

3、使用 reverse 生成数据结构代码，省去苦力活

4、实例引擎xorm.NewEngine()

5、痛快的调用

demo 里提供了我们开发业务上常用的增，删，改，查单条数据，查列表，查分页，事务等内容。如果文章对你有用，请点个赞。

原文链接：https://mp.weixin.qq.com/s/Zz_x9j18-l1dcqRvxuJWww

标签：

相关文章