MybatisPlus逻辑删除与唯一性索引冲突：解决方案与最佳实践 ...

在现代软件开发中，数据持久化层的优化和题目解决是确保应用性能和数据同等性的关键。MybatisPlus，作为Mybatis的加强版本，提供了许多便利功能，包罗逻辑删除。然而，逻辑删除与数据库唯一性索引的结合可能会引发一些预料之外的冲突。本文将深入探讨这一题目，并提供一系列解决方案。
1. 明白逻辑删除与唯一性索引

逻辑删除是一种常见的数据处理方式，它通过设置一个标志字段（如deleted）来标记记录是否已被删除，而不是直接从数据库中物理删除数据。这样可以保留历史数据，方便后续审计或数据分析。
唯一性索引则是数据库中用来确保某一列或某几列组合的值的唯一性，防止重复数据的插入。例如，用户表中通常会为username或email列设置唯一性索引。
2. 冲突场景

当一个被逻辑删除的记录仍然占据其唯一性索引的位置时，新数据尝试插入相同值时就会碰到冲突，导致插入失败。例如，如果一个用户的username被逻辑删除后，另一个新用户尝试使用相同的username注册，就会因为唯一性束缚而失败。
3. 解决方案

3.1 修改唯一性索引

最直接的方法是在数据库层面修改唯一性索引，使其仅在非逻辑删除的记录上见效。例如，在MySQL中，可以创建一个包含username和del_at字段的复合唯一性索引：

1. ALTER TABLE users ADD COLUMN del_at datetime NULL DEFAULT 0 COMMENT '删除时间';
2. ALTER TABLE users ADD UNIQUE INDEX unique_username_deleted(username, del_at) USING BTREE;

复制代码

这样，当添加修改时根据username与del_at字段举行唯一性校验。在逻辑删除时需要给del_at字段举行赋值，该字段仅用来存储删除操作时的时间。
注意：给del_at字段默认值是为了避免MySQL数据库索引字段中如果有null时可能会导致唯一性索引失效的题目。
3.2 新建MybatisPlus逻辑删除拦截器

新建一个LogicSqlInnerInterceptor，继承JsqlParserSupport并实现MybatisPlus的InnerInterceptor，在beforePrepare方法中处理逻辑删除时自动给del_at字段赋值为当前操作时间。具体代码如下：

1. import cn.hutool.core.date.DateUtil;
2. import cn.hutool.core.util.ReflectUtil;
3. import com.baomidou.mybatisplus.core.toolkit.PluginUtils;
4. import com.baomidou.mybatisplus.extension.parser.JsqlParserSupport;
5. import com.baomidou.mybatisplus.extension.plugins.inner.InnerInterceptor;
6. import net.sf.jsqlparser.JSQLParserException;
7. import net.sf.jsqlparser.expression.StringValue;
8. import net.sf.jsqlparser.parser.CCJSqlParserUtil;
9. import net.sf.jsqlparser.schema.Column;
10. import net.sf.jsqlparser.statement.Statement;
11. import net.sf.jsqlparser.statement.update.Update;
12. import net.sf.jsqlparser.statement.update.UpdateSet;
13. import org.apache.ibatis.executor.Executor;
14. import org.apache.ibatis.executor.statement.StatementHandler;
15. import org.apache.ibatis.mapping.BoundSql;
16. import org.apache.ibatis.mapping.MappedStatement;
17. import org.apache.ibatis.mapping.SqlCommandType;
18. import org.slf4j.Logger;
19. import org.slf4j.LoggerFactory;
20. import org.springframework.stereotype.Component;
22. import java.sql.Connection;
23. import java.sql.SQLException;
25. /**
26. * 处理逻辑删除的拦截器，当逻辑删除时给delete_at字段赋值当前时间
27. * @author haohaiyang
28. */
29. @Component
30. public class LogicSqlInnerInterceptor extends JsqlParserSupport implements InnerInterceptor {
32.     // 日志记录器
33.     private Logger logger = LoggerFactory.getLogger(LogicSqlInnerInterceptor.class);
35.     @Override
36.     public void beforePrepare(StatementHandler sh, Connection connection, Integer transactionTimeout) {
37.         // 获取MyBatis的MPStatementHandler对象，用于进一步操作
38.         PluginUtils.MPStatementHandler mpSh = PluginUtils.mpStatementHandler(sh);
39.         // 获取映射语句对象，用于判断操作类型
40.         MappedStatement ms = mpSh.mappedStatement();
41.         // 获取SQL命令类型
42.         SqlCommandType sct = ms.getSqlCommandType();
43.         // 判断是否为更新操作
44.         if (sct == SqlCommandType.UPDATE) {
45.             // 获取MPBoundSql对象，用于访问和修改SQL语句及参数
46.             PluginUtils.MPBoundSql mpBs = mpSh.mPBoundSql();
47.             // 判断是否为逻辑删除操作
48.             if (ms.getId().contains(".deleteById") || ms.getId().contains(".deleteBatchIds")) {
49.                 try {
50.                     // 解析SQL语句
51.                     Statement statement = CCJSqlParserUtil.parse(mpBs.sql());
52.                     // 获取参数对象
53.                     Object o = mpBs.parameterObject();
54.                     // 检查参数对象是否包含逻辑删除字段
55.                     if (ReflectUtil.hasField(o.getClass(), "delAt")) {
56.                         // 转换为逻辑删除操作
57.                         Update update = (Update) statement;
58.                         String parsedSQL = this.processParser(update, 0, mpBs.sql(), mpBs.parameterObject());
59.                         mpBs.sql(parsedSQL);
60.                     }
61.                 } catch (JSQLParserException e) {
62.                     throw new RuntimeException(e);
63.                 }
65.             }
66.         }
67.     }
69.     /**
70.      * 处理更新操作的方法
71.      * 将更新操作转换为逻辑删除操作
72.      *
73.      * @param update 更新语句对象
74.      * @param index 更新语句中的索引位置
75.      * @param sql 原始SQL语句
76.      * @param obj SQL语句的参数对象
77.      */
78.     @Override
79.     protected void processUpdate(Update update, int index, String sql, Object obj) {
80.         // 添加逻辑删除的设置
81.         update.addUpdateSet(new UpdateSet(new Column("del_at"), new StringValue(DateUtil.now())));
82.     }
84. }

