扩展DefaultBatchConfiguration时如何启用Spring Batch元数据表自动初始化？

当通过继承DefaultBatchConfiguration自定义Spring Batch配置时，即使配置了spring.batch.jdbc.initialize-schema=always，元数据表也不会自动创建——这是因为自定义配置会覆盖Spring Boot自动装配的BatchDataSourceInitializer，导致默认的表初始化逻辑失效。以下是两种可行的解决方式：

方式一：手动注册BatchDataSourceInitializer Bean #

在你的JobConfiguration类中添加BatchDataSourceInitializer的Bean定义，复用Spring Boot的配置参数来触发表初始化：

@Configuration
public class JobConfiguration extends DefaultBatchConfiguration {
    @Override
    protected Isolation getIsolationLevelForCreate() {
        return Isolation.READ_COMMITTED;
    }

    @Bean
    public Job job(JobRepository jobRepository, Step processStep) {
        return new JobBuilder("PROCESS_JOB", jobRepository)
                .validator(new DefaultJobParamsValidator())
                .start(processStep)
                .build();
    }

    // 新增：注册元数据表初始化器
    @Bean
    public BatchDataSourceInitializer batchDataSourceInitializer(DataSource dataSource,
                                                                 BatchProperties batchProperties,
                                                                 ResourceLoader resourceLoader) throws SQLException {
        BatchDataSourceInitializer initializer = new BatchDataSourceInitializer();
        initializer.setDataSource(dataSource);
        // 自动识别数据库类型
        String dbProductName = dataSource.getConnection().getMetaData().getDatabaseProductName();
        initializer.setDatabaseType(DatabaseType.fromProductName(dbProductName));
        initializer.setResourceLoader(resourceLoader);
        // 复用配置文件中的schema路径和初始化策略
        BatchProperties.Jdbc jdbcProps = batchProperties.getJdbc();
        initializer.setSchemaLocation(jdbcProps.getSchema());
        initializer.setInitializeSchema(jdbcProps.getInitializeSchema());
        return initializer;
    }

    // steps definition omitted
}

方式二：手动执行Schema初始化脚本 #

如果不想依赖BatchDataSourceInitializer，也可以在配置类中通过ResourceDatabasePopulator手动执行Spring Batch的schema脚本：

@Configuration
public class JobConfiguration extends DefaultBatchConfiguration {
    // 原有的方法...

    @PostConstruct
    public void initializeSchema(DataSource dataSource) throws IOException {
        // 根据数据库类型选择对应的脚本，以MySQL为例
        Resource schemaResource = new ClassPathResource("org/springframework/batch/core/schema-mysql.sql");
        ResourceDatabasePopulator populator = new ResourceDatabasePopulator(schemaResource);
        populator.execute(dataSource);
    }
}

注意事项 #

• 确保application.properties或application.yaml中已正确设置spring.batch.jdbc.initialize-schema=always；
• 方式二中需要根据你的数据库类型替换对应的schema脚本（比如schema-oracle.sql、schema-postgresql.sql等）；
• 两种方式都需要保证数据源配置正确，应用能正常连接数据库。

内容的提问来源于stack exchange，提问作者Thierno Barry