未加星标

Golang+MySQL 事务

字体大小 | |
[数据库(mysql) 所属分类 数据库(mysql) | 发布者 店小二05 | 时间 2018 | 作者 红领巾 ] 0人收藏点击收藏

准备知识:mysql事务

1 基本操作 sql.Tx

tx会从连接池中取一个空闲的连接,直至调用 commit 或者 rollback 才会释放

tx, err := db.Begin() // 创建tx对象 tx.Query(command1) tx.Exec(command2) tx.Commit() 2 并发

事务只有 一个连接 ,事务内的操作是 串行 的

db, _ := sql.Open(...) rows, _ := db.Query("SELECT id FROM tt_users") for rows.Next(){ var ( user_id int openid string ) rows.Scan(&user_id) db.QueryRow("SELECT openid FROM tt_users_third WHERE user_id = ?", user_id).Scan(&openid) }

这段代码在并发执行的时候 Query 和 QueryRow 是独立的两个连接。非 tx 对象的操作,每执行一个操作之前会从连接池取空闲连接。

rows, _ := tx.Query("SELECT id FROM tt_users") for rows.Next(){ var ( user_id int openid string ) rows.Scan(&user_id) tx.QueryRow("SELECT openid FROM tt_users_third WHERE user_id = ?", user_id).Scan(&openid) }

tx执行完 Query 方法之后,连接转移到 rows 上,在 Next 方法中, tx.QueryRow 将尝试获取该连接进行操作。因为还没有调用 rows.Close() ,因此连接还处于 busy 状态, tx 无法进行 QueryRow 操作。这时候使用 JOIN 语句可以规避这个问题。

3 实践

事务处理过程中出现了异常为保证数据完整一致性和及时释放连接,需要 rollback 。

tx, err := db.Begin() if err != nil { log.Println(err) } var ( user_id uint openid string ) err = tx.QueryRow("SELECT user_id FROM tt_users WHERE phone = ?", phone).Scan(&user_id) if err != nil { err = tx.Rollback() if err != nil { log.Println("tx.Rollback() Error:" + err.Error()) return } } err = tx.QueryRow("SELECT openid FROM tt_user_third WHERE user_id = ?", user_id).Scan(&openid) if err != nil { err = tx.Rollback() if err != nil { log.Println("tx.Rollback() Error:" + err.Error()) return } } err := tx.Commit() if err != nil { err = tx.Rollback() if err != nil { log.Println("tx.Rollback() Error:" + err.Error()) return } }

这篇文章相当于下面参考文章的一个简单总结,感谢作者“人世间”的分享

参考文章: https://www.jianshu.com/p/bc8120bec94e

本文数据库(mysql)相关术语:navicat for mysql mysql workbench mysql数据库 mysql 存储过程 mysql安装图解 mysql教程 mysql 管理工具

tags: tx,err,id,user,openid,rows,nil,QueryRow,SELECT,Scan,amp,Rollback,tt,Error
分页:12
转载请注明
本文标题:Golang+MySQL 事务
本站链接:https://www.codesec.net/view/586434.html


1.凡CodeSecTeam转载的文章,均出自其它媒体或其他官网介绍,目的在于传递更多的信息,并不代表本站赞同其观点和其真实性负责;
2.转载的文章仅代表原创作者观点,与本站无关。其原创性以及文中陈述文字和内容未经本站证实,本站对该文以及其中全部或者部分内容、文字的真实性、完整性、及时性,不作出任何保证或承若;
3.如本站转载稿涉及版权等问题,请作者及时联系本站,我们会及时处理。
登录后可拥有收藏文章、关注作者等权限...
技术大类 技术大类 | 数据库(mysql) | 评论(0) | 阅读(73)