复制代码

3.3 在MybatisPlusConfig中参加上面创建好的逻辑删除插件

1. import com.baomidou.mybatisplus.annotation.DbType;
2. import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
3. import com.baomidou.mybatisplus.extension.plugins.inner.BlockAttackInnerInterceptor;
4. import com.baomidou.mybatisplus.extension.plugins.inner.OptimisticLockerInnerInterceptor;
5. import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;
6. import com.ruoyi.framework.interceptor.LogicSqlInnerInterceptor;
7. import org.springframework.context.annotation.Bean;
8. import org.springframework.context.annotation.Configuration;
9. import org.springframework.transaction.annotation.EnableTransactionManagement;
10. /**
11. * Mybatis Plus 配置
12. *  * @author ruoyi
13. */
14. @EnableTransactionManagement(proxyTargetClass = true)
15. @Configuration
16. public class MybatisPlusConfig
17. {
18.     @Bean
19.     public MybatisPlusInterceptor mybatisPlusInterceptor()
20.     {
21.         MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
22.         // 分页插件
23.         interceptor.addInnerInterceptor(paginationInnerInterceptor());
24.         // 乐观锁插件
25.         interceptor.addInnerInterceptor(optimisticLockerInnerInterceptor());
26.         // 阻断插件
27.         interceptor.addInnerInterceptor(blockAttackInnerInterceptor());
28.         // 自定义逻辑删除插件
29.         interceptor.addInnerInterceptor(logicSqlInnerInterceptor());
30.         return interceptor;
31.     }
33.     /**
34.      * 分页插件，自动识别数据库类型 https://baomidou.com/guide/interceptor-pagination.html
35.      */
36.     public PaginationInnerInterceptor paginationInnerInterceptor()
37.     {
38.         PaginationInnerInterceptor paginationInnerInterceptor = new PaginationInnerInterceptor();
39.         // 设置数据库类型为mysql
40.         paginationInnerInterceptor.setDbType(DbType.MYSQL);
41.         // 设置最大单页限制数量，默认 500 条，-1 不受限制
42.         paginationInnerInterceptor.setMaxLimit(-1L);
43.         return paginationInnerInterceptor;
44.     }
46.     /**
47.      * 乐观锁插件 https://baomidou.com/guide/interceptor-optimistic-locker.html
48.      */
49.     public OptimisticLockerInnerInterceptor optimisticLockerInnerInterceptor()
50.     {
51.         return new OptimisticLockerInnerInterceptor();
52.     }
54.     /**
55.      * 如果是对全表的删除或更新操作，就会终止该操作 https://baomidou.com/guide/interceptor-block-attack.html
56.      */
57.     public BlockAttackInnerInterceptor blockAttackInnerInterceptor()
58.     {
59.         return new BlockAttackInnerInterceptor();
60.     }
62.     /**
63.      * 自定义逻辑删除插件
64.      */
65.     public LogicSqlInnerInterceptor logicSqlInnerInterceptor()
66.     {
67.         return new LogicSqlInnerInterceptor();
68.     }
69. }

复制代码

4. 实践建议

• 定期清理逻辑删除的数据：虽然逻辑删除可以保留历史数据，但定期清理不再需要的数据可以开释存储空间并优化索引。
  
• 设计时考虑业务需求：在设计数据库和逻辑删除策略时，应充实考虑业务场景，避免不须要的数据冗余。
  
• 性能考量：修改唯一性索引或自定义查询条件可能会对数据库性能产生影响，需要根据实际环境权衡。
  

通过上述方法，我们可以有效解决MybatisPlus中逻辑删除与唯一性索引的冲突，确保数据的完整性和应用的稳定运行。盼望本文能帮助你在碰到类似题目时，可以或许快速定位并解决。如果你在实践中碰到其他挑战，接待在评论区分享你的经验或提问。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。