MyBatisPlus高效开发12式与性能优化实战
1. MyBatisPlus核心价值与定位解析作为MyBatis的增强工具MyBatisPlus在Java持久层领域已经形成了独特的技术生态。与原生MyBatis相比它最大的特点是增强而不改变——这意味着开发者可以在现有MyBatis项目上无缝集成同时获得更强大的功能支持。根据官方统计使用MyBatisPlus后常规CRUD操作的代码量可以减少70%以上这正是它被称为开发效率加速器的根本原因。在实际项目经验中我发现很多团队对MyBatisPlus的认知还停留在基础CRUD封装层面。事实上3.x版本后的MyBatisPlus已经发展成为一个包含代码生成、多租户支持、性能分析等完整解决方案的生态体系。特别是在处理复杂业务场景时那些鲜为人知的高级特性往往能带来意想不到的提效效果。2. 效率提升12式实战详解2.1 智能代码生成器深度定制传统的代码生成器往往只能生成基础实体类和Mapper接口。通过调整Velocity模板我们可以实现全栈代码的一键生成// 配置示例 AutoGenerator generator new AutoGenerator(); StrategyConfig strategy new StrategyConfig() .setNaming(NamingStrategy.underline_to_camel) .setColumnNaming(NamingStrategy.underline_to_camel) .setEntityLombokModel(true) .setRestControllerStyle(true) .setControllerMappingHyphenStyle(true) .setInclude(sys_user,sys_role); // 自定义模板配置 TemplateConfig templateConfig new TemplateConfig() .setController(templates/controller.java.vm) .setService(templates/service.java.vm) .setServiceImpl(templates/serviceImpl.java.vm); generator.setStrategy(strategy); generator.setTemplate(templateConfig);关键技巧将公司项目的通用基类如BaseController、BaseService集成到模板中可使生成的代码直接符合项目规范。2.2 动态表名处理器实战在 SaaS 和多租户系统中动态表名是常见需求。通过实现TableNameHandler接口可以优雅地解决这个问题public class DynamicTableNameHandler implements TableNameHandler { Override public String dynamicTableName(String sql, String tableName) { // 从线程上下文中获取租户ID String tenantId TenantContext.getCurrentTenant(); return tenantId _ tableName; } } // 配置拦截器 Bean public MybatisPlusInterceptor mybatisPlusInterceptor() { MybatisPlusInterceptor interceptor new MybatisPlusInterceptor(); DynamicTableNameInnerInterceptor dynamicTableNameInnerInterceptor new DynamicTableNameInnerInterceptor(); dynamicTableNameInnerInterceptor.setTableNameHandler(new DynamicTableNameHandler()); interceptor.addInnerInterceptor(dynamicTableNameInnerInterceptor); return interceptor; }2.3 高性能批量插入方案当需要处理大量数据插入时传统的循环插入方式性能极差。通过改写SqlInjector可以实现真正的批量插入public class BatchInsertInjector extends DefaultSqlInjector { Override public ListAbstractMethod getMethodList(Class? mapperClass) { ListAbstractMethod methodList super.getMethodList(mapperClass); methodList.add(new BatchInsert()); return methodList; } } // 使用示例 ListUser userList ... // 万级数据 userMapper.batchInsert(userList);实测对比万条数据插入从原来的120秒降至3秒左右。2.4 智能字段填充进阶用法自动填充字段的常见场景包括创建时间、更新时间等。但我们可以扩展更多业务场景public class AuditMetaObjectHandler implements MetaObjectHandler { Override public void insertFill(MetaObject metaObject) { this.strictInsertFill(metaObject, createBy, String.class, getCurrentUser()); this.strictInsertFill(metaObject, createTime, Date.class, new Date()); this.strictInsertFill(metaObject, dataVersion, Integer.class, 1); } Override public void updateFill(MetaObject metaObject) { this.strictUpdateFill(metaObject, updateBy, String.class, getCurrentUser()); this.strictUpdateFill(metaObject, updateTime, Date.class, new Date()); this.setFieldValByName(dataVersion, (Integer)getFieldValByName(dataVersion, metaObject) 1, metaObject); } }2.5 多租户方案深度优化多租户场景下不同表可能需要不同的租户字段。通过自定义TenantLineInnerInterceptor实现精细化控制public class CustomTenantLineHandler implements TenantLineHandler { Override public Expression getTenantId() { return new StringValue(TenantContext.getCurrentTenant()); } Override public boolean ignoreTable(String tableName) { // 系统表不添加租户条件 return tableName.startsWith(sys_); } Override public String getTenantIdColumn() { // 根据表名返回不同的租户字段 String tableName RequestDataHelper.getRequestData(tableName); if(order.equals(tableName)){ return tenant_code; } return tenant_id; } }2.6 逻辑删除与唯一索引冲突解决方案当使用逻辑删除时可能会与数据库唯一索引产生冲突。可以通过以下方案解决TableName(value sys_user, autoResultMap true) public class User { TableId private Long id; TableField(condition SqlCondition.EQUAL) private String username; TableLogic private Integer deleted; // 解决方案添加删除标记到唯一约束 TableField(exist false) private String uniqueKey; public String getUniqueKey() { return username _ deleted; } }在数据库层面创建联合唯一索引(username, deleted)2.7 动态查询条件构建通过Lambda表达式构建动态查询条件使代码更简洁安全public PageUser queryUsers(UserQuery query) { return lambdaQuery() .eq(query.getId() ! null, User::getId, query.getId()) .like(StringUtils.isNotBlank(query.getName()), User::getName, query.getName()) .between(query.getStartTime() ! null query.getEndTime() ! null, User::getCreateTime, query.getStartTime(), query.getEndTime()) .orderByDesc(User::getCreateTime) .page(query.buildPage()); }2.8 枚举类型智能处理通过实现IEnum接口可以实现枚举值与数据库字段的自动转换Getter public enum UserStatus implements IEnumInteger { NORMAL(1, 正常), LOCKED(2, 锁定), DISABLED(3, 禁用); private final int value; private final String desc; UserStatus(int value, String desc) { this.value value; this.desc desc; } Override public Integer getValue() { return this.value; } } // 实体类中使用 TableField(user_status) private UserStatus status;2.9 分页查询性能优化针对大数据量分页查询通过优化拦截器实现性能提升Bean public MybatisPlusInterceptor mybatisPlusInterceptor() { MybatisPlusInterceptor interceptor new MybatisPlusInterceptor(); // 使用优化后的分页拦截器 interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL){ Override protected void optimizeCount(IPage? page, MappedStatement ms, BoundSql boundSql) { // 对特定查询使用快速count方案 if (ms.getId().contains(UserMapper.selectComplexQuery)) { page.setTotal(quickCount(page)); return; } super.optimizeCount(page, ms, boundSql); } }); return interceptor; }2.10 多数据源事务管理结合dynamic-datasource组件实现多数据源分布式事务DS(order) Transactional public void placeOrder(Order order) { orderMapper.insert(order); // 切换到库存数据源 DynamicDataSourceContextHolder.push(stock); try { stockService.reduceInventory(order.getProductId(), order.getQuantity()); } finally { DynamicDataSourceContextHolder.poll(); } }2.11 数据权限精细化控制通过自定义拦截器实现行级数据权限public class DataPermissionInterceptor implements InnerInterceptor { Override public void beforeQuery(Executor executor, MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler, BoundSql boundSql) { // 获取当前用户数据权限范围 DataPermission dataPermission SecurityContext.getDataPermission(); if (dataPermission ! null dataPermission.hasRestriction()) { // 修改SQL添加数据权限条件 String newSql boundSql.getSql() AND dataPermission.toSqlSegment(); resetSql(ms, boundSql, newSql); } } }2.12 审计日志自动记录通过自定义拦截器实现操作审计public class AuditLogInterceptor implements InnerInterceptor { Override public void beforeUpdate(Executor executor, MappedStatement ms, Object parameter) { if (parameter instanceof Map) { Map?,? map (Map?,?) parameter; Object entity map.get(et); if (entity ! null) { saveAuditLog(UPDATE, entity); } } else if (parameter ! null) { saveAuditLog(UPDATE, parameter); } } private void saveAuditLog(String operation, Object entity) { // 记录审计日志逻辑 } }3. 性能调优与生产实践3.1 SQL执行性能监控通过配置性能分析拦截器可以及时发现慢SQLBean public MybatisPlusInterceptor mybatisPlusInterceptor() { MybatisPlusInterceptor interceptor new MybatisPlusInterceptor(); interceptor.addInnerInterceptor(new PerformanceInnerInterceptor(3000)); // 超过3秒记录警告 return interceptor; }建议在生产环境设置合理的阈值并配合日志监控系统实现自动告警。3.2 二级缓存优化策略MyBatis原生二级缓存存在一些局限性可以通过以下方式优化Configuration public class CacheConfig { Bean public MybatisRedisCache mybatisRedisCache() { return new MybatisRedisCache(myCache, redisTemplate()); } } public class MybatisRedisCache implements Cache { // 自定义序列化方式 // 添加缓存过期时间 // 实现缓存命中率监控 }3.3 复杂查询优化方案对于复杂关联查询建议采用以下模式// 1. 主表使用MyBatisPlus查询 PageOrder page orderService.page(query); // 2. 批量获取关联数据 ListLong userIds page.getRecords().stream().map(Order::getUserId).distinct().collect(Collectors.toList()); MapLong, User userMap userService.listByIds(userIds).stream() .collect(Collectors.toMap(User::getId, Function.identity())); // 3. 内存关联 page.getRecords().forEach(order - order.setUser(userMap.get(order.getUserId())));这种方式比直接使用关联查询性能更好特别是在分布式架构中。4. 常见问题排查指南4.1 分页查询结果不正确可能原因及解决方案未正确配置分页拦截器 → 确保PaginationInnerInterceptor已添加到拦截器链自定义SQL未保持参数一致 → 检查count查询与data查询的参数是否匹配多表关联查询未处理重复数据 → 使用DISTINCT或调整关联方式4.2 自动填充字段不生效检查清单实体类字段是否添加TableField(fill FieldFill.INSERT)MetaObjectHandler是否实现并注册为Spring Bean是否使用了wrapper.update(entity)而非wrapper.update()4.3 多租户SQL未正确过滤调试步骤确认TenantLineInnerInterceptor拦截器顺序在分页拦截器之前检查ignoreTable配置是否意外排除了目标表通过日志查看最终执行的SQL语句4.4 逻辑删除与唯一约束冲突解决方案将删除状态包含在唯一约束中使用历史表归档已删除数据采用软删除业务状态组合方案在实际项目中使用MyBatisPlus时建议建立团队内部的开发规范文档明确各种高级特性的使用场景和最佳实践。特别是在多人协作项目中统一的使用方式可以避免很多潜在问题。
