Spring4环境下如何避免Spring Batch元数据持久化到业务数据库？

嘿，我太懂你这困扰了——本来只是想写个从数据库读数据转CSV的批处理作业，结果Spring Batch默认把作业执行的元数据全塞到业务数据库里了，完全不是预期的样子！既然你用的是Spring 4版本，我给你俩靠谱的解决方案，应该能搞定：

方案1：配置独立的元数据数据源 #

Spring Batch默认会复用业务数据源来存储批处理元数据，咱们只要给它单独配一个专属数据源就行，不管是物理数据库还是内存库都可以。

代码配置示例 #

@Configuration
@EnableBatchProcessing
public class BatchConfig {

    // 业务数据源，连接你的业务数据库
    @Bean
    @Primary
    public DataSource businessDataSource() {
        DriverManagerDataSource dataSource = new DriverManagerDataSource();
        dataSource.setDriverClassName("com.mysql.jdbc.Driver");
        dataSource.setUrl("jdbc:mysql://localhost:3306/business_db");
        dataSource.setUsername("biz_user");
        dataSource.setPassword("biz_pass");
        return dataSource;
    }

    // 批处理元数据专属数据源（这里用独立物理库，也可以换成H2内存库）
    @Bean
    public DataSource batchMetadataDataSource() {
        DriverManagerDataSource dataSource = new DriverManagerDataSource();
        dataSource.setDriverClassName("com.mysql.jdbc.Driver");
        dataSource.setUrl("jdbc:mysql://localhost:3306/batch_meta_db");
        dataSource.setUsername("meta_user");
        dataSource.setPassword("meta_pass");
        return dataSource;
    }

    // 指定Batch使用元数据数据源
    @Bean
    public BatchConfigurer batchConfigurer(@Qualifier("batchMetadataDataSource") DataSource dataSource) {
        return new DefaultBatchConfigurer(dataSource);
    }

    // 后续的ItemReader、ItemWriter、Step、Job配置正常使用业务数据源即可
    // ...
}

如果是测试场景或者不需要持久化元数据，换成H2内存库更轻便：

@Bean
public DataSource batchMetadataDataSource() {
    EmbeddedDatabaseBuilder builder = new EmbeddedDatabaseBuilder();
    return builder.setType(EmbeddedDatabaseType.H2)
                  .addScript("classpath:org/springframework/batch/core/schema-h2.sql")
                  .build();
}

方案2：彻底禁用元数据持久化（仅适合不需要作业状态追踪的场景） #

如果你完全不需要保存作业执行历史、状态这些元数据，可以把Spring Batch改成纯内存模式：

@Configuration
@EnableBatchProcessing
public class BatchConfig {

    @Bean
    public JobRepository jobRepository() throws Exception {
        MapJobRepositoryFactoryBean factory = new MapJobRepositoryFactoryBean();
        factory.setTransactionManager(new ResourcelessTransactionManager());
        return factory.getObject();
    }

    @Bean
    public JobLauncher jobLauncher() throws Exception {
        SimpleJobLauncher launcher = new SimpleJobLauncher();
        launcher.setJobRepository(jobRepository());
        launcher.setTaskExecutor(new SimpleAsyncTaskExecutor());
        return launcher;
    }

    // 你的ItemReader、ItemWriter等业务逻辑配置...
}

application.properties配置补充 #

如果是用.properties配合XML配置的方式，可以这样拆分数据源：

# 业务数据源配置
spring.datasource.url=jdbc:mysql://localhost:3306/business_db
spring.datasource.username=biz_user
spring.datasource.password=biz_pass
spring.datasource.driver-class-name=com.mysql.jdbc.Driver

# 批处理元数据数据源配置
batch.datasource.url=jdbc:mysql://localhost:3306/batch_meta_db
batch.datasource.username=meta_user
batch.datasource.password=meta_pass
batch.datasource.driver-class-name=com.mysql.jdbc.Driver

之后在XML配置里指定Batch组件使用batch.datasource即可。

你之前尝试方案失败，大概率是因为Spring 4中@EnableBatchProcessing会优先选用标注@Primary的数据源，一定要确保批处理的专属数据源被正确注入到BatchConfigurer或者JobRepository里哦。

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