Go语言中使用Gin框架配合 GORM 实现乐观锁并发控制-Golang-PHP中文网

gorm默认update不带版本校验，导致并发时后写入覆盖前写入；必须显式用where加version条件、set递增version、执行后检查rowsaffected是否为0，三者缺一不可。

go语言中使用gin框架配合 gorm 实现乐观锁并发控制

为什么直接用 GORM 的 `Update` 会丢更新？

多个请求同时读取同一条记录、各自修改后调用 Save 或 Update，后写入的会覆盖前写入的——GORM 默认不带版本校验，本质是“最后提交者胜出”，不是并发安全的。这不是 Gin 的问题，而是没启用乐观锁机制。

乐观锁的核心是：更新时检查数据是否被别人改过。GORM 支持通过 UpdatedAt 字段或自定义 Version 字段实现，但必须显式参与 WHERE 条件，否则无效。

UpdatedAt 字段默认由 GORM 自动维护，但仅用于记录时间，不会自动加入 UPDATE 的 WHERE 条件
必须手动在 Where 中带上旧的 UpdatedAt 值，或使用 Version 字段配合 OptimisticLock 插件
Gin 路由里不做额外同步控制，所有并发压力都落到数据库层，靠 SQL 条件拦截失败

怎么让 GORM 在 Update 时带上版本检查？

推荐用 Version 字段 + gorm.Model 组合，比依赖 UpdatedAt 更可靠：时间精度有限、时钟不同步、人为修改都可能破坏一致性。

结构体定义示例：

type Order struct {
    gorm.Model
    UserID    uint   `gorm:"index"`
    Amount    int64
    Status    string
    Version   int64  `gorm:"column:version;default:1"` // 必须显式声明字段
}

更新时写法关键点：

先查出当前 Version 值（比如 v := order.Version）
用 Where("id = ? AND version = ?", order.ID, v).Save(&order)
检查 result.RowsAffected == 0，为真说明已被别人抢先更新，当前操作失效

注意：Save 不会自动递增 Version，要自己加一；Update 同理，需显式设置 Version 新值。

Gin框架 1.9.0

Gin框架 1.9.0版本源码包下载，版本号 1.9.0，适合需要 sonic JSON 支持、路由修复和内容协商改进的 Go Web 开发场景。

下载

Gin 路由里怎么返回合理的并发冲突响应？

不能让前端反复重试却得不到明确反馈。GORM 执行失败时不会 panic，只是 RowsAffected 为 0，需要主动判断。

典型 Gin handler 片段：

func updateOrder(c *gin.Context) {
    var order Order
    if err := c.ShouldBindJSON(&order); err != nil {
        c.AbortWithStatusJSON(400, gin.H{"error": err.Error()})
        return
    }

    // 先查旧值（含 version）
    var old Order
    if err := db.Where("id = ?", order.ID).First(&old).Error; err != nil {
        c.AbortWithStatusJSON(404, gin.H{"error": "not found"})
        return
    }

    // 设置新 version
    order.Version = old.Version + 1

    // 带 version 条件更新
    result := db.Where("id = ? AND version = ?", order.ID, old.Version).Save(&order)
    if result.Error != nil {
        c.AbortWithStatusJSON(500, gin.H{"error": result.Error.Error()})
        return
    }
    if result.RowsAffected == 0 {
        c.AbortWithStatusJSON(409, gin.H{"error": "concurrent update conflict", "current_version": old.Version})
        return
    }
    c.JSON(200, order)
}

关键细节：