MyBatisPlus之逻辑删除、MyBatisPlus解决并发问题的乐观锁机制

---

🐌个人主页： 🐌 叶落闲庭
💨我的专栏：💨
c语言
数据结构
javaEE
操作系统

石可破也，而不可夺坚；丹可磨也，而不可夺赤。

---

一、 逻辑删除

• 删除操作业务问题：业务数据从数据库中丢失
• 逻辑删除：为数据设置是否可用的状态字段，删除时设置状态字段为不可用状态，数据保存在数据库中。

1.1 数据库表中添加逻辑删除标记字段

1.2 实体类中添加对应字段，并设定当前字段为逻辑删除标记字段

public class User {
//    @TableId(type = IdType.ASSIGN_ID)
    private Long id;
    @TableField(value = "username")
    private String userName;
    @TableField(value = "password",select = false)
    private String passWord;
    private String gender;
    private String addr;
    @TableField(exist = false)
    private Integer online;
    //逻辑删除字段，标记当前记录是否被删除
    //1表示删除，0表示未删除
    @TableLogic(value = "0",delval = "1")
    private Integer deleted;
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

1.3配置逻辑删除字面值

mybatis-plus:
  global-config:
    banner: false
    db-config:
      logic-delete-field: deleted
      logic-delete-value: 1
      logic-not-delete-value: 0
1
2
3
4
5
6
7

执行SQL语句：UPDATE tb_user SET deleted=1 WHERE id=? AND deleted=0
执行结果：

二、 乐观锁

2.1 数据库表中添加锁标记字段

2.2 实体类中添加对应字段，并设定当前字段为逻辑删除标记字段

public class User {
//    @TableId(type = IdType.ASSIGN_ID)
    private Long id;
    @TableField(value = "username")
    private String userName;
    @TableField(value = "password",select = false)
    private String passWord;
    private String gender;
    private String addr;
    @TableField(exist = false)
    private Integer online;
    //逻辑删除字段，标记当前记录是否被删除
    //1表示删除，0表示未删除
    @TableLogic(value = "0",delval = "1")
    private Integer deleted;
    //实现乐观锁
    @Version
    private Integer version;
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

2.3 配置乐观锁拦截器实现锁机制对应的动态SQL语句拼装

@Configuration
public class MpConfig {
    @Bean
    public MybatisPlusInterceptor mpInterceptor() {
        //1.定义Mp拦截器
        MybatisPlusInterceptor mpInterceptor = new MybatisPlusInterceptor();
        //2.添加乐观锁的拦截器
        mpInterceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor());
        return mpInterceptor;
    }
}
1
2
3
4
5
6
7
8
9
10
11

2.4 使用乐观锁机制在修改前必须先获取到对应数据的version方可正常进行

void testUpdate() {
		//1.先通过要修改的数据id将当前的数据查询出来
		User user = userDao.selectById(4L);
		//2.将要修改的属性逐一设置进去
		user.setUserName("小小");
		userDao.updateById(user);
	}
1
2
3
4
5
6
7

• 执行修改前先执行的查询语句：SELECT id,username,gender,addr,deleted,version FROM tb_user WHERE id=? AND deleted=0
• 执行修改时使用version字段作为乐观锁检查依据：UPDATE tb_user SET username=?, gender=?, addr=?, version=? WHERE id=? AND version=? AND deleted=0