MybatisPlus配置乐观锁
【摘要】 1、乐观锁主要适用场景当要更新一条记录的时候,希望这条记录没有被别人更新,也就是说实现线程安全的数据更新乐观锁实现方式:取出记录时,获取当前version更新时,带上这个version执行更新时, set version = newVersion where version = oldVersion如果version不对,就更新失败 2、乐观锁配置 2.1 数据库中添加version字段 ...
1、乐观锁主要适用场景
当要更新一条记录的时候,希望这条记录没有被别人更新,也就是说实现线程安全的数据更新
乐观锁实现方式:
- 取出记录时,获取当前version
- 更新时,带上这个version
- 执行更新时, set version = newVersion where version = oldVersion
- 如果version不对,就更新失败
2、乐观锁配置
2.1 数据库中添加version字段
2.2 实体类中添加version字段
并添加@Version注解
@Version
@TableField(fill = FieldFill.INSERT)
private Integer version;//版本号
2.3 元对象处理器接口添加version的insert默认值
package com.atguigu.mpdemo1010.handler;
import com.baomidou.mybatisplus.core.handlers.MetaObjectHandler;
import org.apache.ibatis.reflection.MetaObject;
import org.springframework.stereotype.Component;
import java.util.Date;
//自动填充配置类
@Component
public class MyMetaObjectHandler implements MetaObjectHandler {
/**
* mp添加操作时执行
* 插入元对象字段填充(用于插入时对公共字段的填充)
* @param metaObject 元对象
*/
@Override
public void insertFill(MetaObject metaObject) {
this.setFieldValByName("version",1,metaObject);
}
/**
* mp修改操作时执行
* 更新元对象字段填充(用于更新时对公共字段的填充)
*
* @param metaObject 元对象
*/
@Override
public void updateFill(MetaObject metaObject) {
}
}
特别说明:
- 支持的数据类型只有int,Integer,long,Long,Date,Timestamp,LocalDateTime
- 整数类型下 newVersion = oldVersion + 1
- newVersion 会回写到 entity 中
- 仅支持 updateById(id) 与 update(entity, wrapper) 方法
- 在 update(entity, wrapper) 方法下, wrapper 不能复用!!!
2.4 在配置类中注册Bean
package com.atguigu.mpdemo1010.config;
import com.baomidou.mybatisplus.core.injector.ISqlInjector;
import com.baomidou.mybatisplus.extension.injector.LogicSqlInjector;
import com.baomidou.mybatisplus.extension.plugins.OptimisticLockerInterceptor;
import com.baomidou.mybatisplus.extension.plugins.PaginationInterceptor;
import com.baomidou.mybatisplus.extension.plugins.PerformanceInterceptor;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Profile;
/**
* 配置类
*/
@Configuration
@MapperScan("com.atguigu.mpdemo1010.mapper") //这里加上 启动类中就不用加了
public class MpConfig {
/**
* 乐观锁插件
*/
@Bean
public OptimisticLockerInterceptor optimisticLockerInterceptor() {
return new OptimisticLockerInterceptor();
}
}
2.5 测试乐观锁
修改之前version的值为1
测试乐观锁
//测试乐观锁
@Test
public void testOptimisticLocker(){
//根据id查询数据L
User user = userMapper.selectById(1452613718658596866L);
//进行修改
user.setAge(200);
int update = userMapper.updateById(user);
}
执行上述代码之后,version进行了+1操作
从输出的sql语句可以知道,在更新的时候会比较当前查到的version和数据库中的是否相等,若不想等,则会修改失败,避免了丢失更新操作
。
【版权声明】本文为华为云社区用户原创内容,未经允许不得转载,如需转载请自行联系原作者进行授权。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱:
cloudbbs@huaweicloud.com
- 点赞
- 收藏
- 关注作者
评论(0)