不同模式中的Spring批处理表

Question

我想使用不同的模式来保存Spring批处理表。我可以在＜code＞JobRepositoryFactoryBean＜code＞中看到我的新数据源。但这些表仍然是在另一个shcema中创建的，在那里我有业务表。我在这里读到了可以使用＜code＞数据源的soemwhere。setValidationQuery来更改模式，但仍然不起作用。我能解决这个问题。下面是＜code＞JobRepositoryFactoryBean

 @Bean
 @Qualifier("batchDataSource")
 protected JobRepository createJobRepository() throws Exception {
    JobRepositoryFactoryBean factory = createJobRepositoryFactoryBean();    
    factory.setDataSource(getDataSource());
    if (getDbType() != null) {
      factory.setDatabaseType(getDbType());
    }
    factory.setTransactionManager(getTransactionManager());
    factory.setIsolationLevelForCreate(getIsolationLevel());
    factory.setMaxVarCharLength(maxVarCharLength);
    factory.setTablePrefix(getTablePrefix());
    factory.setValidateTransactionState(validateTransactionState);
    factory.afterPropertiesSet();
    return factory.getObject();
  }

 spring.datasource.url=url
 spring.datasource.username=username
 spring.datasource.password=pwd
spring.datasource.driver-class-name:oracle.jdbc.driver.OracleDriver
spring.datasource.validation-query=ALTER SESSION SET 
 CURRENT_SCHEMA=schemaname

#batch setting
spring.batch.datasource.url=burl
spring.batch.datasource.username=busername
spring.batch.datasource.password=bpwd
spring.batch.datasource.driver-class-name:oracle.jdbc.driver.OracleDriver
spring.batch.datasource.validation-query=ALTER SESSION SET 
CURRENT_SCHEMA=batchschema

 org.apache.tomcat.jdbc.pool.DataSource dataSource = new org.apache.tomcat.jdbc.pool.DataSource();
      dataSource.setName("batchDataSourceName");
      dataSource.setDriverClassName(batchDataSourceProperties.getDriverClassName());
      dataSource.setUrl(batchDataSourceProperties.getUrl());
      dataSource.setUsername(batchDataSourceProperties.getUsername());
      dataSource.setPassword(batchDataSourceProperties.getPassword());
     // dataSource.setValidationQuery(batchDataSourceProperties.getValidationQuery());

Answer 1

复制现有的数据源属性，并重写BatchConfigurer以返回这个新的数据源。然后，在新数据源的属性中，更改

>

将数据库连接到一个默认模式定义为Spring Batch表所需模式的用户

包含Spring Batch表所需架构的连接url。

您选择的选项将取决于您的数据库类型，如下所示：

对于SQL服务器，您可以为用于连接到数据库的用户定义默认模式（I

CREATE SCHEMA batchschema;

USE database;
CREATE USER batchuser;
GRANT CREATE TABLE TO batchuser;    
ALTER USER batchuser WITH DEFAULT_SCHEMA = batchschema;
ALTER AUTHORIZATION ON SCHEMA::batchschema TO batchuser;

对于Postgres 9.4，您可以使用电流模式参数在连接URL中指定模式：jdbc： postgresql：//host： port/db？电流模式=批处理

对于Postgres 9.4之前的版本，您可以使用search chpath参数在连接URL中指定架构：jdbc： postgresql：//host： port/db？搜索路径=批处理

对于 Oracle，看起来需要在会话上设置架构。我不完全确定这个将如何工作...

ALTER SESSION SET CURRENT_SCHEMA batchschema

限定每个数据源，将要用于 Batch 表的数据源设置为@Primary，并为 DefaultBatchConfigurer 设置数据源，如下所示：

@Bean(name="otherDataSource")
public DataSource otherDataSource() {
    //...
}

@Primary
@Bean(name="batchDataSource")
public DataSource batchDataSource() {
    //...
}

@Bean
BatchConfigurer configurer(@Qualifier("batchDataSource") DataSource dataSource){
    return new DefaultBatchConfigurer(dataSource);
}

Answer 2

当使用Spring Batch的＜code＞@EnableBatchProcessing＜code＞时，Spring Batch表使用的＜code＞数据源数据源，则必须创建自己的批配置器（通过扩展DefaultBatchConfigurer或实现接口），以便Spring Batch知道使用哪个。您可以在此处的参考文档中阅读有关此自定义的更多信息：https://docs.spring.io/spring-batch/4.0.x/reference/html/job.html#configuringJobRepository

Answer 3

应用程序中的以下属性.属性正在为我工作。这将在数据库中new_schema下创建元架构表。

spring.batch.tablePrefix=new_schema.BATCH_

下面是我使用的springBoot版本。

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.3.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>