Spring Boot/Spring Batch：使用和配置两个数据源通过应用程序属性

Question

我正在使用Spring Boot/Spring Batch，需要提供两个JDBC数据源。

我找不到一种从我的application.properties自动加载配置参数的方法。

//BatchConfiguration which uses both Data Sources:
@Configuration
@EnableBatchProcessing
public class BatchConfiguration {

  @Bean
  public JdbcBatchItemWriter<Customer> writer(@Qualifier("dataSourceOne") DataSource dataSource) {
    return new JdbcBatchItemWriterBuilder<Customer>()
            .itemSqlParameterSourceProvider(new BeanPropertyItemSqlParameterSourceProvider<>())
            .sql("..."))
            .dataSource(dataSource)
            .build();
  }
@Bean
  public JdbcCursorItemReader<Customer> reader(@Qualifier("dataSourceTwo") DataSource dataSource) {
    return new JdbcCursorItemReaderBuilder<Customer>()
            .dataSource(dataSource)
            .name("myItemReader")
            .sql("...")
            .rowMapper(new CustomerRowMapper())
            .build();
  }

上面的代码可与以下配置一起使用，该配置直接提供了数据源：

//WORKING SOLUTION
@Configuration(proxyBeanMethods = false)
public class DataSourcesConfiguration {

  @Bean("dataSourceOne")
  @Primary
  public DataSource dataSource() {
    DataSourceBuilder dataSourceBuilder = DataSourceBuilder.create();
    dataSourceBuilder.url("jdbc:h2:mem:AAA-h2");
    dataSourceBuilder.username("AAA");
    dataSourceBuilder.password("AAA");
    dataSourceBuilder.driverClassName("org.h2.Driver");
    return dataSourceBuilder.build();
  }

  @Bean("dataSourceTwo")
  public DataSource dataSourceTwo() {
    DataSourceBuilder dataSourceBuilder = DataSourceBuilder.create();
    dataSourceBuilder.url("jdbc:oracle:thin:@AAA");
    dataSourceBuilder.username("AAA");
    dataSourceBuilder.password("AAA");
    dataSourceBuilder.driverClassName("oracle.jdbc.driver.OracleDriver");
    return dataSourceBuilder.build();
  }
}

我尝试通过注释从我的应用程序属性创建数据源@configurationProperties

//NOT WORKING
@Configuration(proxyBeanMethods = false)
public class DataSourcesConfiguration {
  @Bean("dataSourceOne")
  @Primary
  @ConfigurationProperties(prefix="data1.datasource")
  public DataSource dataSource() {
    return DataSourceBuilder.create().build();
  }

  @Bean("dataSourceTwo")
  @ConfigurationProperties(prefix="data2.datasource")
  public DataSource dataSourceTwo() {
    return DataSourceBuilder.create().build();
  }
}

如果

data1.datasource.url=jdbc:h2:mem:AAA-h2
data1.datasource.username=AAA
data1.datasource.password=AAA
data1.datasource.driverClassName=org.h2.Driver

data2.datasource.url=jdbc:oracle:thin:@AAA
data2.datasource.username=AAA
data2.datasource.password=AAA
data2.datasource.driverClassName=oracle.jdbc.driver.OracleDriver

错误无法在非工作版本中检测数据库类型。

如何通过我的application.properties中的属性正确配置并通过我的属性提供数据源？

Answer 1

创建dataSource用于创建的值实际上是其他类datasourceproperties的一部分。
您还可以使用它来创建dataSource。

以下是来自 taskdbconfig （如果您需要更多功能，此类还包含信息）。

import org.springframework.boot.autoconfigure.jdbc.DataSourceProperties;
import com.zaxxer.hikari.HikariDataSource;

    @Bean
    @ConfigurationProperties("data1.datasource")
    public DataSourceProperties data1DataSourceProperties() {
        return new DataSourceProperties();
    }
        
    @Bean
    @ConfigurationProperties("data1.datasource.hikari")
    public HikariDataSource data1DataSource() {
    
        // Different types are documented at
        // https://docs.spring.io/spring-boot/docs/current/api/org/springframework/boot/jdbc/DataSourceBuilder.html
        
        return data1DataSourceProperties().initializeDataSourceBuilder()
            .type(HikariDataSource.class).build();
    }

application.yml

data1.datasource.platform: h2
data1.datasource.url: 'jdbc:h2:mem:test'

# Hikari config properties: https://github.com/brettwooldridge/HikariCP#configuration-knobs-baby
data1.datasource.hikari.minimumIdle: 1
data1.datasource.hikari.maximumPoolSize: 4