在单个事务中运行 Spring Batch 步骤

Question

我正在编写 Spring Batch 作业以：

1. 从数据库表中读取一些记录
2. 将它们写入文件
3. 更新同一个数据库表上的相同记录

到目前为止，我的解决方案包括：

• 从数据库读取的JdbcCursorItemReader
• CompositeItemWriter 反过来又委托给
  • ItemWriter 写入文件
  • JdbcBatchItemWriter 用于更新数据库中已处理的记录

如何确保整个步骤在单个事务中运行？只有当步骤成功时，我才能提交数据库 UPDATE。

下面是相关的基于Java的配置代码：

@Bean
public Step step1() {
    return stepBuilderFactory.get("step1")
            .<Person, Person>chunk(...)
            .reader(...)
            .processor(...)
            .writer(compositeWriter())
            .build();
}

@Bean
public CompositeItemWriter<Person> compositeWriter() {
    return new CompositeItemWriterBuilder<Person>()
            .delegates(..., jdbcWriter())
            .build();
}

@Bean
public JdbcBatchItemWriter<Person> jdbcWriter(DataSource dataSource) {
    return new JdbcBatchItemWriterBuilder<Person>()
        .itemSqlParameterSourceProvider(...)
        .sql("UPDATE ...")
        .dataSource(dataSource)
        .build();
}

Answer 1

在单个事务中运行整个步骤首先不是面向块的处理模型的目的。原因显然是在处理大量数据时相关的长时间运行的事务。

也就是说，没有什么能阻止您创建一个自定义步骤实现，如果这对您有用，那么它可以在单个事务中完成工作，即使我不建议这样做。