企业官网建设流程全解析

1. MyBatis-Plus核心特性解析

MyBatis-Plus作为MyBatis的增强工具包，在Java持久层开发中已经成为事实上的行业标准。我在实际项目中使用该框架近五年，处理过日均百万级流量的电商系统，也搭建过复杂的金融交易平台。以下从实战角度剖析其核心价值：

非侵入式设计是MP（MyBatis-Plus简称）最精妙的特点。它通过巧妙的方法注入和动态代理机制，在不修改MyBatis原生代码的前提下扩展功能。这意味着：

• 已有MyBatis项目可无缝升级
• 与SpringBoot的自动配置完美融合
• 随时可以回退到原生MyBatis模式

重要提示：升级时注意mybatis和mybatis-plus的版本兼容性，建议参考官方版本矩阵

2. 高频面试题深度剖析

2.1 动态表名处理方案

多租户系统中动态表名是常见需求。MP提供多种实现方式：

// 方案1：分页插件配置动态表名处理器 public class MyPaginationInterceptor extends PaginationInnerInterceptor { @Override protected String changeTableName(String sql, long page, long size) { return sql.replace("order", TenantContext.getTablePrefix()+"_order"); } } // 方案2：自定义SQL解析器 public class DynamicTableNameParser implements ISqlParser { @Override public SqlInfo parser(MetaObject metaObject, String sql) { String newSql = SqlUtils.replaceTable(sql, "user", TenantContext.getCurrentTenant()+"_user"); return SqlInfo.newInstance().setSql(newSql); } }

避坑指南：

1. 分布式环境下需要同步租户上下文
2. 表名缓存可能导致动态失效
3. 连表查询需要特殊处理关联表名

2.2 多数据源事务管理

结合dynamic-datasource组件实现多源事务：

# application.yml配置示例 spring: datasource: dynamic: primary: master strict: true datasource: master: url: jdbc:mysql://localhost:3306/main username: root password: 123456 slave1: url: jdbc:mysql://192.168.1.1:3306/replica username: repl password: repl123

// 事务注解使用示例 @DS("slave1") @Transactional(rollbackFor = Exception.class) public void crossDatabaseOperation() { // 操作slave1数据源 userMapper.insert(...); // 切换数据源 DynamicDataSourceContextHolder.push("master"); orderMapper.update(...); }

性能优化点：

• 数据源连接池建议使用HikariCP
• 读写分离场景建议配置负载均衡策略
• 事务传播行为需要特别注意

3. 高级特性实战技巧

3.1 逻辑删除与唯一索引冲突

当字段设置逻辑删除时，与数据库唯一索引会产生冲突。解决方案：

-- 数据库方案：创建包含delete_status的复合唯一索引 ALTER TABLE user ADD UNIQUE idx_username (username, delete_status);

// 代码方案：重写逻辑删除处理器 public class MyLogicSqlInjector extends DefaultSqlInjector { @Override public List<AbstractMethod> getMethodList(Class<?> mapperClass) { List<AbstractMethod> methods = super.getMethodList(mapperClass); methods.add(new LogicDeleteByIdWithFill()); return methods; } }

3.2 字段自动填充最佳实践

审计字段自动填充的进阶用法：

