Go 語言操作 MySQL 之 事務操作
友情提示:此篇文章大約需要閱讀 5分鐘 9秒,不足之處請多指教,感謝你的閱讀。 訂閱本站
事務
數據庫事務( transaction )是訪問並可能操作各種數據項的一個數據庫操作序列,這些操作要麼全部執行,要麼全部不執行,是一個不可分割的工作單位。 事務由事務開始與事務結束之間執行的全部數據庫操作組成。
MySQL 存儲引擎分類有 MyISAM、InnoDB、Memory、Merge等,但是其中最爲常用的就是 MyISAM 和 InnoDB 兩個引擎,這兩個引擎中,支持事務的引擎就是 Innodb(MySQL 默認引擎),在創建數據庫中要注意對應引擎。
這裏可以看一下針對 MySQL 選擇引擎的文章:
事務 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 – 李文周的個人博客
歡迎關注我們的微信公衆號,每天學習Go知識