Gorm-事务锁定（二）

使用事务锁定避免死锁

在使用事务锁定时，需要注意避免死锁的发生。死锁是指两个或多个goroutine在等待对方释放锁定资源的情况下，陷入了一种互相等待的状态。为了避免死锁的发生，我们应该在进行事务锁定时，按照一定的顺序对数据进行加锁。

下面是一个使用事务锁定避免死锁的示例：

代码语言：javascript复制

package main

import (
    "fmt"

    "gorm.io/driver/mysql"
    "gorm.io/gorm"
)

type Account struct {
    ID      uint
    Balance float64
}

func main() {
    dsn := "user:password@tcp(host:port)/database"
    db, err := gorm.Open(mysql.Open(dsn), &gorm.Config{})
    if err != nil {
        panic(err)
    }
    defer db.Close()

    tx := db.Begin()
    defer func() {
        if r := recover(); r != nil {
            tx.Rollback()
        }
    }()

    var account1, account2 Account
    if err := tx.Set("gorm:query_option", "FOR UPDATE").Where("id = ?", 1).First(&account1).Error; err != nil {
        tx.Rollback()
        panic(err)
    }

    if err := tx.Set("gorm:query_option", "FOR UPDATE").Where("id = ?", 2).First(&account2).Error; err != nil {
        tx.Rollback()
        panic(err)
    }

    if account1.Balance < 100.00 {
        tx.Rollback()
        panic("insufficient balance")
    }

    account1.Balance -= 100.00
    if err := tx.Save(&account1).Error; err != nil {
        tx.Rollback()
        panic(err)
    }

    account2.Balance  = 100.00
    if err := tx.Save(&account2).Error; err != nil {
        tx.Rollback()
        panic(err)
    }

    tx.Commit()
}

在这个示例中，我们定义了一个Account结构体，表示账户信息。我们使用Set方法设置查询选项，并使用Where方法查询id为1和2的账户信息，并将查询结果存储在变量account1和account2中。

我们按照id的大小对两个账户进行加锁，这样可以避免两个goroutine对同一组数据进行加锁，从而避免死锁的发生。接下来，我们检查账户1的余额是否足够，如果不足，则进行回滚操作。

然后，我们分别将账户1的余额减去100元，账户2的余额加上100元，并使用Save方法将修改后的账户信息写入数据库。

最后，我们使用Commit方法提交事务。

0 人点赞