GORM默认不防止不可重复读,因依赖数据库默认Read Committed隔离级别;PostgreSQL中需手动执行SET TRANSACTION ISOLATION LEVEL REPEATABLE READ或使用SELECT FOR UPDATE加行锁来保障一致性。

GORM 本身不阻止不可重复读——它依赖数据库隔离级别,而默认的 Read Committed 在 PostgreSQL/MySQL 中天然允许不可重复读。 你写的业务逻辑“看起来正确”,但两次 SELECT 同一条记录中间若被别人改过,第二次读到的就是新值,旧判断可能已失效。这不是 GORM 的 bug,是默认隔离级别的行为。
PostgreSQL 中不可重复读的真实触发场景
比如库存扣减:先 SELECT stock FROM goods WHERE id = 1 得到 10,判断够用;再执行 UPDATE goods SET stock = stock - 1 WHERE id = 1 AND stock >= 1。看似安全?但在 Read Committed 下,两次查询之间若另一事务把 stock 改成 0 并提交,你的 UPDATE 会失败(影响行数为 0),但你的 Go 代码若没检查 RowsAffected,就会误以为扣成功了。
- 这个现象不是 GORM 导致的,但 GORM 默认不帮你加锁、不自动升级隔离级别
- PostgreSQL 的
REPEATABLE READ实际语义等价于串行化(SERIALIZABLE),能彻底防止不可重复读和幻读 - 但 GORM 的
Session(&gorm.Session{IsolationLevel: ...})对 PostgreSQL 无效——它只对 MySQL 和 SQL Server 生效
在事务中显式设置 REPEATABLE READ(PostgreSQL)
必须用原生 SQL,在 Begin() 之后、任何查询之前立即执行:
tx := db.Begin()
// 关键:必须在这里执行
if err := tx.Exec("SET TRANSACTION ISOLATION LEVEL REPEATABLE READ").Error; err != nil {
tx.Rollback()
return err
}
// 后续所有操作都在该隔离级别下
var g Goods
if err := tx.First(&g, 1).Error; err != nil {
tx.Rollback()
return err
}
// 第二次 First 读到的 g.stock 一定和第一次一致
if err := tx.First(&g, 1).Error; err != nil {
tx.Rollback()
return err
}
return tx.Commit().Error
- 顺序不能错:
SET TRANSACTION必须在事务开启后、第一个业务查询前 - 不能写在
db.Session(...)里——GORM 不会透传这个参数给 PostgreSQL 驱动 - 如果事务里混用
Raw()和模型方法,只要都走同一个tx对象,就受该隔离级别约束
替代方案:SELECT FOR UPDATE(更轻量、更可控)
如果你只需要锁定某几行防并发修改,而不是整个事务升隔离级别,SELECT ... FOR UPDATE 更精准、开销更低:
var g Goods
// 这条语句会加行级写锁,阻塞其他事务对该行的 UPDATE/SELECT FOR UPDATE
if err := tx.Select("stock").Where("id = ?", 1).ForUpdate().First(&g).Error; err != nil {
tx.Rollback()
return err
}
// 此时 stock 值已锁定,后续 UPDATE 可直接基于此值计算
if err := tx.Model(&g).Update("stock", g.Stock-1).Error; err != nil {
tx.Rollback()
return err
}
- 比
REPEATABLE READ更细粒度,不会因事务长导致锁升级或序列化失败回滚 - 注意:PostgreSQL 中
FOR UPDATE锁的是查询命中的行,不是条件本身;若 WHERE 条件无索引,可能锁整张表 - GORM 的
ForUpdate()方法仅在事务内有效,普通db.调用会被忽略
真正容易被忽略的点是:你以为用了事务就安全了,但没确认底层数据库实际生效的隔离级别;而 GORM 在 PostgreSQL 上根本不会替你做这件事——它连提示都不会给。要么手动 Exec("SET TRANSACTION..."),要么用 ForUpdate() 显式加锁,二者选一,别指望默认配置兜底。











