mybatisplus修改加锁

### MyBatis Plus 中实现修改操作时加锁的方式

#### 使用乐观锁机制

在 MyBatis-Plus 中，可以通过版本号字段来实现乐观锁。当一个实体类中存在 `@Version` 注解标注的版本号字段时，MyBatis-Plus 会在更新操作中自动处理版本号的比对和更新。

package com.example.demo.pojo;

import com.baomidou.mybatisplus.annotation.TableName;
import com.baomidou.mybatisplus.annotation.Version;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

@Data
@NoArgsConstructor
@AllArgsConstructor
public class TTest {
    private Long id;
    private Integer count;
    
    @Version
    private Integer version;
}

每次执行更新操作时，MyBatis-Plus 会自动生成带有版本号校验条件的 SQL 语句[^4]：

UPDATE t_test SET count=?, version=version+1 WHERE id=? AND version=?

如果更新过程中发现其他事务已经修改了同一行数据，则更新失败并抛出异常。

#### 配置乐观锁插件

为了使乐观锁生效，还需要配置 MyBatis-Plus 的乐观锁插件。可以在 Spring Boot 应用程序中的 `application.yml` 文件中添加如下配置：

mybatis-plus:
  global-config:
    db-config:
      id-type: auto
  configuration:
    map-underscore-to-camel-case: true
  plugins:
    optimistic-locker: true

同时，在启动类中注册乐观锁插件：

import com.baomidou.mybatisplus.extension.plugins.OptimisticLockerInterceptor;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class MyBatisPlusConfig {

    @Bean
    public OptimisticLockerInterceptor optimisticLockerInterceptor() {
        return new OptimisticLockerInterceptor();
    }
}

通过上述配置，可以确保在执行更新操作时自动启用乐观锁机制[^1]。

#### 更新操作示例

下面是一个完整的更新操作示例，展示了如何使用 MyBatis-Plus 进行带乐观锁的更新操作：

@Service
public class TestService {

    @Autowired
    private TTestMapper testMapper;

    public boolean updateCount(Long id, int newCount) throws Exception {
        // 查询原始记录
        TTest oldRecord = testMapper.selectById(id);
        
        if (oldRecord == null) {
            throw new RuntimeException("记录不存在");
        }

        // 创建新的对象用于更新
        TTest updatedRecord = new TTest();
        updatedRecord.setId(oldRecord.getId());
        updatedRecord.setCount(newCount);

        try {
            // 执行更新操作
            int result = testMapper.updateById(updatedRecord);
            
            if (result != 1) {
                throw new RuntimeException("更新失败，可能已被其他线程修改");
            }
        } catch (Exception e) {
            throw new RuntimeException("更新失败：" + e.getMessage(), e);
        }

        return true;
    }
}

在这个例子中，`updateById` 方法会根据传入的对象及其版本号来进行更新操作。如果有任何并发冲突发生，将会捕获到相应的异常并给出提示信息[^3]。