SpringBoot+MyBatisPlus中乐观锁的实现示例

 更新时间:2023年08月22日 15:42:22   作者:weixin_43652507  
乐观锁是一种用于解决并发冲突的机制,在数据库中用于保护数据的一致性,本文主要介绍了SpringBoot+MyBatisPlus中乐观锁的实现示例,具有一定的参考价值,感兴趣的可以了解一下

乐观锁加注解@Version后不需要手动进行加1操作。乐观锁是一种用于解决并发冲突的机制,在数据库中用于保护数据的一致性。@Version注解是MyBatisPlus框架中的乐观锁注解,它会在更新数据时自动检查版本号是否一致,如果一致则进行更新操作,如果不一致则表示数据已被其他线程修改过,更新操作会失败。

@Version注解会自动对版本号进行加1操作,所以在使用乐观锁时不需要手动进行加1操作。当进行更新操作时,MyBatisPlus会自动更新版本号,并将更新后的版本号与更新条件一起发送给数据库,如果版本号在更新过程中发生变化,则说明数据已被其他线程修改,更新操作会失败。

因此,使用乐观锁加注解@Version后,可以简化代码,并且可以保证数据的一致性

使用场景: 当要更新一条数据时,希望这条数据没有被别人更新,也就是说实现线程安全的数据更新

1. 数据库新增version字段, int类型, 默认值为0

2. 引入依赖

<!--MyBatisPlus 拦截器-->
<dependency>
	<groupId>com.baomidou</groupId>
	<artifactId>mybatis-plus-boot-starter</artifactId>
	<version>3.5.1</version>
</dependency>

3. springboot启动类中新增bean

     /**
     * 支持拦截器乐观锁
     *
     * @return
     */
    @Bean
    public MybatisPlusInterceptor optimisticLockerInterceptor(){
        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
        interceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor());
        return interceptor;
    }

4. 实体类 version字段贴上注解 &#64;Version

@Version
private Long version;

5. sql更新语句 (&#64;Version注解会自动对版本号进行加1操作&#xff0c;所以在使用乐观锁时不需要手动进行加1操作)

// 没加@Version注解sql
update wx_dept set name=#{name}, sn=#{sn}, version=#{version}+1 where id=#{id} and version=#{version}
// 加了@Version注解sql
update wx_dept set name=#{name}, sn=#{sn}, version=#{version} where id=#{id} and version=#{version}

6. service (乐观锁操作步骤: 每次操作前都是先查询、替换、最后更新, 否则乐观锁无效)

    /**
     * 修改部门
     * 
     * @param wxDept 部门
     * @return 结果
     */
    @Override
    public AjaxResult updateWxDept(WxDept wxDept) {
        // 乐观锁操作步骤: 每次操作前都是先查询、替换、最后更新, 否则乐观锁无效
        // 1. 先查询
        WxDept dept = wxDeptMapper.selectWxDeptById(wxDept.getId());
        log.info("查询出来的数据: {}", dept);
        // 2. 替换
        dept.setName("小卖铺");
        dept.setSn("sell");
        // 3. 最后更新
        int i = wxDeptMapper.updateWxDept(dept);
        if (i > 0) {
            return AjaxResult.success("乐观锁更新成功");
        } else {
            return AjaxResult.error("乐观锁更新失败");
        }
    }

7. 测试

7.1 查询出id是1的数据, 并修改数据 name&#61;小卖铺, sn&#61;sell

查询出来的数据: com.ruoyi.ruoyiwx.dept.domain.WxDept@861f795[
  id=1
  name=开发部
  sn=dev
  version=0
]

7.2 假设

7.1还没更新时, 就有其它线程修改了id为1的数据, 版本号version&#61;1

7.3 上面7.1执行update更新时就会失败, 因为版本号version&#61;1, 不是刚查询出来的version&#61;0

{
    "msg": "乐观锁更新失败",
    "code": 500
}

总结:

1. 每次去拿数据的时候都会认为别人不会修改数据, 所以不会上锁

2. 但是在更新的时候会判断在此期间有没有人去更新过这个数据, 可以使用版本号version

到此这篇关于SpringBoot+MyBatisPlus中乐观锁的实现示例的文章就介绍到这了,更多相关SpringBoot MyBatisPlus乐观锁内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

最新评论