mybatis-plus 动态数据源

Mybatis-Plus是一个基于Mybatis的增强工具，它提供了很多便捷的功能来简化开发。在使用Mybatis-Plus时，如果需要实现动态数据源的功能，可以按照以下步骤进行配置。 首先，需要创建一个自定义的动态数据源类，比如`MyDynamicDataSource`。这个类需要继承`AbstractRoutingDataSource`，并实现`determineCurrentLookupKey`方法来返回当前的数据源标识。在这个类中，可以使用`ThreadLocal`来保存当前的数据源标识，以便在不同的线程中切换数据源。同时，还需要提供设置数据源标识和清除数据源标识的方法。\[1\] 接下来，需要引入`dynamic-datasource-spring-boot-starter`的依赖，可以在`pom.xml`文件中添加以下配置： ```xml <dependency> <groupId>com.baomidou</groupId> <artifactId>dynamic-datasource-spring-boot-starter</artifactId> <version>3.5.1</version> </dependency> ```\[2\] 然后，需要创建一个配置类，比如`DataSourceConfig`，并使用`@Configuration`注解标记。在这个配置类中，可以使用`@Bean`注解来创建主数据源和从数据源，并使用`@ConfigurationProperties`注解来指定数据源的配置信息。同时，还需要使用`@Primary`注解标记主数据源。最后，将主数据源和从数据源添加到`MyDynamicDataSource`中，并返回一个`MyDynamicDataSource`实例。\[3\] 通过以上配置，就可以实现Mybatis-Plus的动态数据源功能了。在使用Mybatis-Plus时，可以通过调用`MyDynamicDataSource.setDataSource`方法来设置当前的数据源标识，从而实现动态切换数据源的功能。 #### 引用[.reference_title] - *1* *3* [MyBatis Plus动态数据源](https://blog.csdn.net/qq_44802667/article/details/129247656)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v91^koosearch_v1,239^v3^insert_chatgpt"}} ] [.reference_item] - *2* [mybatis-plus动态数据源](https://blog.csdn.net/qq_41472891/article/details/123270082)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v91^koosearch_v1,239^v3^insert_chatgpt"}} ] [.reference_item] [ .reference_list ]

### 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参与的情况下显得尤为重要。