Spring Batch v5.x如何配置元数据表使用独立数据库？

由于Spring Batch 5.x已废弃@EnableBatchProcessing，需通过自动配置+指定元数据数据源的方式实现多数据源分离，以下是具体实现方案：

1. 配置数据源属性 #

在application.properties（或application.yml）中分别定义H2（元数据）和MySQL（业务）的数据源配置：

# H2 元数据数据源配置
spring.datasource.h2.url=jdbc:h2:mem:batch_metadata;DB_CLOSE_DELAY=-1
spring.datasource.h2.driver-class-name=org.h2.Driver
spring.datasource.h2.username=sa
spring.datasource.h2.password=

# MySQL 业务数据源配置
spring.datasource.mysql.url=jdbc:mysql://localhost:3306/your_business_db?useSSL=false&serverTimezone=UTC
spring.datasource.mysql.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.mysql.username=root
spring.datasource.mysql.password=your_mysql_password

# 自动初始化Spring Batch元数据表格（H2中）
spring.batch.jdbc.initialize-schema=always

2. 定义数据源Bean #

创建配置类，分别注册两个数据源，并通过@BatchDataSource注解标记Spring Batch元数据专用的H2数据源：

@Configuration
public class DataSourceConfiguration {

    // 注册H2数据源作为Spring Batch元数据存储
    @Bean
    @BatchDataSource
    @ConfigurationProperties(prefix = "spring.datasource.h2")
    public DataSource batchMetadataDataSource() {
        return DataSourceBuilder.create().build();
    }

    // 注册MySQL数据源作为业务数据存储
    @Bean(name = "businessDataSource")
    @ConfigurationProperties(prefix = "spring.datasource.mysql")
    public DataSource businessDataSource() {
        return DataSourceBuilder.create().build();
    }

    // 配置业务专用JdbcTemplate（若用JPA可配置EntityManagerFactory）
    @Bean(name = "businessJdbcTemplate")
    public JdbcTemplate businessJdbcTemplate(@Qualifier("businessDataSource") DataSource dataSource) {
        return new JdbcTemplate(dataSource);
    }
}

3. 业务组件使用MySQL数据源 #

在你的ItemReader、ItemWriter等业务组件中，注入标记为@Qualifier("businessJdbcTemplate")的JdbcTemplate，操作MySQL中的业务数据：

@Component
public class BusinessItemWriter implements ItemWriter<YourBusinessEntity> {

    private final JdbcTemplate businessJdbcTemplate;

    // 注入业务专用JdbcTemplate
    public BusinessItemWriter(@Qualifier("businessJdbcTemplate") JdbcTemplate businessJdbcTemplate) {
        this.businessJdbcTemplate = businessJdbcTemplate;
    }

    @Override
    public void write(List<? extends YourBusinessEntity> items) throws Exception {
        // 执行MySQL业务数据写入逻辑
        String sql = "INSERT INTO business_table (field1, field2) VALUES (?, ?)";
        items.forEach(item -> businessJdbcTemplate.update(sql, item.getField1(), item.getField2()));
    }
}

关键说明 #

• @BatchDataSource是Spring Batch 5.x新增的注解，用于标记供元数据存储使用的数据源，自动配置会优先使用该Bean作为Batch元数据的数据源。
• 无需使用@EnableBatchProcessing，Spring Batch 5.x默认启用自动配置，只要类路径下存在Batch依赖且配置了数据源，就会自动初始化元数据表格。
• 若使用JPA操作业务数据，可基于businessDataSource配置专属的EntityManagerFactory和TransactionManager，避免与Batch的事务管理冲突。

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