无法捕获 Spring Batch 的 ItemWriter 中的异常

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

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

据我观察，有一个@Transactional我的 DAO 的“保存”方法上的注释，我希望在其中发生提交和刷新。 Spring Batch 是否会以任何方式改变此事务？这样使得@Transactional注释适用于 '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: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>

这里有几点：

1. 去除@Transactional您的 DAO 上的注释。@TransactionalSpring 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 http://docs.spring.io/spring-batch/trunk/reference/html/configureStep.html