深入分析Go?實現?MySQL?數據庫事務
更新時間：2023年06月12日 08:34:55 作者：尋月隱君
本文深入分析了Go語言實現MySQL數據庫事務的原理和實現方式，包括事務的ACID特性、事務的隔離級別、事務的實現方式等。同時，本文還介紹了Go語言中的事務處理機制和相關的API函數，以及如何使用Go語言實現MySQL數據庫事務。
一、MySQL事務
MySQL事務是指一組數據庫操作，它們被視為一個邏輯單元，并且要么全部成功執(zhí)行，要么全部回滾（撤銷）。事務是數據庫管理系統提供的一種機制，用于確保數據的一致性和完整性。
事務具有以下特性（通常由ACID原則定義）：
- 原子性（Atomicity）：事務中的所有操作要么全部成功執(zhí)行，要么全部回滾，不存在部分執(zhí)行的情況。如果事務中的任何一個操作失敗，則所有操作都會被回滾到事務開始之前的狀態(tài)，保持數據的一致性。
- 一致性（Consistency）：事務的執(zhí)行使數據庫從一個一致的狀態(tài)轉換到另一個一致的狀態(tài)。這意味著在事務開始和結束時，數據必須滿足預定義的完整性約束。
- 隔離性（Isolation）：事務的執(zhí)行是相互隔離的，即一個事務的操作在提交之前對其他事務是不可見的。并發(fā)事務之間的相互影響被隔離，以避免數據損壞和不一致的結果。
- 持久性（Durability）：一旦事務提交成功，其對數據庫的更改將永久保存，即使在系統故障或重啟之后也能保持數據的持久性。
在MySQL中，使用以下語句來開始一個事務：
START TRANSACTION;
在事務中，可以執(zhí)行一系列的數據庫操作，如插入、更新和刪除等。最后，使用以下語句來提交事務或回滾事務：
提交事務：
COMMIT;
回滾事務：
ROLLBACK;
通過使用事務，可以確保數據庫操作的一致性和完整性，尤其在處理涉及多個相關操作的復雜業(yè)務邏輯時非常有用。
二、MySQL 事務 示例
以下是一個示例，演示如何在MySQL中使用事務：
START TRANSACTION;
-- 在事務中執(zhí)行一系列數據庫操作
INSERT INTO users (name, age) VALUES ('Alice', 25);
UPDATE accounts SET balance = balance - 100 WHERE user_id = 1;
DELETE FROM logs WHERE user_id = 1;
-- 如果一切正常，提交事務
COMMIT;在上述示例中，我們開始了一個事務，并在事務中執(zhí)行了一系列數據庫操作。
首先，我們向users表插入了一條新記錄，
然后更新了accounts表中用戶ID為1的賬戶余額，
最后刪除了logs表中與用戶ID為1相關的日志條目。
如果在事務執(zhí)行的過程中出現任何錯誤或異常情況，可以使用ROLLBACK語句回滾事務，使所有操作都被撤銷，數據庫恢復到事務開始之前的狀態(tài)：
START TRANSACTION;
-- 在事務中執(zhí)行一系列數據庫操作
INSERT INTO users (name, age) VALUES ('Bob', 30);
UPDATE accounts SET balance = balance - 200 WHERE user_id = 2;
-- 發(fā)生錯誤或異常，回滾事務
ROLLBACK;
在上述示例中，如果在更新accounts表的操作中發(fā)生錯誤，整個事務將被回滾，插入的用戶記錄和更新的賬戶余額將被撤銷。
事務的關鍵在于將多個相關的數據庫操作組織在一起，并以原子性和一致性的方式進行提交或回滾。這確保了數據的完整性和一致性，同時也提供了靈活性和錯誤恢復機制。
三、MySQL 事務引擎
MySQL提供了多個事務引擎，每個引擎都具有不同的特性和適用場景。以下是MySQL中常見的事務引擎：
- InnoDB：InnoDB是MySQL默認的事務引擎。它支持事務、行級鎖定、外鍵約束和崩潰恢復等功能。InnoDB適用于需要強調數據完整性和并發(fā)性能的應用程序。
- MyISAM：MyISAM是MySQL的另一個常見的事務引擎。它不支持事務和行級鎖定，但具有較高的插入和查詢性能。MyISAM適用于讀密集型應用程序，例如日志記錄和全文搜索。
- NDB Cluster：NDB Cluster是MySQL的集群事務引擎，適用于需要高可用性和可擴展性的分布式應用程序。它具有自動分片、數據冗余和故障恢復等功能。
- Memory：Memory（也稱為Heap）引擎將表數據存儲在內存中，提供非常高的插入和查詢性能。但由于數據存儲在內存中，因此在數據庫重新啟動時數據會丟失。Memory引擎適用于臨時數據或緩存數據的存儲。
除了以上列出的常見事務引擎之外，MySQL還支持其他一些事務引擎，例如Archive、Blackhole等。每個引擎都有其獨特的特性和適用場景，選擇合適的事務引擎需要根據應用程序的需求和性能要求進行評估。
在創(chuàng)建表時，可以指定所需的事務引擎。例如，使用以下語句創(chuàng)建一個使用InnoDB引擎的表：
CREATE TABLE mytable ( id INT PRIMARY KEY, name VARCHAR(50) ) ENGINE=InnoDB;
需要注意的是，不同的事務引擎可能會有不同的配置和限制，因此在選擇和使用特定的事務引擎時，建議參考MySQL文檔以了解詳細信息和最佳實踐。
四、事務實例
開啟事務 Begin 源碼：
// BeginTx starts a transaction.
//
// The provided context is used until the transaction is committed or rolled back.
// If the context is canceled, the sql package will roll back
// the transaction. Tx.Commit will return an error if the context provided to
// BeginTx is canceled.
//
// The provided TxOptions is optional and may be nil if defaults should be used.
// If a non-default isolation level is used that the driver doesn't support,
// an error will be returned.
func (db *DB) BeginTx(ctx context.Context, opts *TxOptions) (*Tx, error) {
var tx *Tx
var err error
err = db.retry(func(strategy connReuseStrategy) error {
tx, err = db.begin(ctx, opts, strategy)
return err
})
return tx, err
}
// Begin starts a transaction. The default isolation level is dependent on
// the driver.
//
// Begin uses context.Background internally; to specify the context, use
// BeginTx.
func (db *DB) Begin() (*Tx, error) {
return db.BeginTx(context.Background(), nil)
}中止事務 Rollback 源碼：
// rollback aborts the transaction and optionally forces the pool to discard
// the connection.
func (tx *Tx) rollback(discardConn bool) error {
if !tx.done.CompareAndSwap(false, true) {
return ErrTxDone
}
if rollbackHook != nil {
rollbackHook()
}
// Cancel the Tx to release any active R-closemu locks.
// This is safe to do because tx.done has already transitioned
// from 0 to 1. Hold the W-closemu lock prior to rollback
// to ensure no other connection has an active query.
tx.cancel()
tx.closemu.Lock()
tx.closemu.Unlock()
var err error
withLock(tx.dc, func() {
err = tx.txi.Rollback()
})
if !errors.Is(err, driver.ErrBadConn) {
tx.closePrepared()
}
if discardConn {
err = driver.ErrBadConn
}
tx.close(err)
return err
}
// Rollback aborts the transaction.
func (tx *Tx) Rollback() error {
return tx.rollback(false)
}提交事務 Commit 源碼：
// Commit commits the transaction.
func (tx *Tx) Commit() error {
// Check context first to avoid transaction leak.
// If put it behind tx.done CompareAndSwap statement, we can't ensure
// the consistency between tx.done and the real COMMIT operation.
select {
default:
case <-tx.ctx.Done():
if tx.done.Load() {
return ErrTxDone
}
return tx.ctx.Err()
}
if !tx.done.CompareAndSwap(false, true) {
return ErrTxDone
}
// Cancel the Tx to release any active R-closemu locks.
// This is safe to do because tx.done has already transitioned
// from 0 to 1. Hold the W-closemu lock prior to rollback
// to ensure no other connection has an active query.
tx.cancel()
tx.closemu.Lock()
tx.closemu.Unlock()
var err error
withLock(tx.dc, func() {
err = tx.txi.Commit()
})
if !errors.Is(err, driver.ErrBadConn) {
tx.closePrepared()
}
tx.close(err)
return err
}例子
package main
import (
"database/sql"
"fmt"
"time"
_ "github.com/go-sql-driver/mysql" // 匿名導入 自動執(zhí)行 init()
)
var db *sql.DB
func initMySQL() (err error) {
//DSN (Data Source Name)
dsn := "root:12345678@tcp(127.0.0.1:3306)/sql_test"
// 注意：要初始化全局的 db 對象，不要新聲明一個 db 變量
db, err = sql.Open("mysql", dsn) // 只對格式進行校驗，并不會真正連接數據庫
if err != nil {
return err
}
// Ping 驗證與數據庫的連接是否仍處于活動狀態(tài)，并在必要時建立連接。
err = db.Ping()
if err != nil {
fmt.Printf("connect to db failed, err: %v\n", err)
return err
}
// 數值需要根據業(yè)務具體情況來確定
db.SetConnMaxLifetime(time.Second * 10) // 設置可以重用連接的最長時間
db.SetConnMaxIdleTime(time.Second * 5) // 設置連接可能處于空閑狀態(tài)的最長時間
db.SetMaxOpenConns(200) // 設置與數據庫的最大打開連接數
db.SetMaxIdleConns(10) // 設置空閑連接池中的最大連接數
return nil
}
type user struct {
id int
age int
name string
}
// 事務操作
func transactionDemo() {
// 啟動事務。默認隔離級別取決于驅動程序。
tx, err := db.Begin() // 開啟事務
if err != nil {
if tx != nil {
tx.Rollback() // 回滾 中止事務
}
fmt.Printf("begin trans failed, err:%v\n", err)
return
}
sqlStr1 := "UPDATE user SET age=? WHERE id=?"
ret1, err := tx.Exec(sqlStr1, 22, 2)
if err != nil {
tx.Rollback() // 回滾
fmt.Printf("exec sql1 failed, err: %v\n", err)
return
}
// RowsAffected 返回受更新、插入或刪除影響的行數。并非每個數據庫或數據庫驅動程序都支持此功能。
affRow1, err := ret1.RowsAffected()
if err != nil {
tx.Rollback() // 回滾
fmt.Printf("exec ret1.RowsAffected() failed, err: %v\n", err)
return
}
sqlStr2 := "UPDATE user SET age=? WHERE id=?"
ret2, err := tx.Exec(sqlStr2, 100, 5)
if err != nil {
tx.Rollback() // 回滾
fmt.Printf("exec sql2 failed, err: %v\n", err)
return
}
affRow2, err := ret2.RowsAffected()
if err != nil {
tx.Rollback() // 回滾
fmt.Printf("exec ret2.RowsAffected() failed, err: %v\n", err)
return
}
fmt.Println(affRow1, affRow2)
if affRow1 == 1 && affRow2 == 1 {
fmt.Println("事務提交...")
tx.Commit() // 提交事務
} else {
tx.Rollback()
fmt.Println("事務回滾...")
}
fmt.Println("exec trans success!")
}
func main() {
if err := initMySQL(); err != nil {
fmt.Printf("connect to db failed, err: %v\n", err)
}
// 檢查完錯誤之后執(zhí)行，確保 db 不為 nil
// Close() 用來釋放數據庫連接相關的資源
// Close 將關閉數據庫并阻止啟動新查詢。關閉，然后等待服務器上已開始處理的所有查詢完成。
defer db.Close()
fmt.Println("connect to database success")
// db.xx() 去使用數據庫操作...
// 事務
transactionDemo()
}
運行
Code/go/mysql_demo via ?? v1.20.3 via ?? base ? go run main.go connect to database success 1 0 事務回滾... exec trans success! Code/go/mysql_demo via ?? v1.20.3 via ?? base ? go run main.go connect to database success 1 1 事務提交... exec trans success! Code/go/mysql_demo via ?? v1.20.3 via ?? base ?
SQL 查詢結果
mysql> select * from user; +----+--------+------+ | id | name | age | +----+--------+------+ | 1 | 小喬 | 16 | | 2 | 小喬 | 12 | | 5 | 昭君 | 12 | | 6 | 黛玉 | 16 | +----+--------+------+ 4 rows in set (0.00 sec) mysql> select * from user; # 第一次執(zhí)行后查詢 +----+--------+------+ | id | name | age | +----+--------+------+ | 1 | 小喬 | 16 | | 2 | 小喬 | 12 | | 5 | 昭君 | 12 | | 6 | 黛玉 | 16 | +----+--------+------+ 4 rows in set (0.00 sec) mysql> select * from user; # 第二次執(zhí)行后查詢 +----+--------+------+ | id | name | age | +----+--------+------+ | 1 | 小喬 | 16 | | 2 | 小喬 | 22 | | 5 | 昭君 | 100 | | 6 | 黛玉 | 16 | +----+--------+------+ 4 rows in set (0.00 sec) mysql>
在上例中，第一次執(zhí)行SQL更新中的sqlStr2值為：age = 100， id = 3。因沒有id為3 的數據，故事務回滾了，即使sqlStr1執(zhí)行成功，也會回滾到事務開始的狀態(tài)。所以第一次執(zhí)行后查詢數據庫，數據未發(fā)生改變。第二次執(zhí)行SQL更新中的sqlStr2值為：age = 100， id = 5。數據庫中存在 id 為 5 的數據，事務提交成功，SQL語句執(zhí)行成功。故第二次執(zhí)行后查詢數據發(fā)生改變，更新成功。
本文詳細介紹了Go語言實現MySQL數據庫事務的原理和實現方式，包括事務的ACID特性、事務的隔離級別、事務的實現方式等。同時，本文還介紹了Go語言中的事務處理機制和相關的API函數，以及如何使用Go語言實現MySQL數據庫事務。通過本文的學習，讀者可以深入了解MySQL數據庫事務的實現原理和Go語言中的事務處理機制，為開發(fā)高性能、高可靠性的數據庫應用程序提供了重要的參考。
到此這篇關于深入分析Go 實現 MySQL 數據庫事務的文章就介紹到這了,更多相關Go 實現 MySQL 數據庫事務內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
相關文章
工作中查看項目代碼,發(fā)現會存在使用?GO?語言做并發(fā)的時候出現各種各樣的異常情況,實際上,出現上述的情況,還是因為我們對于?GO?語言的并發(fā)模型和涉及的?GO?語言基礎不夠扎實,所以本文小編就來帶大家深入了解下Go語言中的并發(fā)模式吧2023-08-08
日志記錄對程序排查問題比較關鍵，所以本文將選擇Logrus和lumberjack兩個庫進行日志切割以及記錄調用源，感興趣的小伙伴可以了解一下2023-07-07
這篇文章主要給大家詳細介紹了Golang 中的 crypto/ecdh 包,主要包括什么是ECDH 算法和crypto/ecdh 包的使用方法,文中通過代碼示例介紹的非常詳細,需要的朋友可以參考下2023-09-09
這篇文章主要介紹了go語言goto語句跳轉到指定的標簽實現方法，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2020-05-05
相信每位編程開發(fā)者們應該都知道,Golang作為一門標榜工程化的語言,提供了非常簡便、實用的編寫單元測試的能力,下面這篇文章主要給大家介紹了關于GoLang基礎學習之go?test測試的相關資料,需要的朋友可以參考下2022-08-08
在golang xorm中使用postgresql的json,array類型的操作
這篇文章主要介紹了在golang xorm中使用postgresql的json,array類型的操作，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2021-04-04
這篇文章主要為大家介紹了Go??import下劃線_使用小技巧,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2023-12-12
這篇文章主要為大家介紹了go開源Hugo站點渲染之模板詞法解析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2023-02-02
Golang學習筆記之安裝Go1.15版本(win/linux/macos/docker安裝)
這篇文章主要介紹了Golang學習筆記之安裝Go1.15版本(win/linux/macos/docker安裝),本文給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2020-12-12
這篇文章主要介紹了Go語言fmt模塊使用的相關資料,fmt庫最基本的功能之一就是格式化輸出,文中通過代碼介紹的非常詳細,需要的朋友可以參考下2025-03-03