Go 語言操做 MySQL 之 事務操做

友情提示:此篇文章大約須要閱讀 5分鐘 9秒,不足之處請多指教,感謝你的閱讀。 訂閱本站html

事務

數據庫事務( transaction )是訪問並可能操做各類數據項的一個數據庫操做序列,這些操做要麼所有執行,要麼所有不執行,是一個不可分割的工做單位。 事務由事務開始與事務結束之間執行的所有數據庫操做組成。mysql

MySQL 存儲引擎分類有 MyISAM、InnoDB、Memory、Merge等,可是其中最爲經常使用的就是 MyISAM 和 InnoDB 兩個引擎,這兩個引擎中,支持事務的引擎就是 Innodb(MySQL 默認引擎),在建立數據庫中要注意對應引擎。sql

這裏能夠看一下針對 MySQL 選擇引擎的文章:數據庫

怎麼優雅的選擇 MySQL 存儲引擎 - Debug客棧post

事務 ACID

一般事務必須知足4個條件( ACID ):原子性(Atomicity,或稱不可分割性)、一致性(Consistency)、隔離性(Isolation,又稱獨立性)、持久性(Durability)。學習

image.png

Go 操做 MySQL 使用事務

Go語言中使用如下三個方法實現MySQL中的事務操做:spa

// 開始事務
func (db *DB) Begin() (*Tx, error)
// 回滾事務
func (tx *Tx) Rollback() error
// 提交事務
func (tx *Tx) Commit() error

示例代碼:debug

// 事務更新操做
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 – 李文周的我的博客code

相關文章
相關標籤/搜索