Spring Batch元数据表未按指定前缀创建，寻求缺失配置

问题描述 #

我有一个标注了@Configuration、@Slf4j、@EnableBatchProcessing的配置类BatchConfiguration，代码如下：

@Configuration
@Slf4j
@EnableBatchProcessing
public class BatchConfiguration {

    @Autowired
    private JobParametersValidator jobParametersValidator;

    @Value("${spring.datasource.url}")
    private String postgresUrl;

    @Value("${spring.datasource.username}")
    private String postgresUserName;

    @Value("${spring.datasource.password}")
    private String postgresPassword;

    private String postgresSchema = "public";


    @Bean("dataSource")
    @Primary
    public DataSource dataSource() {
        HikariDataSource hikariDataSource = new HikariDataSource();
        hikariDataSource.setJdbcUrl(this.postgresUrl);
        hikariDataSource.setUsername(this.postgresUserName);
        hikariDataSource.setPassword(this.postgresPassword);
        hikariDataSource.setSchema(this.postgresSchema);
        return hikariDataSource;
    }

    @Bean
    public JpaTransactionManager transactionManager(){
        JpaTransactionManager transactionManager = new JpaTransactionManager();
        transactionManager.setDataSource(dataSource());
        return transactionManager;
    }
   
    @Bean
    public Job...


}

application.yml配置如下：

spring:
  application:
    name: ${APPLICATION_NAME}
  batch:
    jdbc:
      initialize-schema: ALWAYS
      table-prefix: CUSTOM_
    job:
      enabled: false

当前元数据表已创建，但未添加指定前缀CUSTOM_。使用依赖为spring-boot-starter-batch:3.0.5（含spring-batch-core:5.0.1），initialize-schema设为ALWAYS，table-prefix设为CUSTOM_，请问缺少什么配置才能让元数据表按指定前缀初始化？

问题原因与解决方法 #

原因分析 #

当自定义DataSource和TransactionManager的Bean并使用@EnableBatchProcessing时，Spring Boot自动配置的Batch相关组件（包括表前缀处理逻辑）会被覆盖，导致table-prefix配置无法生效。

解决步骤 #

1. 通过BatchConfigurer手动指定表前缀
   继承DefaultBatchConfigurer并重写相关方法，在创建JobRepository时显式设置表前缀，同时保留自定义的数据源和事务管理器：

   @Configuration
   @Slf4j
   @EnableBatchProcessing
   public class BatchConfiguration extends DefaultBatchConfigurer {
   
       @Value("${spring.datasource.url}")
       private String postgresUrl;
   
       @Value("${spring.datasource.username}")
       private String postgresUserName;
   
       @Value("${spring.datasource.password}")
       private String postgresPassword;
   
       private String postgresSchema = "public";
   
       @Value("${spring.batch.jdbc.table-prefix}")
       private String tablePrefix;
   
       @Override
       protected DataSource createDataSource() {
           HikariDataSource hikariDataSource = new HikariDataSource();
           hikariDataSource.setJdbcUrl(this.postgresUrl);
           hikariDataSource.setUsername(this.postgresUserName);
           hikariDataSource.setPassword(this.postgresPassword);
           hikariDataSource.setSchema(this.postgresSchema);
           return hikariDataSource;
       }
   
       @Override
       public PlatformTransactionManager getTransactionManager() {
           return new JpaTransactionManager(getDataSource());
       }
   
       @Override
       protected JobRepository createJobRepository() throws Exception {
           JobRepositoryFactoryBean factory = new JobRepositoryFactoryBean();
           factory.setDataSource(getDataSource());
           factory.setTransactionManager(getTransactionManager());
           factory.setTablePrefix(tablePrefix); // 显式指定表前缀
           factory.setIsolationLevelForCreate("ISOLATION_REPEATABLE_READ");
           factory.afterPropertiesSet();
           return factory.getObject();
       }
   }
   

2. 验证初始化逻辑
   Spring Boot的BatchDataSourceScriptDatabaseInitializer会读取application.yml中的table-prefix配置生成初始化脚本，结合上述JobRepository的前缀设置，重启应用后数据库中会生成带CUSTOM_前缀的元数据表（如CUSTOM_JOB_INSTANCE、CUSTOM_JOB_EXECUTION等）。

内容的提问来源于stack exchange，提问作者Nidhi Kaushal