@Slf4j public class MyMetaObjectHandler implements MetaObjectHandler { // 插入时填充 @Override public void insertFill(MetaObject metaObject) { this.strictInsertFill(metaObject, "createTime", LocalDateTime.class, LocalDateTime.now()); this.strictInsertFill(metaObject, "createBy", String.class, getCurrentUser()); // 复杂填充逻辑示例 if (metaObject.hasGetter("departmentCode")) { String deptCode = SecurityUtils.getUser().getDepartment(); this.strictInsertFill(metaObject, "departmentCode", String.class, deptCode); } } // 更新时填充 @Override public void updateFill(MetaObject metaObject) { // 防止覆盖已存在的值 Object updateTime = getFieldValByName("updateTime", metaObject); if (updateTime == null) { this.strictUpdateFill(metaObject, "updateTime", LocalDateTime.class, LocalDateTime.now()); } // 条件填充示例 if (shouldFillOperator()) { this.strictUpdateFill(metaObject, "updateBy", String.class, getCurrentUser()); } } }

4. 性能优化专项

4.1 分页查询优化方案

百万级数据分页的优化策略：

// 游标分页实现示例 public Page<User> cursorPage(long lastId, int size) { return userMapper.selectPage(new Page<User>(1, size) .setSearchCount(false), Wrappers.<User>lambdaQuery() .gt(User::getId, lastId) .orderByAsc(User::getId) ); }

4.2 批量操作性能对比

测试环境：MySQL 8.0，10000条数据插入

// 高性能批量插入方案 @Transactional public void batchInsert(List<User> users) { String sql = "INSERT INTO user(name,age) VALUES "; StringBuilder sb = new StringBuilder(sql); for (int i = 0; i < users.size(); i++) { sb.append("(?,?)"); if (i != users.size() - 1) { sb.append(","); } } jdbcTemplate.batchUpdate(sb.toString(), new BatchPreparedStatementSetter() { @Override public void setValues(PreparedStatement ps, int i) throws SQLException { User user = users.get(i); ps.setString(1, user.getName()); ps.setInt(2, user.getAge()); } @Override public int getBatchSize() { return users.size(); } }); }

5. 复杂查询解决方案

5.1 多表关联查询实践

MP处理多表查询的三种模式：

1. 注解方式（适合简单关联）

@Select("SELECT u.*, d.name AS deptName FROM user u LEFT JOIN department d ON u.dept_id=d.id") List<UserVO> selectUserWithDept();

2. XML映射（适合复杂SQL）

<select id="selectComplexQuery" resultMap="userResultMap"> SELECT u.*, d.name as dept_name, p.project_count FROM user u LEFT JOIN department d ON u.dept_id = d.id LEFT JOIN ( SELECT user_id, COUNT(*) as project_count FROM project GROUP BY user_id ) p ON u.id = p.user_id WHERE u.status = 1 </select>

3. QueryWrapper扩展（动态条件）

public List<UserDTO> queryUsersWithRoles(String name) { return userMapper.selectUserList( new QueryWrapper<User>() .select("u.*", "GROUP_CONCAT(r.role_name) as roles") .lambda() .like(StringUtils.isNotBlank(name), User::getName, name) .eq(User::getStatus, 1) .leftJoin("user_role ur", "ur.user_id = u.id") .leftJoin("role r", "r.id = ur.role_id") .groupBy("u.id") ); }

5.2 聚合字段查询技巧

处理数据库不存在的计算字段：

// 方案1：使用@TableField(exist=false) @Data public class UserVO { private Long id; @TableField(exist = false) private Integer loginCount; @TableField(exist = false) private String departmentName; } // 方案2：ResultMap映射 @Results({ @Result(column = "login_count", property = "loginCount"), @Result(column = "dept_name", property = "departmentName") }) @Select("SELECT u.*, COUNT(l.id) as login_count, d.name as dept_name " + "FROM user u LEFT JOIN login_log l ON u.id=l.user_id " + "LEFT JOIN department d ON u.dept_id=d.id " + "GROUP BY u.id") List<UserVO> selectUserWithStats();

6. 插件扩展机制

6.1 自定义插件开发

实现SQL执行时间监控插件：

@Intercepts({ @Signature(type = StatementHandler.class, method = "query", args = {Statement.class, ResultHandler.class}), @Signature(type = StatementHandler.class, method = "update", args = {Statement.class}), @Signature(type = StatementHandler.class, method = "batch", args = {Statement.class}) }) public class PerformanceInterceptor implements Interceptor { private static final Logger logger = LoggerFactory.getLogger("sql-performance"); @Override public Object intercept(Invocation invocation) throws Throwable { long start = System.currentTimeMillis(); try { return invocation.proceed(); } finally { long cost = System.currentTimeMillis() - start; StatementHandler handler = (StatementHandler) invocation.getTarget(); String sql = handler.getBoundSql().getSql(); if (cost > 500) { // 慢SQL阈值 logger.warn("Slow SQL detected: {}ms - {}", cost, StringUtils.abbreviate(sql.replaceAll("\\s+", " "), 100)); } } } @Override public Object plugin(Object target) { return Plugin.wrap(target, this); } @Override public void setProperties(Properties properties) { // 可读取配置参数 } }

6.2 多租户实现方案

基于MyBatis-Mate实现企业级多租户：

// 租户处理器 public class TenantHandler implements TenantLineHandler { @Override public Expression getTenantId() { return new StringValue(TenantContext.getCurrentTenant()); } @Override public String getTenantIdColumn() { return "tenant_id"; } @Override public boolean ignoreTable(String tableName) { // 忽略系统表 return "sys_config".equals(tableName) || "sys_dict".equals(tableName); } @Override public boolean ignoreInsert(List<Column> columns, String tenantIdColumn) { // 特殊场景跳过租户ID填充 return TenantContext.isIgnoreTenant(); } }

生产环境建议：

1. 租户ID建议使用数值类型而非字符串
2. 分布式环境下需要保证租户上下文传递
3. 审计日志需要记录租户信息

7. 踩坑实录与解决方案

7.1 版本升级常见问题

从3.x升级到最新版的注意事项：

1. 分页插件重构：

// 旧版 new PaginationInterceptor() // 新版需要改为 new MybatisPlusInterceptor() { { addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL)); } }

2. Lambda表达式变化：

// 旧版 wrapper.lambda().eq(User::getName, "test") // 新版更推荐 wrapper.eq(User::getName, "test")

3. 主键生成策略调整：

// 新版需要显式指定 @TableId(type = IdType.ASSIGN_ID) private Long id;

7.2 生产环境高频问题

问题1：Wrapper复用导致SQL错误

错误示例：

QueryWrapper<User> wrapper = new QueryWrapper<>(); wrapper.eq("status", 1); List<User> list1 = userMapper.selectList(wrapper); wrapper.eq("dept_id", 2); // 会累积条件 List<User> list2 = userMapper.selectList(wrapper);

解决方案：

// 方案1：每次新建Wrapper // 方案2：使用clone方法 List<User> list2 = userMapper.selectList(wrapper.clone().eq("dept_id", 2));

问题2：自动填充字段不生效

排查步骤：

1. 检查@TableField注解配置
2. 确认MetaObjectHandler实现类已注入Spring容器
3. 检查字段是否为final修饰
4. 确认没有其他拦截器修改了参数

问题3：逻辑删除与唯一索引冲突

解决方案已在3.1章节详细说明，这里补充索引设计建议：

-- 推荐方案 ALTER TABLE user ADD UNIQUE idx_username (username, is_deleted); -- 替代方案（需要业务逻辑配合） ALTER TABLE user ADD UNIQUE idx_username (username); UPDATE user SET username = CONCAT(username, '@deleted', id) WHERE is_deleted = 1;

8. 架构设计思考

8.1 复杂系统分层建议

大型项目中推荐的分层模式：

├── controller │ └── Web适配层（参数校验、DTO转换） ├── service │ ├── 应用服务层（业务流程编排） │ └── 领域服务层（核心业务逻辑） ├── manager │ └── 通用能力层（跨领域协调） ├── dao │ ├── mapper（MyBatis接口） │ └── dataobject（实体类） └── infrastructure ├── config（框架配置） └── util（工具类）

各层使用MP的建议：

1. Controller层不应直接操作Wrapper
2. Service层可封装通用查询条件
3. Manager层处理跨表事务
4. Dao层保持最精简的MP用法

8.2 微服务下的最佳实践

分布式系统中的特殊处理：

1. ID生成策略：

// 使用分布式ID生成器 @TableId(type = IdType.ASSIGN_ID) private Long id; // 或者自定义生成策略 public class CustomIdGenerator implements IdentifierGenerator { @Override public Number nextId(Object entity) { return Snowflake.nextId(); } }

2. 分库分表整合：

// 结合ShardingSphere配置示例 spring: shardingsphere: datasource: names: ds0,ds1 sharding: tables: user: actual-data-nodes: ds$->{0..1}.user_$->{0..15} table-strategy: inline: sharding-column: id algorithm-expression: user_$->{id % 16} database-strategy: inline: sharding-column: id algorithm-expression: ds$->{id % 2}

3. 缓存一致性方案：

@CacheEvict(value = "user", key = "#user.id") @Transactional public void updateUser(User user) { userMapper.updateById(user); // 双写保障 redisTemplate.opsForValue().set( "user:" + user.getId(), user, 30, TimeUnit.MINUTES); }

在微服务架构下使用MP，需要特别注意：

• 分布式事务的传播
• 跨服务的数据关联查询
• 缓存与数据库的一致性
• 监控指标的收集

9. 监控与调优

9.1 性能监控方案

集成Prometheus监控指标：

public class MetricsInterceptor implements Interceptor { private final Counter sqlCounter; private final Histogram latencyHistogram; public MetricsInterceptor() { this.sqlCounter = Counter.build() .name("mybatis_sql_total") .help("Total SQL executions") .labelNames("type", "method") .register(); this.latencyHistogram = Histogram.build() .name("mybatis_sql_latency_seconds") .help("SQL execution latency in seconds") .labelNames("type") .buckets(0.1, 0.5, 1, 5, 10) .register(); } @Override public Object intercept(Invocation invocation) throws Throwable { String methodName = invocation.getMethod().getName(); String sqlType = methodName.startsWith("select") ? "read" : "write"; sqlCounter.labels(sqlType, methodName).inc(); Histogram.Timer timer = latencyHistogram.labels(sqlType).startTimer(); try { return invocation.proceed(); } finally { timer.observeDuration(); } } }

9.2 慢SQL优化策略

通过执行计划分析优化：

1. 开启MP的SQL日志：

mybatis-plus: configuration: log-impl: org.apache.ibatis.logging.stdout.StdOutImpl

2. 使用EXPLAIN分析问题SQL：

EXPLAIN SELECT * FROM user WHERE status = 1 ORDER BY create_time DESC;

3. 常见优化手段：
   • 添加缺失的索引
   • 重写复杂子查询
   • 避免SELECT *
   • 优化JOIN顺序
   • 使用覆盖索引

10. 未来演进方向

10.1 云原生适配

MP在Kubernetes环境下的优化建议：

1. 使用ConfigMap管理数据源配置
2. 实现健康检查端点
3. 适配Service Mesh的流量管理

10.2 响应式编程支持

与Spring WebFlux的整合尝试：

@Repository public interface ReactiveUserMapper extends BaseMapper<User> { @Select("SELECT * FROM user WHERE name = #{name}") Mono<User> findByName(String name); @Update("UPDATE user SET email = #{email} WHERE id = #{id}") Mono<Integer> updateEmail(@Param("id") Long id, @Param("email") String email); }

10.3 多语言支持

通过GraalVM实现原生镜像编译的注意事项：

1. 需要注册MyBatis的反射类
2. 处理动态代理的编译时初始化
3. 预编译XML映射文件

这些方向目前还处于探索阶段，建议生产环境谨慎评估。我在金融级项目中的实践经验是，稳定性和性能始终应该放在第一位，新技术引入需要充分的测试验证。