MyBatis-Plus通過(guò)version機(jī)制實(shí)現(xiàn)樂(lè)觀(guān)鎖的思路
MyBatis-Plus是通過(guò)version機(jī)制實(shí)現(xiàn)樂(lè)觀(guān)鎖的。
大致思路：
- 取出記錄，攜帶記錄的當(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è)觀(guān)鎖分兩步：
- 實(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è)觀(guān)鎖攔截器
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è)觀(guān)鎖才會(huì)生效?。。?/strong>
控制臺(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)鎖的思路的文章就介紹到這了,更多相關(guān)MyBatis Plus實(shí)現(xiàn)樂(lè)觀(guān)鎖內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
- Mybatis-Plus樂(lè)觀(guān)鎖配置流程
- MyBatis-Plus樂(lè)觀(guān)鎖插件的用法小結(jié)
- SpringBoot整合MyBatis-Plus樂(lè)觀(guān)鎖不生效的問(wèn)題及解決方法
- Mybatis-Plus進(jìn)階分頁(yè)與樂(lè)觀(guān)鎖插件及通用枚舉和多數(shù)據(jù)源詳解
- mybatis-plus樂(lè)觀(guān)鎖實(shí)現(xiàn)方式詳解
- MP（MyBatis-Plus）實(shí)現(xiàn)樂(lè)觀(guān)鎖更新功能的示例代碼
- MyBatis-Plus 樂(lè)觀(guān)鎖的具體實(shí)現(xiàn)
相關(guān)文章
JavaWeb入門(mén):ServletContext詳解和應(yīng)用
這篇文章主要介紹了Java ServletContext對(duì)象用法解析,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2021-07-07
這篇文章主要介紹了Java中import導(dǎo)入的用法說(shuō)明，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2022-06-06
這篇文章主要介紹了Spring @Cacheable注解中key的使用，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2021-12-12
SpringBoot在項(xiàng)目停止(服務(wù)停止/關(guān)閉退出)之后執(zhí)行的方法
SpringBoot使用ApplicationEvent&Listener完成業(yè)務(wù)解耦
使用RedisAtomicLong優(yōu)化性能問(wèn)題
Java8新特性時(shí)間日期庫(kù)DateTime API及示例詳解
java四種引用及在LeakCanery中應(yīng)用詳解