在使用 MySQL 时，避免死锁是一项重要的任务。死锁通常发生在多个事务相互等待对方持有的锁时，导致无法继续执行。
- 遵循一致的访问顺序：确保所有事务在访问多个表或行时，始终以相同的顺序进行访问。这可以显著减少死锁的机会。
- 使用较短的事务：尽量缩短事务的生命周期，减少锁的持有时间。较短的事务可以减少发生死锁的概率。
- 使用适当的隔离级别：选择适合应用程序的隔离级别。MySQL 支持四种隔离级别，较低的隔离级别（如 READ COMMITTED）可以减少锁争用，但可能会引入脏读和不可重复读等问题。：
- READ UNCOMMITTED
- READ COMMITTED
- REPEATABLE READ
- SERIALIZABLE
- 使用索引：确保查询使用索引来减少锁定的行数。全表扫描会锁定更多的行，从而增加死锁的可能性。
- 分析和优化查询：使用 EXPLAIN 命令分析查询执行计划，确保查询尽可能高效，减少锁争用。
- 使用行级锁而不是表级锁：尽量使用行级锁（InnoDB 默认使用行级锁），而不是表级锁。行级锁可以减少锁争用，降低死锁的可能性。
- 捕获和处理死锁：即使采取了所有预防措施，死锁仍可能发生。因此，需要在应用程序中捕获并处理死锁错误。通常的做法是捕获死锁异常，回滚事务并重试。
示例代码
下面是一个使用 Go 和 MySQL 的示例，展示了如何避免死锁以及捕获和处理死锁错误：
代码语言：go复制package main
import (
"database/sql"
"fmt"
"log"
"time"
_ "github.com/go-sql-driver/mysql"
)
func main() {
// 连接到 MySQL
dsn := "user:password@tcp(127.0.0.1:3306)/dbname"
db, err := sql.Open("mysql", dsn)
if err != nil {
log.Fatal(err)
}
defer db.Close()
// 确保连接成功
if err := db.Ping(); err != nil {
log.Fatal(err)
}
// 执行事务
if err := executeTransaction(db); err != nil {
log.Printf("Transaction failed: %v", err)
}
}
func executeTransaction(db *sql.DB) error {
var err error
for i := 0; i < 5; i { // 重试最多 5 次
tx, err := db.Begin()
if err != nil {
return err
}
// 执行查询或更新操作
_, err = tx.Exec("UPDATE table1 SET value1 = value1 1 WHERE id = 1")
if err != nil {
tx.Rollback()
return err
}
_, err = tx.Exec("UPDATE table2 SET value2 = value2 - 1 WHERE id = 1")
if err != nil {
tx.Rollback()
return err
}
// 提交事务
err = tx.Commit()
if err == nil {
return nil // 成功
}
// 检查是否为死锁错误
if isDeadlockError(err) {
log.Printf("Deadlock detected, retrying... (%d/5)", i 1)
time.Sleep(time.Second) // 等待一段时间后重试
continue
}
// 其他错误
return err
}
return fmt.Errorf("transaction failed after 5 retries: %v", err)
}
func isDeadlockError(err error) bool {
if mysqlErr, ok := err.(*mysql.MySQLError); ok {
// Error code 1213: Deadlock found when trying to get lock; try restarting transaction
return mysqlErr.Number == 1213
}
return false
}
