使用Java配置时的Spring批处理表前缀

Question

我的Spring Batch存储库（部署在Oracle数据库上）位于不同的模式中，因此我需要在模式名称之前添加。

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

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

但是，当我使用JavaConfig时，这变得更加棘手。我发现的最佳解决方案是让我的JavaConfig类扩展DefaultBatchConfigrer并覆盖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解决方案相比，这相当多的代码！这也不太符合逻辑——我的第一个猜测是提供一个< code>@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，而不是必须覆盖一些不太直观的类的方法......显然，如果我们可以缩短代码以有点接近XML配置中的单行代码，那就更好了。

Answer 1

您应该在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();
            }
        };

Answer 2

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

spring.batch.table-prefix= GFA.BATCH_

仅供参考，前缀< code>spring.batch与Spring boot提供的< code > org . Spring framework . boot . auto configure . batch . batch properties 相映射。参见github上的源代码。