spring batch 读写怎么配置多个数据源

在Spring Boot应用中，配置多数据源是一项常见的需求，尤其对于那些需要同时连接不同数据库（如MySQL、Oracle等）的应用来说。Spring Boot以其简洁的配置和自动配置特性，使得这项任务变得相对简单。本文将详细讲解如何在Spring Boot中配置多个数据源，以及结合MyBatis进行数据操作。 我们要明白什么是数据源（DataSource）。数据源是Java中用于存储数据库连接的信息，它是JDBC的一部分，负责管理与数据库的连接。在Spring Boot中，我们可以使用`@Bean`注解来创建并配置数据源。 对于MySQL和Oracle这两种不同的数据库，我们需要分别创建两个数据源。以下是一个基本的配置示例： 1. **配置MySQL数据源** 在`application.properties`或`application.yml`中配置MySQL的相关属性，例如： ```properties # application.properties spring.datasource.url=jdbc:mysql://localhost:3306/mysql_db spring.datasource.username=root spring.datasource.password=password spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver 或者在YAML格式中： ```yaml # application.yml spring: datasource: url: jdbc:mysql://localhost:3306/mysql_db username: root password: password driver-class-name: com.mysql.cj.jdbc.Driver 2. **配置Oracle数据源** 对于Oracle数据库，同样在配置文件中添加相应的属性： ```properties # application.properties spring.second-datasource.url=jdbc:oracle:thin:@localhost:1521:orcl spring.second-datasource.username=oracle_user spring.second-datasource.password=oracle_password spring.second-datasource.driver-class-name=oracle.jdbc.OracleDriver 或YAML格式： ```yaml # application.yml spring: second-datasource: url: jdbc:oracle:thin:@localhost:1521:orcl username: oracle_user password: oracle_password driver-class-name: oracle.jdbc.OracleDriver 3. **创建数据源 Bean** 接下来，我们需要创建两个数据源的Bean。在Spring Boot中，我们通常会创建一个主数据源，并通过`@Primary`注解标记，其他数据源则不加此注解。 ```java @Configuration public class DataSourceConfig { @Primary @Bean(name = "primaryDataSource") @ConfigurationProperties(prefix = "spring.datasource") public DataSource primaryDataSource() { return DataSourceBuilder.create().build(); @Bean(name = "secondaryDataSource") @ConfigurationProperties(prefix = "spring.second-datasource") public DataSource secondaryDataSource() { return DataSourceBuilder.create().build(); 4. **配置多数据源** 为了在业务代码中切换数据源，我们需要创建一个`AbstractRoutingDataSource`的实现类，它可以根据特定的条件选择要使用的数据源。 ```java @Configuration public class DynamicDataSource extends AbstractRoutingDataSource { @Override protected Object determineCurrentLookupKey() { // 这里可以根据业务逻辑决定使用哪个数据源，比如通过ThreadLocal获取当前请求的上下文信息 return DataSourceContextHolder.getDataSourceKey(); 5. **设置数据源切换上下文** 在服务调用前，我们需要设置当前的数据源key，这里可以使用ThreadLocal来保存上下文。 ```java public class DataSourceContextHolder { private static final ThreadLocal<String> contextHolder = new ThreadLocal<>(); public static void setDataSourceKey(String dataSourceKey) { contextHolder.set(dataSourceKey); public static String getDataSourceKey() { return contextHolder.get(); public static void clearDataSourceKey() { contextHolder.remove(); 6. **结合MyBatis** 我们需要配置MyBatis与多数据源的整合。创建一个MyBatis的配置类，并指定数据源。 ```java @Configuration @MapperScan(basePackages = {"com.example.mapper.primary", "com.example.mapper.secondary"}) public class MyBatisConfig { @Autowired @Qualifier("primaryDataSource") private DataSource primaryDataSource; @Autowired @Qualifier("secondaryDataSource") private DataSource secondaryDataSource; @Bean(name = "primarySqlSessionFactory") public SqlSessionFactory primarySqlSessionFactory() throws Exception { SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean(); factoryBean.setDataSource(primaryDataSource); return factoryBean.getObject(); @Bean(name = "secondarySqlSessionFactory") public SqlSessionFactory secondarySqlSessionFactory() throws Exception { SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean(); factoryBean.setDataSource(secondaryDataSource); return factoryBean.getObject(); 7. **在Service层切换数据源** 在Service层中，我们可以根据业务需求，使用`DataSourceContextHolder`来切换数据源。 ```java @Service public class SomeService { @Autowired @Qualifier("primarySqlSessionFactory") private SqlSessionFactory primarySessionFactory; @Autowired @Qualifier("secondarySqlSessionFactory") private SqlSessionFactory secondarySessionFactory; public void executeOnPrimaryDB() { DataSourceContextHolder.setDataSourceKey("primary"); // ...执行针对primary数据库的操作 DataSourceContextHolder.clearDataSourceKey(); public void executeOnSecondaryDB() { DataSourceContextHolder.setDataSourceKey("secondary"); // ...执行针对secondary数据库的操作 DataSourceContextHolder.clearDataSourceKey(); 至此，我们就完成了Spring Boot配置多数据源（MySQL + Oracle）以及与MyBatis的整合。在实际开发中，还需要根据项目需求进行适当的调整，比如添加事务管理、AOP切面等，确保数据源切换的平滑进行。同时，要特别注意数据源的安全性，避免敏感信息泄露。