MyBatis-Plus 动态数据源DataSourceTransactionManager

### MyBatis-Plus 动态数据源配置 在MyBatis-Plus中，动态数据源可以通过多种方式进行配置。一种常见的做法是在主数据源之外定义其他的数据源，并通过自定义逻辑来决定具体使用哪一个数据源[^2]。 对于多数据源场景下的事务管理，`DataSourceTransactionManager`起到了至关重要的作用。它负责协调不同数据源之间的事务边界，确保跨库操作的一致性和原子性。当应用程序执行涉及多个数据库的操作时，`DataSourceTransactionManager`会参与到Spring框架的声明式事务管理体系当中去，在必要时候发起分布式事务处理流程[^1]。 为了实现基于Mapper接口路径的不同数据源自动切换功能，通常会在启动类上利用`@MapperScan`注解指定各个分组对应的包位置，同时配合AOP切面编程技术拦截SQL请求并修改当前线程上下文中默认使用的数据源名称。这种方式不仅简化了开发人员的工作量，而且提高了系统的可维护性和扩展能力[^3]。 ```java @Configuration public class DynamicDataSourceConfig { @Bean(name = "primaryDataSource") @ConfigurationProperties(prefix="spring.datasource.primary") public DataSource primaryDataSource() { return DataSourceBuilder.create().build(); } @Bean(name = "secondaryDataSource") @ConfigurationProperties(prefix="spring.datasource.secondary") public DataSource secondaryDataSource() { return DataSourceBuilder.create().build(); } @Primary @Bean(name = "dynamicDataSource") public DynamicDataSource dataSource(@Qualifier("primaryDataSource") DataSource primaryDataSource, @Qualifier("secondaryDataSource") DataSource secondaryDataSource){ Map<Object, Object> targetDataSources = new HashMap<>(); targetDataSources.put(DataSourceEnum.PRIMARY.name(), primaryDataSource); targetDataSources.put(DataSourceEnum.SECONDARY.name(), secondaryDataSource); DynamicDataSource dynamicDataSource = new DynamicDataSource(); dynamicDataSource.setTargetDataSources(targetDataSources); // 添加数据源 dynamicDataSource.setDefaultTargetDataSource(primaryDataSource); // 设置默认数据源 return dynamicDataSource; } } ``` 上述代码展示了如何创建两个独立的数据源实例，并将其注册到名为`dynamicDataSource`的对象里作为目标数据源列表的一部分。这里还指定了默认情况下应该采用哪个数据源来进行查询或更新操作[^4]。 ### 关联组件说明 - `DynamicDataSource`: 自定义的一个继承于AbstractRoutingDataSource抽象类的具体实现版本，用于存储所有可能被调用的实际物理连接池对象，并根据某种策略返回恰当的选择结果给上游模块。 - `SqlSessionFactory`: 负责生产与特定持久化层交互所需的Session实体，每一个工厂都对应着唯一的JDBC Connection Pool资源描述符即DataSource实例。 - `SqlSessionTemplate`: 提供了一个线程安全的方法封装器，内部持有对某个具体的SqlSessionFactory引用关系，从而允许开发者以面向接口的形式编写DAO层业务逻辑而无需关心底层细节。 - `DataSourceTransactionManager`: 是Spring Framework提供的标准事务管理者之一，专门用来控制单个或者一组相互关联的数据访问过程中的提交/回滚行为，特别是在存在多个异构型DBMS参与的情况下显得尤为重要。