MySQL 事务主要用于处理操作量大，复杂度高的数据。在 MySQL 中只有使用了 Innodb 数据库引擎的数据库或表才支持事务。事务用来管理 insert,update,delete 语句，事务处理可以用来维护数据库的完整性，保证成批的 SQL 语句要么全部执行，要么全部不执行。
一般来说，事务是必须满足4个条件（ACID）：：原子性（Atomicity，或称不可分割性）、一致性（Consistency）、隔离性（Isolation，又称独立性）、持久性（Durability）。
本文主要介绍golang实现MySQL数据库事物的提交与回滚。用到的库有：
1"github.com/jmoiron/sqlx" 2_ "github.com/go-sql-driver/mysql"
事务（Transactions）
事务操作是通过三个方法实现：
Begin()：开启事务
Commit()：提交事务（执行sql)
Rollback()：回滚
举例：在事物里操作MySQL任意一步操作出错，都需要Rollback()回滚。
1package main 2 3import ( 4 "fmt" 5 "github.com/alecthomas/log4go" 6 _ "github.com/go-sql-driver/mysql" 7 "github.com/jmoiron/sqlx" 8) 9 10var Db *sqlx.DB 11 12func init() { 13 db,err:=sqlx.Open("mysql","TigerwolfC:123456@tcp(127.0.0.1:3306)/test?charset=utf8") 14 if err != nil { 15 fmt.Println("open mysql failed,", err) 16 return 17 } 18 Db = db 19} 20 21func main() { 22 mysqlTest() 23} 24 25 26func mysqlTest() error{ 27 tx, err := Db.Begin() 28 if err != nil { 29 log4go.Error("open mysql database fail", err) 30 return err 31 } 32 33 result, err := tx.Exec("INSERT INTO userinfo (username, password,department,email) VALUES (?, ?,?,?)","cici","33333","it","TigerwolfC@163.com") 34 if err != nil{ 35 fmt.Println("insert failed,error： ", err) 36 tx.Rollback() 37 return err 38 } 39 id,_ := result.LastInsertId() 40 fmt.Println("insert id is :",id) 41 _, err = tx.Exec("update userinfo set department = ? where username = ?","cekong","hahah") 42 if err != nil{ 43 fmt.Println("update failed error:",err) 44 tx.Rollback() 45 return err 46 } else { 47 fmt.Println("update success!") 48 } 49 _, err = tx.Exec("delete from userinfo where username = ? ", "weiwei") 50 if err != nil{ 51 fmt.Println("delete error:",err) 52 tx.Rollback() 53 return err 54 }else{ 55 fmt.Println("delete success") 56 } 57 return tx.Commit() 58}
当然也可以用defer tx.Rollback()，在程序退出前回滚。
1func mysqlTest() error{ 2 tx, err := Db.Begin() 3 if err != nil { 4 log4go.Error("open mysql database fail", err) 5 } 6 defer tx.Rollback() 7 8 result, err := tx.Exec("INSERT INTO userinfo (username, password,department,email) VALUES (?, ?,?,?)","cici","33333","it","TigerwolfC@163.com") 9 if err != nil{ 10 fmt.Println("insert failed,error： ", err) 11 return err 12 } 13 id,_ := result.LastInsertId() 14 fmt.Println("insert id is :",id) 15 _, err = tx.Exec("update userinfo set department = ? where username = ?","cekong","hahah") 16 if err != nil{ 17 fmt.Println("update failed error:",err) 18 return err 19 } else { 20 fmt.Println("update success!") 21 } 22 _, err = tx.Exec("delete from userinfo where username = ? ", "weiwei") 23 if err != nil{ 24 fmt.Println("delete error:",err) 25 return err 26 }else{ 27 fmt.Println("delete success") 28 } 29 return tx.Commit() 30}
如有不对欢迎指正，相互学习，共同进步。
本文转自 https://blog.csdn.net/wade3015/article/details/87893532，如有侵权，请联系删除。