Mybatis-plus多数据源实战：5分钟搞定跨库数据同步（含动态切换避坑指南）

MyBatis-Plus多数据源动态切换实战：从配置到避坑全指南

在微服务架构盛行的今天，单一数据源已无法满足复杂业务场景的需求。想象一下这样的场景：你需要从订单库查询交易记录，同时将统计结果写入分析库；或者需要将用户主库的数据同步到缓存库中。传统做法往往需要编写复杂的SQL语句或依赖ETL工具，而MyBatis-Plus提供的多数据源解决方案，让这一切变得优雅而高效。

1. 环境准备与基础配置

在开始之前，确保你的项目已经集成了MyBatis-Plus基础依赖。我们将使用dynamic-datasource-spring-boot-starter这个官方推荐的扩展包来简化多数据源配置。

Maven依赖配置：

<dependency> <groupId>com.baomidou</groupId> <artifactId>dynamic-datasource-spring-boot-starter</artifactId> <version>3.5.2</version> </dependency>

YAML配置文件示例：

spring: datasource: dynamic: primary: master # 默认数据源 strict: false # 未匹配到数据源时是否抛异常 datasource: master: url: jdbc:mysql://localhost:3306/master_db username: root password: master123 driver-class-name: com.mysql.cj.jdbc.Driver slave: url: jdbc:mysql://localhost:3306/slave_db username: root password: slave123 driver-class-name: com.mysql.cj.jdbc.Driver

关键配置说明：

• primary：指定默认数据源，当方法未标注@DS时使用
• strict：设置为true时，如果指定的数据源不存在会抛出异常
• 每个数据源的配置与传统单数据源配置方式一致

2. 基础使用：@DS注解详解

@DS是MyBatis-Plus多数据源功能的核心注解，它可以标注在类或方法上，遵循"就近原则"——方法上的注解优先级高于类上的注解。

典型应用场景：

@Service @DS("slave") // 类级别注解，默认使用slave数据源 public class UserServiceImpl implements UserService { @Autowired private UserMapper userMapper; @DS("master") // 方法级别注解，覆盖类级别注解 public void addUser(User user) { userMapper.insert(user); } public List<User> listUsers() { // 使用类注解指定的slave数据源 return userMapper.selectList(null); } }

@DS注解使用规范：

提示：建议在只读操作上使用@DS注解，写操作尽量保持默认数据源，避免事务管理复杂化。

3. 动态数据源切换高级技巧

虽然@DS注解简单易用，但在某些复杂场景下会失效，特别是当存在方法间调用时。这是因为Spring的AOP代理机制导致注解无法跨方法生效。

3.1 方法间调用问题解决方案

考虑以下场景：

@Service public class DataSyncService { @DS("sourceDB") public List<User> getSourceUsers() { // 从源数据库查询数据 } @DS("targetDB") public void syncUsers() { List<User> users = getSourceUsers(); // 这里@DS注解会失效！ // 尝试写入目标数据库 } }

解决方案一：自注入模式

@Service public class DataSyncService { @Autowired private DataSyncService self; // 注入自身代理对象 public void syncUsers() { List<User> users = self.getSourceUsers(); // 通过代理对象调用 // 使用DynamicDataSourceContextHolder切换数据源 DynamicDataSourceContextHolder.push("targetDB"); try { // 写入目标数据库 } finally { DynamicDataSourceContextHolder.poll(); } } }

解决方案二：编程式切换

public void syncUsers() { DynamicDataSourceContextHolder.push("sourceDB"); try { List<User> users = userMapper.selectList(null); DynamicDataSourceContextHolder.push("targetDB"); try { // 批量插入目标数据库 } finally { DynamicDataSourceContextHolder.poll(); } } finally { DynamicDataSourceContextHolder.poll(); } }

3.2 批量操作优化

对于需要频繁切换数据源的批量操作，可以抽象出工具类：

public class DataSourceUtils { public static <T> T execute(String dsName, Supplier<T> supplier) { DynamicDataSourceContextHolder.push(dsName); try { return supplier.get(); } finally { DynamicDataSourceContextHolder.poll(); } } public static void execute(String dsName, Runnable runnable) { DynamicDataSourceContextHolder.push(dsName); try { runnable.run(); } finally { DynamicDataSourceContextHolder.poll(); } } } // 使用示例 List<User> users = DataSourceUtils.execute("sourceDB", () -> userMapper.selectList(null)); DataSourceUtils.execute("targetDB", () -> userMapper.batchInsert(users));

4. 事务管理与性能优化

多数据源环境下的事务管理需要特别注意，跨数据源的事务需要使用分布式事务解决方案如Seata。对于单数据源事务，MyBatis-Plus提供了良好的支持。

事务配置建议：

@Configuration public class TransactionConfig { @Bean public PlatformTransactionManager transactionManager(DynamicRoutingDataSource dataSource) { return new DataSourceTransactionManager(dataSource); } }

性能优化技巧：

1. 连接池配置：

spring: datasource: dynamic: datasource: master: hikari: maximum-pool-size: 20 minimum-idle: 5 connection-timeout: 30000

2. 多数据源监控：

@RestController public class DataSourceMonitor { @Autowired private DynamicRoutingDataSource dynamicDataSource; @GetMapping("/ds/info") public Map<String, Object> getDataSourceInfo() { Map<String, DataSource> dataSources = dynamicDataSource.getDataSources(); Map<String, Object> info = new HashMap<>(); dataSources.forEach((key, value) -> { // 获取各数据源状态信息 }); return info; } }

3. 读写分离实践：

@Service public class UserService { @DS("slave") public Page<User> listUsers(PageParam param) { // 读操作使用从库 } @DS("master") public void saveUser(User user) { // 写操作使用主库 } }

5. 常见问题排查指南

在实际开发中，你可能会遇到以下典型问题：

问题1：数据源切换不生效

• 检查是否在同一个类中方法调用（需通过代理对象调用）
• 确认@DS注解是否被正确扫描（Spring Boot启动类需包含@MapperScan）
• 检查数据源名称是否拼写正确

问题2：事务与数据源切换冲突

• 避免在事务方法内切换数据源
• 对于需要跨数据源事务的场景，考虑引入Seata等分布式事务框架

问题3：性能瓶颈

• 检查连接池配置是否合理
• 避免频繁切换数据源，尽量批量处理
• 考虑使用缓存减少数据库访问

问题4：动态增减数据源

@Autowired private DynamicRoutingDataSource dynamicRoutingDataSource; public void addDataSource(String dsName, DataSourceProperty property) { DataSource dataSource = dynamicRoutingDataSource.createDataSource(property); dynamicRoutingDataSource.addDataSource(dsName, dataSource); }

在实际项目中，我曾遇到一个典型的坑点：在使用@Async异步方法时，数据源切换会失效。这是因为异步执行通常会在不同的线程中进行，而数据源信息默认是线程绑定的。解决方案是手动传递数据源信息：

@Async public void asyncProcess(String dsName) { DynamicDataSourceContextHolder.push(dsName); try { // 业务处理 } finally { DynamicDataSourceContextHolder.poll(); } }