java - 无法在 Spring 批处理的 ItemWriter 中捕获异常

Question

我正在编写一个 Spring Batch 流程来将数据集从一个系统迁移到另一个系统。在这种情况下，这就像在传递给 ItemWriter 之前使用 RowMapper 实现从查询构建对象一样简单。 ItemWriter 调用我的 DAO 上的 save 方法(定义为接口(interface)并由 spring 数据处理)

问题是这样的:我对 MyItem 表有唯一约束，因此保存重复的记录将导致 DataIntegrityViolationException。我已经尝试在 ItemWriter 中捕获它以允许我记录未导入的记录，但是在执行期间它永远不会进入此 catch 语句。我 try catch Exception 和 Throwable 也无济于事。

据我所知，我的 DAO 的“保存”方法上有一个 @Transactional 注释，我希望在该方法中发生提交和刷新。 Spring Batch 会以任何方式改变这个交易吗？使得 @Transactional 注释适用于 ItemWriter 的“write”方法？

我什至可以捕获此类中的异常吗？

我在下面提供了代码片段，如果您需要更多信息 - 请告诉我。

非常感谢您提供的任何帮助

ItemWriter

@Component
public class MyItemWriter implements ItemWriter<MyItem> {

    private static final Logger LOG = LoggerFactory.getLogger(MyItemWriter.class);

    @Resource
    private MyItemDao myItemDao;

    @Override
    public void write(List<? extends MyItem> myItems) throws Exception {
        for (MyItem myItem : myItems) {
            try {
                myItemDao.save(myItem);
            } catch (Throwable ex) {
                LOG.warn("Failed to import MyItem: {}: {} ", myItem.getId(), ex.toString());
            }
        }
    }
}

DAO

public interface MyItemDao extends PagingAndSortingRepository<MyItem, Integer> {
    [Custom methods omitted]
}

Spring Batch 配置

<batch:job id="myImportJob" restartable="true" job-repository="jobRepository">
    <batch:step id="myImportStep" allow-start-if-complete="true">
        <batch:tasklet>
            <batch:chunk reader="myItemReader" writer="myItemWriter" commit-interval="50" />
        </batch:tasklet>
    </batch:step>
</batch:job>

Answer 1

这里有几点:

1. 删除 DAO 上的 @Transactional 注释。 @Transactional 和 Spring Batch 通常表现不佳。 Spring Batch 将事务作为框架功能的一部分进行管理，尝试操纵该功能可能会导致意外的副作用。
2. 正如 M. Deinum 指出的那样，您的 ItemWriter 以及您的 DAO 正在参与 Spring Batch 正在管理的事务。因此，在事务提交之前您不会得到该异常。

考虑到上述因素后，您有两个选择:

1. 您可以配置跳过逻辑以跳过引发该异常的记录。如果您需要记录该项目，您可以将 SkipListener 添加到组合中，以便您可以记录导致异常的项目。但是，这种方法会带来性能损失，因为抛出异常会导致事务回滚并一次重放一项。
2. 您可以通过 ItemProcessor 过滤项目。这节省了跳过逻辑的性能损失。

您可以在此处阅读第 5.1.5 节中有关 Spring Batch 的跳过逻辑的更多信息:http://docs.spring.io/spring-batch/trunk/reference/html/configureStep.html