MyBatis-Plus高阶用法与Spring Boot3实战技巧
1. 项目概述
作为一名长期使用MyBatis-Plus进行企业级开发的工程师，我发现很多团队仅仅停留在基础CRUD操作层面，未能充分发挥这个强大工具的价值。特别是在Spring Boot3环境下，MyBatis-Plus 3.5.x版本提供了诸多提升开发效率的高级特性，值得深入挖掘。
本文将重点分享我在实际项目中验证过的5个高阶用法，包括动态表名处理、多租户方案实现、自定义SQL注入器、性能优化技巧以及复杂查询的优雅实现。这些技巧能帮助开发者减少30%以上的重复代码量，特别适合中大型项目中使用。
2. 核心功能解析
2.1 动态表名处理器
在分库分表场景中，动态表名是刚需。MyBatis-Plus提供了DynamicTableNameInnerInterceptor拦截器，我们可以这样配置：
@Bean public MybatisPlusInterceptor mybatisPlusInterceptor() { MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor(); DynamicTableNameInnerInterceptor dynamicTableNameInterceptor = new DynamicTableNameInnerInterceptor(); dynamicTableNameInterceptor.setTableNameHandler((sql, tableName) -> { // 根据业务逻辑动态返回表名 return "t_" + tableName + "_" + LocalDate.now().getYear(); }); interceptor.addInnerInterceptor(dynamicTableNameInterceptor); return interceptor; }注意：动态表名处理会影响SQL缓存，建议在需要动态切换的场景才启用
2.2 多租户方案实现
SaaS系统必备的多租户功能，通过TenantLineInnerInterceptor可以轻松实现：
public class MyTenantLineHandler implements TenantLineHandler { @Override public String getTenantIdColumn() { return "tenant_id"; } @Override public Expression getTenantId() { return new StringValue(RequestContext.getCurrentTenant()); } @Override public boolean ignoreTable(String tableName) { return !Arrays.asList("user","order").contains(tableName); } }配置拦截器时需要注意：
- 排除不需要租户过滤的表（如系统表）
- 确保tenant_id字段在所有需要隔离的表都存在
- 批量插入操作需要特殊处理
3. 高级查询技巧
3.1 复杂条件构造
LambdaQueryWrapper的强大之处在于可以构建类型安全的复杂查询：
public Page<UserVO> queryUsers(UserQuery query) { return lambdaQuery() .select(User::getId, User::getName) .eq(query.getDeptId() != null, User::getDeptId, query.getDeptId()) .between(query.getStartTime() != null && query.getEndTime() != null, User::getCreateTime, query.getStartTime(), query.getEndTime()) .nested(w -> w.like(User::getEmail, "%@gmail.com") .or() .like(User::getEmail, "%@outlook.com")) .orderByDesc(User::getCreateTime) .page(query.toPage()); }3.2 自定义SQL注入器
扩展MyBatis-Plus的SQL功能，比如实现批量插入时忽略重复记录：
public class InsertIgnoreBatch extends AbstractMethod { @Override public MappedStatement injectMappedStatement(...) { String sql = "<script>INSERT IGNORE INTO %s %s VALUES %s</script>"; // 构建SQL逻辑 return addInsertMappedStatement(mapperClass, modelClass, "insertIgnoreBatch", sqlSource, keyGenerator, keyProperty, keyColumn); } }注册自定义方法：
@Bean public MybatisPlusSqlInjector mybatisPlusSqlInjector() { return new MybatisPlusSqlInjector() { @Override public List<AbstractMethod> getMethodList(Class<?> mapperClass) { List<AbstractMethod> methods = super.getMethodList(mapperClass); methods.add(new InsertIgnoreBatch()); return methods; } }; }4. 性能优化实践
4.1 分页查询优化
默认分页查询会执行COUNT(1)，可以通过自定义分页优化：
public class OptimizePaginationInterceptor extends PaginationInnerInterceptor { @Override protected void queryTotal(IPage<?> page, MappedStatement ms, Object parameter, BoundSql boundSql, List<Object> resultList) { // 特定场景下跳过count查询 if (page.getSize() < 10) { page.setTotal(-1L); return; } super.queryTotal(page, ms, parameter, boundSql, resultList); } }4.2 二级缓存整合
整合Redis作为二级缓存提升性能：
@Configuration public class MybatisRedisCacheConfig { @Bean public Cache mybatisRedisCache(RedisTemplate<String, Object> redisTemplate) { return new MybatisRedisCache(redisTemplate) { @Override public String getId() { return "GLOBAL_CACHE"; } @Override public void putObject(Object key, Object value) { // 自定义缓存策略 if (shouldCache(key)) { super.putObject(key, value); } } }; } }5. 实战问题排查
5.1 事务失效场景
常见问题及解决方案：
| 问题现象 | 原因分析 | 解决方案 |
|---|---|---|
| @Transactional不生效 | MyBatis-Plus内置方法未通过代理调用 | 使用自定义Service方法 |
| 批量操作效率低 | 未启用批量模式 | 配置rewriteBatchedStatements=true |
| 分页总数不准 | 关联查询导致 | 使用自定义count查询 |
5.2 类型处理器问题
处理JSON字段的典型配置：
@TableField(typeHandler = FastjsonTypeHandler.class) private UserProfile profile;常见坑点：
- 字段类型与处理器不匹配
- 不同版本JSON库的兼容性问题
- 嵌套对象的循环引用问题
6. 扩展应用场景
6.1 数据权限控制
通过自定义拦截器实现行级数据过滤：
public class DataPermissionInterceptor implements InnerInterceptor { @Override public void beforeQuery(Executor executor, MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler, BoundSql boundSql) { // 注入数据权限SQL String dataPermissionSql = buildDataPermissionSql(); resetSql(boundSql, dataPermissionSql); } }6.2 审计日志记录
自动记录数据变更日志：
public class AuditLogInterceptor implements InnerInterceptor { @Override public void beforeUpdate(Executor executor, MappedStatement ms, Object parameter, BoundSql boundSql) { Object entity = extractEntity(parameter); auditLogService.saveUpdateLog(entity); } }在Spring Boot3中集成时，需要注意拦截器的执行顺序问题，建议通过@Order注解明确指定。