Spring 批量 Table 使用 Java 配置时的前缀

Question

我的 Spring 批处理存储库（部署在 Oracle 数据库上）位于不同的架构中，因此我需要在架构名称前添加。

使用 XML 配置时，这很容易做到：

<job-repository id="jobRepository" table-prefix="GFA.BATCH_" />

然而，当我使用 Java 配置时，这变得更加棘手。我找到的最佳解决方案是让我的 Java 配置 class extend DefaultBatchConfigurer 并覆盖 createJobRepository() 方法：

@Configuration
@EnableBatchProcessing
public class BatchConfiguration extends DefaultBatchConfigurer{
    @Autowired
    private DataSource dataSource;

    @Autowired
    private PlatformTransactionManager transactionManager;

    @Override
    protected JobRepository createJobRepository() throws Exception {
        JobRepositoryFactoryBean factory = new JobRepositoryFactoryBean();
        factory.setDataSource(dataSource);
        factory.setTransactionManager(transactionManager);
        factory.setTablePrefix("GFA.BATCH_");
        factory.afterPropertiesSet();
        return factory.getObject();
    }
...
}

与 XML 解决方案相比，代码量相当大！而且这也不太合逻辑——我的第一个猜测是提供一个 @Bean 方法，如下所示：

@Bean
public JobRepository jobRepository() throws Exception {
    JobRepositoryFactoryBean factory = new JobRepositoryFactoryBean();
    factory.setDataSource(dataSource);
    factory.setTransactionManager(transactionManager);
    factory.setTablePrefix("GFA.BATCH_");
    factory.afterPropertiesSet();
    return factory.getObject();
}

但这行不通。

我的问题是：我的解决方案是最优的还是有更好的？我宁愿定义一个 Bean 而不是必须重写一些 class 的方法，这不是很直观...... 显然，如果我们可以将代码缩短到有点接近 XML 配置中的单行代码，那就更好了。

Answer 1

只需将此行添加到您在批处理配置中注册的任何属性文件：

spring.batch.table-prefix= GFA.BATCH_

仅供参考，前缀 spring.batch 映射到 org.springframework.boot.autoconfigure.batch.BatchProperties 随 Spring 引导提供。查看源代码 on github.

Answer 2

您应该在 java 中定义 BatchConfigurer，并在此 bean 中定义 spring 批处理表前缀：

@Bean
    public BatchConfigurer batchConfigurer() {
        return new DefaultBatchConfigurer() {

            @Autowired
            PlatformTransactionManager platformTransactionManager;

            @Override
            protected JobRepository createJobRepository() throws Exception {
                JobRepositoryFactoryBean factory = new JobRepositoryFactoryBean();
                factory.setDataSource(secondaryDataSource(secondaryDataSourceProperties()));
                factory.setTransactionManager(platformTransactionManager);
                factory.setIsolationLevelForCreate("ISOLATION_READ_COMMITTED");
                factory.setTablePrefix(batchTablePrefix);
                factory.setDatabaseType("POSTGRES");
                factory.setMaxVarCharLength(maxVarcharSize);
                return factory.getObject();
            }
        };

Spring 批量 Table 使用 Java 配置时的前缀

Spring Batch Table Prefix when using Java Config

java

spring

spring-batch

spring-java-config