Go 语言操做 MySQL 之 事务操做

友情提示：此篇文章大约须要阅读 5分钟 9秒，不足之处请多指教，感谢你的阅读。 订阅本站

事务

数据库事务( transaction )是访问并可能操做各类数据项的一个数据库操做序列，这些操做要么所有执行,要么所有不执行，是一个不可分割的工做单位。 事务由事务开始与事务结束之间执行的所有数据库操做组成。

MySQL 存储引擎分类有 MyISAM、InnoDB、Memory、Merge等，可是其中最为经常使用的就是 MyISAM 和 InnoDB 两个引擎，这两个引擎中，支持事务的引擎就是 Innodb（MySQL 默认引擎），在建立数据库中要注意对应引擎。

这里能够看一下针对 MySQL 选择引擎的文章：

怎么优雅的选择 MySQL 存储引擎 - Debug客栈

事务 ACID

一般事务必须知足4个条件（ ACID ）：原子性（Atomicity，或称不可分割性）、一致性（Consistency）、隔离性（Isolation，又称独立性）、持久性（Durability）。

Go 操做 MySQL 使用事务

Go语言中使用如下三个方法实现MySQL中的事务操做：

// 开始事务
func (db *DB) Begin() (*Tx, error)
// 回滚事务
func (tx *Tx) Rollback() error
// 提交事务
func (tx *Tx) Commit() error

示例代码：

// 事务更新操做
func transActionUpdate() {
    tx, err := db.Begin()
    if err != nil {
        if tx != nil {
            _ = tx.Rollback()
        }
        fmt.Printf("begin trans action failed, err:%v\n", err)
        return
    }
    sqlStr1 := "UPDATE user SET age = ? WHERE id = ?"
    result1, err := tx.Exec(sqlStr1, 20, 1)
    if err != nil {
        _ = tx.Rollback()
        fmt.Printf("exec failed, err:%v\n", err)
        return
    }
    n1, err := result1.RowsAffected()
    if err != nil {
        _ = tx.Rollback()
        fmt.Printf("exec result1.RowsAffected() failed, err:%v\n", err)
        return
    }
    sqlStr2 := "UPDATE user SET age = ? WHERE id = ?"
    result2, err := tx.Exec(sqlStr2, 20, 6)
    if err != nil {
        _ = tx.Rollback()
        fmt.Printf("exec failed, err:%v\n", err)
        return
    }
    n2, err := result2.RowsAffected()
    if err != nil {
        _ = tx.Rollback()
        fmt.Printf("exec result1.RowsAffected() failed, err:%v\n", err)
        return
    }

    if n1 == 1 && n2 == 1 {
        _ = tx.Commit()
        fmt.Printf("transaction commit success\n")
    } else {
        _ = tx.Rollback()
        fmt.Printf("transaction commit error, rollback\n")
        return
    }
}

参考（学习）文章：Go语言操做MySQL – 李文周的我的博客