MyBatis Plus如何实现行锁？

Question

在使用 MyBatis Plus 进行数据库操作时，如何实现行锁（如 for update）以保证并发操作的数据一致性，是一个常见的技术问题。MyBatis Plus 本身并未直接封装行锁机制，但可以通过自定义 SQL 或结合 Wrapper 的方式实现类似效果。例如，在查询语句中手动添加 "FOR UPDATE" 子句，或使用 @SelectProvider 编写带行锁的 SQL。此外，还需考虑事务管理，确保行锁生效范围。那么，如何在 MyBatis Plus 中正确实现行锁并避免死锁？这是开发者在高并发场景下必须掌握的关键技能。

Answer 1

一、MyBatis Plus 中行锁（FOR UPDATE）的实现背景与意义

在高并发场景下，多个线程或事务同时访问数据库中的同一行数据时，可能会导致数据不一致问题。例如，在库存扣减、订单支付等业务中，如果没有合适的并发控制机制，容易出现超卖或重复扣款等问题。

MySQL 提供了行级锁机制，通过 SELECT ... FOR UPDATE 或 SELECT ... LOCK IN SHARE MODE 来实现对特定行的锁定。而 MyBatis Plus 作为一个封装良好的 ORM 框架，并未直接提供行锁封装，但开发者可以通过自定义 SQL 的方式来实现。

二、MyBatis Plus 实现行锁的核心方法

以下是在 MyBatis Plus 中实现行锁的几种常见方式：

1. 使用 Wrapper 构造查询并手动添加 FOR UPDATE 子句
2. 通过 @SelectProvider 编写动态 SQL 并加入 FOR UPDATE
3. 结合原生 SQL 与 LambdaQueryWrapper 进行拼接

1. 使用 Wrapper 添加 FOR UPDATE

虽然 Wrapper 不支持直接添加 FOR UPDATE，但可以借助其构建 SQL 片段后自行拼接：

        QueryWrapper<User> wrapper = new QueryWrapper<>();
        wrapper.eq("id", 1L);
        String sql = "SELECT * FROM user WHERE " + wrapper.getTargetSql() + " FOR UPDATE";
    

2. 使用 @SelectProvider 自定义 SQL

通过 XML 配置或注解方式定义带 FOR UPDATE 的 SQL：

        @SelectProvider(type = UserSqlProvider.class, method = "selectForUpdate")
        User selectForUpdateById(Long id);

        // 对应的 Provider 类
        public String selectForUpdate(Long id) {
            return "SELECT * FROM user WHERE id = #{id} FOR UPDATE";
        }
    

三、事务管理的重要性

行锁的有效性依赖于事务的控制范围。如果不在事务中执行 SELECT FOR UPDATE，则行锁可能不会生效，或者只在当前语句级别存在，无法保证业务逻辑的整体一致性。

因此，在使用行锁时必须配合事务管理：

• 使用 Spring 的 @Transactional 注解开启事务
• 确保所有涉及数据变更的操作都在同一个事务中完成
• 注意事务的隔离级别，推荐使用 REPEATABLE READ 或 READ COMMITTED

四、死锁的预防与处理策略

在高并发系统中，不当使用行锁可能导致死锁问题。以下是常见的预防和处理策略：

策略	描述
统一加锁顺序	对多表操作时，保持一致的加锁顺序，避免交叉等待
缩短事务时间	减少事务执行时间，尽早提交或回滚事务
设置超时时间	为事务设置合理的等待时间，防止无限期阻塞
监控与日志	定期查看数据库死锁日志，分析并优化SQL执行计划

五、实际开发中的最佳实践建议

为了在 MyBatis Plus 中高效、安全地使用行锁，建议遵循以下实践：

1. 尽量避免跨表、跨库操作时加锁，减少锁粒度
2. 在业务层控制重试逻辑，以应对锁等待超时的情况
3. 合理设计索引，避免因全表扫描导致锁升级
4. 对于读多写少的场景，优先考虑共享锁（LOCK IN SHARE MODE）
5. 在分布式环境下，考虑引入分布式锁机制进行补充

六、流程图：行锁实现逻辑示意

            graph TD
                A[开始] --> B{是否需要行锁?}
                B -- 否 --> C[普通查询]
                B -- 是 --> D[开启事务]
                D --> E[执行 SELECT ... FOR UPDATE]
                E --> F[执行后续更新/插入操作]
                F --> G[提交事务]
                G --> H[结束]