Golang用SELECT FOR UPDATE实现悲观锁更新方法

本文深入解析了在 Go 语言中如何正确使用 SQL 的 `SELECT FOR UPDATE` 实现数据库级行锁（悲观锁），强调其本质依赖 MySQL 或 PostgreSQL 等底层数据库的支持，而非 Go 自身提供锁机制；文章系统梳理了事务开启、索引要求、隔离级别适配、锁类型选择（如 PostgreSQL 的 `FOR NO KEY UPDATE`）、常见致命错误（如漏开事务、未提交/回滚、非索引查询导致表锁）及并发安全陷阱，并给出生产可用的代码范式与避坑指南，帮助开发者真正落地高并发场景下的数据一致性保障。

Go 里用 SELECT FOR UPDATE 做行级悲观锁，本质是靠数据库，不是 Go 自己实现的

Go 本身没有内置“悲观锁”概念，SELECT FOR UPDATE 是 SQL 标准语法，必须由底层数据库（如 MySQL、PostgreSQL）支持并执行。Go 的作用只是正确发起带锁的查询，并在事务中完成后续更新——漏掉事务或提前提交，锁就白加了。

常见错误现象：sql: Transaction has already been committed or rolled back、更新没生效但也不报错、并发时仍出现脏写。

• 必须用 db.Begin() 显式开启事务，不能直接对 *sql.DB 执行 SELECT FOR UPDATE
• MySQL 默认隔离级别是 REPEATABLE READ，但 SELECT FOR UPDATE 在该级别下仍能正确加行锁；PostgreSQL 要求至少 READ COMMITTED
• 锁只在事务结束（Commit() 或 Rollback()）时释放，别忘了 defer rollback

MySQL 场景下，SELECT FOR UPDATE 的写法和易错点

不是所有 SELECT 都能加 FOR UPDATE，它只对索引列有效；如果 WHERE 条件不走索引，MySQL 会升级为表锁，性能雪崩。

示例（安全写法）：

tx, _ := db.Begin()
rows, _ := tx.Query("SELECT id, balance FROM accounts WHERE id = ? FOR UPDATE", accountID)
// 处理 rows 后更新
_, _ := tx.Exec("UPDATE accounts SET balance = ? WHERE id = ?", newBalance, accountID)
tx.Commit()

• WHERE 中的 id 必须是主键或有唯一索引，否则可能锁全表
• 避免在 FOR UPDATE 查询后做耗时操作（如 HTTP 调用），会延长锁持有时间
• MySQL 8.0+ 支持 SELECT ... FOR UPDATE SKIP LOCKED，适合任务队列场景，避免阻塞

PostgreSQL 怎么用 SELECT FOR UPDATE 防止更新丢失

PostgreSQL 对锁更严格：即使 WHERE 条件命中索引，若 UPDATE 涉及未被 SELECT 锁定的列，也可能触发额外锁等待。它还区分 FOR UPDATE 和 FOR NO KEY UPDATE。

• 普通业务更新推荐用 FOR NO KEY UPDATE，它不阻塞其他 SELECT FOR UPDATE 对同一行的非键列修改
• 如果事务中要更新主键或唯一键值，必须用 FOR UPDATE，否则可能违反约束
• PostgreSQL 不支持 SKIP LOCKED 的旧版本（

Go 代码里没加事务、没处理 panic，锁就等于没设

很多同学写了 SELECT FOR UPDATE 却没包事务，或者 defer 了 tx.Rollback() 但忘了在成功路径上 tx.Commit()，结果锁一直挂着直到连接超时。

• 务必用 defer func() { if r := recover(); r != nil { tx.Rollback() } }() 或显式 error 判断来保底 rollback
• 不要复用 *sql.Tx 跨 goroutine，它不是并发安全的
• 连接池设置太小（如 SetMaxOpenConns(1)）会导致后续请求在获取连接时排队，掩盖锁等待的真实耗时

锁的有效性完全取决于事务边界是否清晰、SQL 是否真正命中索引、数据库是否真的执行了锁操作——Go 只是把语句发出去，剩下的得盯住 DB 日志和执行计划。

好了，本文到此结束，带大家了解了《Golang用SELECT FOR UPDATE实现悲观锁更新方法》，希望本文对你有所帮助！关注golang学习网公众号，给大家分享更多Golang知识！