Go Mysql 事务的使用方式

by · 2018年09月19日 · 343 Words · ~1min reading time | Improve on


原文链接： Go Mysql 事务的使用方式

经过总结和实验，我采用了下面这种写法，defer tx.Rollback() 使得事务回滚始终得到执行。 当 tx.Commit() 执行后，tx.Rollback() 起到关闭事务的作用， 当程序因为某个错误中止，tx.Rollback() 起到回滚事务，同事关闭事务的作用。

普通场景

    func DoSomething() (err error) {
      tx, _ := db.Begin()
      defer tx.Rollback()

      if _, err = tx.Exec(...); err != nil {
          return
      }
      if _, err = tx.Exec(...); err != nil {
          return
      }
      // ...


      err = tx.Commit()
      return
    }

循环场景

(1) 小事务 每次循环提交一次 在循环内部使用这种写法的时候，defer 不能使用，所以要把事务部分抽离到独立的函数当中

func TxDo() (err error) {
    tx, _ := db.Begin()
    defer tx.Rollback()

    if _, err = tx.Exec(...); err != nil {
        return
    }
    if _, err = tx.Exec(...); err != nil {
        return
    }
    // ...


    err = tx.Commit()
    return
}


for {
    if err := TxDo(); err != nil{
         // ...
    }
}

(2) 大事务 批量提交 大事务的场景和普通场景是一样的，没有任何区别

func DoSomething() (err error) {

tx, _ := db.Begin()
defer tx.Rollback()

for{
    if _, err = tx.Exec(...); err != nil {
        return
    }
    if _, err = tx.Exec(...); err != nil {
        return
    }
    // ...
}

err = tx.Commit()
return

}

参考链接:

https://stackoverflow.com/questions/16184238/database-sql-tx-detecting-commit-or-rollback

Tags:

`