0
点赞
收藏
分享

微信扫一扫

MybatisPlus配置乐观锁


乐观锁

  • ​​1、乐观锁主要适用场景​​
  • ​​2、乐观锁配置​​
  • ​​2.1 数据库中添加version字段​​
  • ​​2.2 实体类中添加version字段​​
  • ​​2.3 元对象处理器接口添加version的insert默认值​​
  • ​​2.4 在配置类中注册Bean​​
  • ​​2.5 测试乐观锁​​

1、乐观锁主要适用场景

当要更新一条记录的时候,希望这条记录没有被别人更新,也就是说实现线程安全的数据更新
乐观锁实现方式:

  • 取出记录时,获取当前version
  • 更新时,带上这个version
  • 执行更新时, set version = newVersion where version = oldVersion
  • 如果version不对,就更新失败

2、乐观锁配置

2.1 数据库中添加version字段

MybatisPlus配置乐观锁_字段

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

MybatisPlus配置乐观锁_spring_02


测试乐观锁

//测试乐观锁
@Test
public void testOptimisticLocker(){
//根据id查询数据L
User user = userMapper.selectById(1452613718658596866L);
//进行修改
user.setAge(200);
int update = userMapper.updateById(user);
}

执行上述代码之后,version进行了+1操作

MybatisPlus配置乐观锁_字段_03


MybatisPlus配置乐观锁_字段_04


从输出的sql语句可以知道,在更新的时候会比较当前查到的version和数据库中的是否相等,若不想等,则会修改失败,避免了​​丢失更新操作​​。

MybatisPlus配置乐观锁_spring_05


举报

相关推荐

0 条评论