MyBatis-Plus通过version机制实现乐观锁的思路

 更新时间:2021年09月25日 09:19:15   作者:西瓜游侠  
version机制的核心思想就是,假设发生并发冲突的几率很低,只有当更新数据的时候采取检查是否有冲突,而判断是否有冲突的依据就是version的值是否被改变了,这篇文章主要介绍了MyBatis-Plus通过version机制实现乐观锁的思路,需要的朋友可以参考下

MyBatis-Plus是通过version机制实现乐观锁的。

大致思路:

  • 取出记录,携带记录的当前version
  • 更新记录的时候,比较记录当前的version是否有改变;
  • 如果version未改变,则更新记录,并更新version,一般值+1
  • 如果version改变了,则不更新记录。

version机制的核心思想就是,假设发生并发冲突的几率很低,只有当更新数据的时候采取检查是否有冲突,而判断是否有冲突的依据就是version的值是否被改变了。

配置

MyBatis-Plus中配置乐观锁分两步:

  • 实例化OptimisticLockerInnerInterceptor,并添加到MyBatis-Plus的拦截器链中;
  • 定义version字段,并在Entity中使用@Version注解注释version字段。

说明:

支持的数据类型只有: intIntegerlongLongDateTimestampLocalDateTime

整数类型下 newVersion = oldVersion + 1

newVersion 会回写到 entity 中;

仅支持 updateById(id)update(entity, wrapper) 方法;

update(entity, wrapper) 方法下, wrapper 不能复用!!!

配置如下:

首先,实例化OptimisticLockerInnerInterceptor,并添加到拦截器链中:

@Configuration
public class MyBatisPlusConfig {

    /**
     * 插件配置
     *
     * @return
     */
    @Bean
    public MybatisPlusInterceptor mybatisPlusInterceptor() {
        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
        // 向MyBatis-Plus的过滤器链中添加分页拦截器,需要设置数据库类型(主要用于分页方言)
        interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));
        // 添加乐观锁拦截器
        interceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor());
        return interceptor;
    }
}

然后,使用@Version注解:

@Data
@TableName("tb_user")
public class UserEntity {
    private Long id;
    private String name;
    private Integer age;
    private String email;

    @TableField(value = "create_time", fill = FieldFill.INSERT)
    private Date createTime;

    @TableField(value = "update_time", fill = FieldFill.INSERT_UPDATE)
    private Date updateTime;

    @TableLogic(value = "0", delval = "-1")
    @TableField(value = "delete_flag", fill = FieldFill.INSERT)
    private Integer deleteFlag;

    @Version
    @TableField(value = "version", fill = FieldFill.INSERT)
    private Integer version;
}

配置insert时候,version默认值赋1

/**
 * 自动填充字段值得配置
 */
@Component
public class AutoFillFieldValueConfig implements MetaObjectHandler {

    @Override
    public void insertFill(MetaObject metaObject) {
        this.strictInsertFill(metaObject, "createTime", Date.class, new Date());
        this.strictInsertFill(metaObject, "updateTime", Date.class, new Date());
        this.strictInsertFill(metaObject, "deleteFlag", Integer.class, 0);
        this.strictInsertFill(metaObject, "version", Integer.class, 1);
    }

    @Override
    public void updateFill(MetaObject metaObject) {
        this.strictUpdateFill(metaObject, "updateTime", Date.class, new Date());
    }
}

测试一下

1.测试新增记录

首先新增一条数据:

@Test
    public void testVersionInsert() {
        // 插入一个新的用户
        UserEntity newUser = new UserEntity();
        newUser.setId(12L);
        newUser.setName("Kelly");
        newUser.setAge(28);
        newUser.setEmail("Kelly@163.com");
        userMapper.insert(newUser);
    }

控制台日志:

==>  Preparing: INSERT INTO tb_user ( id, name, age, email, create_time, update_time, delete_flag, version ) VALUES ( ?, ?, ?, ?, ?, ?, ?, ? )
==> Parameters: 12(Long), Kelly(String), 28(Integer), Kelly@163.com(String), 2021-09-25 00:14:23.894(Timestamp), 2021-09-25 00:14:23.896(Timestamp), 0(Integer), 1(Integer)
<==    Updates: 1

数据库数据:

在这里插入图片描述

可以看到,新增记录时,version默认赋值为1

2.测试更新记录

下面,来测试一下更新记录,看看version的变化。

   @Test
    public void testVersionUpdate() {
        // 查询用户记录
        UserEntity updateUser = userMapper.selectById(12L);
        // 更新用户记录
        updateUser.setId(12L);
        updateUser.setAge(30);
        userMapper.updateById(updateUser);
    }

