分享
  1. 首页
  2. 文章

golang 使用xorm操作mysql

叶子 · · 8169 次点击 · · 开始浏览
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

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
1.png
1、xorm驱动包,我们使用xorm的核心包
2、cmd工具包,用于使用reverse命令生成数据表对应的struct

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

生成数据结构struct

本地数据库test有2张数据表,doctor_tb和user_tb,数据结构如下:
3.png
image.png
我们现在就来生成这2张数据表的结构模型。

1、在任意项目下新建一个文件夹xorm_models,文件名没有规定,为了存放生成的代码文件。
2、拷贝cmd工具包中的摸板目录到xorm_models下,在文件目录github.com\go-xorm\cmd\xorm\templates\goxorm

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

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

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

6.png

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

7.png
我们能看到生成了和表名同名的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("事务执行成功")
}

总结

归纳下使用流程
1、下载xorm包和cmd工具包
2、复制cmd工具包里的模板代码文件夹至生成目录底下
3、使用reverse生成数据结构代码,省去苦力活
4、实例引擎xorm.NewEngine()
5、痛快的调用

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


有疑问加站长微信联系(非本文作者)

本文来自:Segmentfault

感谢作者:叶子

查看原文:golang 使用xorm操作mysql

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

关注微信
8169 次点击 ∙ 1 赞
暂无回复
添加一条新回复 (您需要 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传

用户登录

没有账号?注册
(追記) (追記ここまで)

今日阅读排行

    加载中
(追記) (追記ここまで)

一周阅读排行

    加载中

关注我

  • 扫码关注领全套学习资料 关注微信公众号
  • 加入 QQ 群:
    • 192706294(已满)
    • 731990104(已满)
    • 798786647(已满)
    • 729884609(已满)
    • 977810755(已满)
    • 815126783(已满)
    • 812540095(已满)
    • 1006366459(已满)
    • 692541889

  • 关注微信公众号
  • 加入微信群:liuxiaoyan-s,备注入群
  • 也欢迎加入知识星球 Go粉丝们(免费)

给该专栏投稿 写篇新文章

每篇文章有总共有 5 次投稿机会

收入到我管理的专栏 新建专栏