Golang+MySQL 事务

埃尔温薛定谔不养猫 · · 7760 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

准备知识: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)
}

这段代码在并发执行的时候QueryQueryRow是独立的两个连接。非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


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

本文来自:简书

感谢作者:埃尔温薛定谔不养猫

查看原文:Golang+MySQL 事务

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

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