注意:这里有一个坑!

一定要先查询出这条数据,再更新,乐观锁才会生效!!!

控制台打印的日志:

==>  Preparing: SELECT id,name,age,email,create_time,update_time,delete_flag,version FROM tb_user WHERE id=? AND delete_flag=0
==> Parameters: 12(Long)
<==    Columns: id, name, age, email, create_time, update_time, delete_flag, version
<==        Row: 12, Kelly, 30, Kelly@163.com, 2021-09-25 00:14:24, 2021-09-25 00:20:24, 0, 1
<==      Total: 1

......

==>  Preparing: UPDATE tb_user SET name=?, age=?, email=?, create_time=?, update_time=?, version=? WHERE id=? AND version=? AND delete_flag=0
==> Parameters: Kelly(String), 30(Integer), Kelly@163.com(String), 2021-09-25 00:14:24.0(Timestamp), 2021-09-25 00:20:24.0(Timestamp), 2(Integer), 12(Long), 1(Integer)
<==    Updates: 1

数据库数据:

在这里插入图片描述

可以看到,version字段由原来的1,更新为2

到此这篇关于MyBatis-Plus通过version机制实现乐观锁的思路的文章就介绍到这了,更多相关MyBatis Plus实现乐观锁内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • Spring框架学习之Spring @Autowired实现自动装配的代码

    Spring框架学习之Spring @Autowired实现自动装配的代码

    自动装配就是说,你不用手动实现bean之间的组合关系,只要使用了@Autowired注解,程序就会自动的注入这个需要的bean,前提是你的Spring容器有这个bean,这篇文章主要介绍了Spring @Autowired实现自动装配,需要的朋友可以参考下
    2021-12-12
  • SpringBoot整合Swagger3的流程详解

    SpringBoot整合Swagger3的流程详解

    这篇文章主要介绍了SpringBoot整合Swagger3的流程详解,Swagger最核心的类就是Docket、它可以配置作者信息、扫描类型,在SwaggerConfig配置类,添加@Configuration和@EnableOpenApi注解,需要的朋友可以参考下
    2024-01-01
  • Java 反射机制详解及实例代码

    Java 反射机制详解及实例代码

    本文主要介绍Java 反射机制的知识,这里提供示例代码帮助大家学习理解此部分知识,有需要的小伙伴可以参考下
    2016-09-09
  • Java实现链表的常见操作算法详解

    Java实现链表的常见操作算法详解

    这篇文章主要介绍了Java实现链表的常见操作算法详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-09-09
  • Java基础之详细总结五种常用运算符

    Java基础之详细总结五种常用运算符

    在通常代码逻辑处理中,我们常常都会使用到运算符,今天我们就详细了解一下运算符的使用以及分类.运算符是对常量或者变量进行操作的符号,它分为算术运算符,赋值运算符,比较运算符,逻辑运算符以及位运算符.需要的朋友可以参考下
    2021-05-05
  • Java中null相关注解的实现

    Java中null相关注解的实现

    本文主要介绍了Java中null相关注解的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2023-04-04
  • Java常用的八种排序算法及代码实现+图解

    Java常用的八种排序算法及代码实现+图解

    这篇文章主要介绍了Java常用的八种排序算法及代码实现,在Java的时候,对于排序的应用需要熟练的掌握,这样才能够确保Java学习时候能够有扎实的基础能力。那Java有哪些排序算法呢?本文小编就来详细说说Java经典的8种排序算法,需要的朋友可以参考一下
    2021-12-12
  • Java模拟登录正方教务抓取成绩、课表、空教室

    Java模拟登录正方教务抓取成绩、课表、空教室

    这篇文章主要介绍了Java模拟登录正方教务抓取成绩、课表、空教室等信息,Java实现模拟登录正方教务抓取成绩、课表、空教室,通过HttpClient来模拟浏览器请求,Jsoup解析网页内容,感兴趣的小伙伴们可以参考一下
    2016-04-04
  • WordPress中卸载插件以及移除文章类型组件的代码示例

    WordPress中卸载插件以及移除文章类型组件的代码示例

    这篇文章主要介绍了WordPress中卸载插件以及移除文章类型组件的代码示例,包括卸载函数钩子的方法介绍,需要的朋友可以参考下
    2015-12-12
  • Java中用Socket实现HTTP文件上传实例

    Java中用Socket实现HTTP文件上传实例

    本篇文章主要介绍了Java中用Socket实现HTTP文件上传实例,详细的介绍了通过读取Socket的输入流来实现一个文件上传的功能,有兴趣的同学可以一起了解一下
    2017-04-04

最新评论