MyBatis-Plus是通過(guò)version機(jī)制實(shí)現(xiàn)樂(lè)觀鎖的。

大致思路：

• 取出記錄，攜帶記錄的當(dāng)前version；
• 更新記錄的時(shí)候，比較記錄當(dāng)前的version是否有改變；
• 如果version未改變，則更新記錄，并更新version，一般值+1；
• 如果version改變了，則不更新記錄。

version機(jī)制的核心思想就是，假設(shè)發(fā)生并發(fā)沖突的幾率很低，只有當(dāng)更新數(shù)據(jù)的時(shí)候采取檢查是否有沖突，而判斷是否有沖突的依據(jù)就是version的值是否被改變了。

配置

MyBatis-Plus中配置樂(lè)觀鎖分兩步：

• 實(shí)例化OptimisticLockerInnerInterceptor，并添加到MyBatis-Plus的攔截器鏈中；
• 定義version字段，并在Entity中使用@Version注解注釋version字段。

說(shuō)明:

支持的數(shù)據(jù)類(lèi)型只有: int、Integer、long、Long、Date、Timestamp、LocalDateTime；

整數(shù)類(lèi)型下 newVersion = oldVersion + 1；

newVersion 會(huì)回寫(xiě)到 entity 中；

僅支持 updateById(id) 與 update(entity, wrapper) 方法；

在 update(entity, wrapper) 方法下， wrapper 不能復(fù)用!!!

配置如下：

首先，實(shí)例化OptimisticLockerInnerInterceptor，并添加到攔截器鏈中：

@Configuration
public class MyBatisPlusConfig {

    /**
     * 插件配置
     *
     * @return
     */
    @Bean
    public MybatisPlusInterceptor mybatisPlusInterceptor() {
        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
        // 向MyBatis-Plus的過(guò)濾器鏈中添加分頁(yè)攔截器，需要設(shè)置數(shù)據(jù)庫(kù)類(lèi)型（主要用于分頁(yè)方言）
        interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));
        // 添加樂(lè)觀鎖攔截器
        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時(shí)候，version默認(rèn)值賦1：

/**
 * 自動(dòng)填充字段值得配置
 */
@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());
    }
}

測(cè)試一下

1.測(cè)試新增記錄

首先新增一條數(shù)據(jù)：

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

控制臺(tái)日志：

==>  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

數(shù)據(jù)庫(kù)數(shù)據(jù)：

可以看到，新增記錄時(shí)，version默認(rèn)賦值為1。

2.測(cè)試更新記錄

下面，來(lái)測(cè)試一下更新記錄，看看version的變化。

   @Test
    public void testVersionUpdate() {
        // 查詢(xún)用戶(hù)記錄
        UserEntity updateUser = userMapper.selectById(12L);
        // 更新用戶(hù)記錄
        updateUser.setId(12L);
        updateUser.setAge(30);
        userMapper.updateById(updateUser);
    }

注意：這里有一個(gè)坑！

一定要先查詢(xún)出這條數(shù)據(jù)，再更新，樂(lè)觀鎖才會(huì)生效?。?！

控制臺(tái)打印的日志：

==>  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

數(shù)據(jù)庫(kù)數(shù)據(jù)：

可以看到，version字段由原來(lái)的1，更新為2。

到此這篇關(guān)于MyBatis-Plus通過(guò)version機(jī)制實(shí)現(xiàn)樂(lè)觀鎖的思路的文章就介紹到這了,更多相關(guān)MyBatis Plus實(shí)現(xiàn)樂(lè)觀鎖內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論