Go 语言操作 MySQL 之 SQLX 包
来源:SegmentFault
时间:2023-01-26 15:08:54 210浏览 收藏
本篇文章给大家分享《Go 语言操作 MySQL 之 SQLX 包》,覆盖了数据库的常见基础知识,其实一个语言的全部知识点一篇文章是不可能说完的,但希望通过这些问题,让读者对自己的掌握程度有一定的认识(B 数),从而弥补自己的不足,更好的掌握它。
友情提示:此篇文章大约需要阅读 14分钟5秒,不足之处请多指教,感谢你的阅读。 订阅本站
SQLX 库
1 | go get github.com/jmoiron/sqlx |
使用操作
连接数据库
1 2 3 4 5 6 7 8 9 10 11 12 | // 初始化数据库 func initMySQL() (err error ) { dsn := "root:password@tcp(127.0.0.1:3306)/database" db, err = sqlx.Open( "mysql" , dsn) if err != nil { fmt.Printf( "connect server failed, err:%v\n" , err) return } db.SetMaxOpenConns( 200 ) db.SetMaxIdleConns( 10 ) return } |
1 2 3 4 5 6 7 8 9 10 11 12 13 | import ( "fmt" _ "github.com/go-sql-driver/mysql" "github.com/jmoiron/sqlx" ) var db *sqlx.DB type user struct { Id int `db: "id" ` Age int `db: "age" ` Name string `db: "name" ` } |
查询操作
查询一行数据
查询一行数据使用
1 | func (db *DB) Get(dest interface {}, query string , args ... interface {}) error |
1 2 3 4 5 6 7 8 9 10 11 | // 查询一行数据 func queryRow() { sqlStr := "SELECT id, name, age FROM user WHERE id = ?" var u user if err := db.Get(&u, sqlStr, 1 ); err != nil { fmt.Printf( "get data failed, err:%v\n" , err) return } fmt.Printf( "id:%d, name:%s, age:%d\n" , u.Id, u.Name, u.Age) } |
查询多行数据
而查询多行数据则使用的是
1 | func (db *DB) Select (dest interface {}, query string , args ... interface {}) error |
使用
1 2 3 4 5 6 7 8 9 10 | // 查询多行数据 func queryMultiRow() { sqlStr := "SELECT id, name, age FROM user WHERE id > ?" var users []user if err := db. Select (&users, sqlStr, 0 ); err != nil { fmt.Printf( "get data failed, err:%v\n" , err) return } for i := 0 ; i |
插入、更新、删除操作
在
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 | // 插入数据 func insertRow() { sqlStr := "INSERT INTO user(name, age) VALUES(?, ?)" result, err := db.Exec(sqlStr, "Meng小羽" , 22 ) if err != nil { fmt.Printf( "exec failed, err:%v\n" , err) return } insertID, err := result.LastInsertId() if err != nil { fmt.Printf( "get insert id failed, err:%v\n" , err) return } fmt.Printf( "insert data success, id:%d\n" , insertID) } |
更新操作
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 | // 更新数据 func updateRow() { sqlStr := "UPDATE user SET age = ? WHERE id = ?" result, err := db.Exec(sqlStr, 22 , 6 ) if err != nil { fmt.Printf( "exec failed, err:%v\n" , err) return } affectedRows, err := result.RowsAffected() if err != nil { fmt.Printf( "get affected failed, err:%v\n" , err) return } fmt.Printf( "update data success, affected rows:%d\n" , affectedRows) } |
删除操作
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 | // 删除一行 func deleteRow() { sqlStr := "DELETE FROM user WHERE id = ?" result, err := db.Exec(sqlStr, 4 ) if err != nil { fmt.Printf( "exec failed, err:%v\n" , err) return } affectedRows, err := result.RowsAffected() if err != nil { fmt.Printf( "get affected failed, err:%v\n" , err) return } fmt.Printf( "delete data success, affected rows:%d\n" , affectedRows) } |
参数绑定
在库中提供最常用的就是
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 | // 绑定查询 func selectNamedQuery() { sqlStr := "SELECT id, name, age FROM user WHERE age = :age" rows, err := db.NamedQuery(sqlStr, map [ string ] interface {}{ "age" : 22 , }) if err != nil { fmt.Printf( "named query failed failed, err:%v\n" , err) return } defer rows. Close () for rows.Next() { var u user if err := rows.StructScan(&u); err != nil { fmt.Printf( "struct sacn failed, err:%v\n" , err) continue } fmt.Printf( "%#v\n" , u) } } |
NamedExec
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 | // 使用 named 方法插入数据 func insertNamedExec() { sqlStr := "INSERT INTO user(name, age) VALUES(:name, :age)" result, err := db.NamedExec(sqlStr, map [ string ] interface {}{ "name" : "里斯" , "age" : 18 , }) if err != nil { fmt.Printf( "named exec failed, err:%v\n" , err) return } insertId, err := result.LastInsertId() if err != nil { fmt.Printf( "get last insert id failed, err:%v\n" , err) return } fmt.Printf( "insert data success, id:%d\n" , insertId) } |
事务操作
使用
1 2 3 4 5 6 | // 开启事务 func (db *DB) Begin() (*Tx, error ) // 回滚事务 func (tx *Tx) Rollback() error // 提交事务 func (tx *Tx) Commit() error |
示例代码:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 | // 事务操作 func updateTransaction() (err error ) { tx, err := db.Begin() if err != nil { fmt.Printf( "transaction begin failed, err:%v\n" , err) return err } defer func () { if p := recover (); p != nil { _ = tx.Rollback() panic (p) } else if err != nil { fmt.Printf( "transaction rollback" ) _ = tx.Rollback() } else { err = tx.Commit() fmt.Printf( "transaction commit" ) return } }() sqlStr1 := "UPDATE user SET age = ? WHERE id = ? " reuslt1, err := tx.Exec(sqlStr1, 18 , 1 ) if err != nil { fmt.Printf( "sql exec failed, err:%v\n" , err) return err } rows1, err := reuslt1.RowsAffected() if err != nil { fmt.Printf( "affected rows is 0" ) return } sqlStr2 := "UPDATE user SET age = ? WHERE id = ? " reuslt2, err := tx.Exec(sqlStr2, 19 , 5 ) if err != nil { fmt.Printf( "sql exec failed, err:%v\n" , err) return err } rows2, err := reuslt2.RowsAffected() if err != nil { fmt.Printf( "affected rows is 0\n" ) return } if rows1 > 0 && rows2 > 0 { fmt.Printf( "update data success\n" ) } return } |
开源支持
最后将此开源项目放在此处,大家要是感兴趣可以给这个开源项目一个 Star,感谢。
参考文章
理论要掌握,实操不能落!以上关于《Go 语言操作 MySQL 之 SQLX 包》的详细介绍,大家都掌握了吧!如果想要继续提升自己的能力,那么就来关注golang学习网公众号吧!
声明:本文转载于:SegmentFault 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
-
499 收藏
-
244 收藏
-
235 收藏
-
157 收藏
-
101 收藏
最新阅读
更多>
-
469 收藏
-
289 收藏
-
239 收藏
-
315 收藏
-
361 收藏
-
184 收藏
-
227 收藏
-
202 收藏
-
140 收藏
-
111 收藏
-
415 收藏
-
454 收藏
课程推荐
更多>
-
- 前端进阶之JavaScript设计模式
- 设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
- 立即学习 542次学习
-
- GO语言核心编程课程
- 本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
- 立即学习 508次学习
-
- 简单聊聊mysql8与网络通信
- 如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
- 立即学习 497次学习
-
- JavaScript正则表达式基础与实战
- 在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
- 立即学习 487次学习
-
- 从零制作响应式网站—Grid布局
- 本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
- 立即学习 484次学习
评论列表
-
- 热情的萝莉
- 感谢大佬分享,一直没懂这个问题,但其实工作中常常有遇到...不过今天到这,帮助很大,总算是懂了,感谢师傅分享博文!
- 2023-05-27 08:40:02
-
- 雪白的发卡
- 这篇博文出现的刚刚好,太细致了,真优秀,收藏了,关注老哥了!希望老哥能多写数据库相关的文章。
- 2023-04-29 15:32:19
-
- 可靠的大米
- 这篇博文出现的刚刚好,很详细,很有用,已加入收藏夹了,关注博主了!希望博主能多写数据库相关的文章。
- 2023-02-04 14:15:33
-
- 欣喜的柠檬
- 很好,一直没懂这个问题,但其实工作中常常有遇到...不过今天到这,帮助很大,总算是懂了,感谢师傅分享技术文章!
- 2023-01-31 13:42:00