MyBatisPlus乐观锁插件

2023-12-16 12:37:28

当要更新一条记录的时候,希望这条记录没有被别人更新,如果已经更新,则此时更新失败。

  • 乐观锁实现方式
    1)取出记录时,获取当前 version;
    2)更新时,带上这个 version;
    3)执行更新时, set version = newVersion where version = oldVersion,如果 version 不对,就更新失败;

配置方式

乐观锁配置需要两步:

1.配置插件
@Configuration
@MapperScan("com.giser.mybatisplus.mapper")
public class MyBatisPlusConfig {

    @Bean
    public MybatisPlusInterceptor mybatisPlusInterceptor(){
        MybatisPlusInterceptor mybatisPlusInterceptor = new MybatisPlusInterceptor();
        // 添加分页插件
        mybatisPlusInterceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));
        // 添加乐观锁插件
        mybatisPlusInterceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor());
        return mybatisPlusInterceptor;
    }

}
2.在实体类的字段上加上@Version注解
@Data
public class Product {
    private Long id;
    private String name;
    private Integer price;

    @Version
    private Integer version;
}
  • 注意
① 支持的数据类型只有:int,Integer,long,Long,Date,Timestamp,LocalDateTime
② 整数类型下 newVersion = oldVersion + 1
③ newVersion 会回写到 entity 中
④ 仅支持 updateById(id) 与 update(entity, wrapper) 方法
⑤ 在 update(entity, wrapper) 方法下, wrapper 不能复用!!!

测试

@SpringBootTest
public class ConcurrentUpdateTest {

    @Autowired
    private ProductMapper productMapper;

    @Test
    public void testConcurrentUpdate() {
        //小李取数据
        Product p1 = productMapper.selectById(1L);
        //小王取数据
        Product p2 = productMapper.selectById(1L);
        //小李修改 + 50
        p1.setPrice(p1.getPrice() + 50);
        int result1 = productMapper.updateById(p1);
        System.out.println("小李修改的结果:" + result1);
        //小王修改 - 30
        p2.setPrice(p2.getPrice() - 30);
        int result2 = productMapper.updateById(p2);
        System.out.println("小王修改的结果:" + result2);
        if(result2 == 0){
            //失败重试,重新获取version并更新
            p2 = productMapper.selectById(1L);
            p2.setPrice(p2.getPrice() - 30);
            result2 = productMapper.updateById(p2);
        }
        System.out.println("小王修改重试的结果:" + result2);
        //老板看价格
        Product p3 = productMapper.selectById(1L);
        System.out.println("老板看价格:" + p3.getPrice());
    }

}

文章来源:https://blog.csdn.net/SUNBOYmxbsH/article/details/135030489
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。