@OnWriteError 方法不更新数据库记录状态

Question

我有一个 itemWriter 将项目写入表。编写时，我得到一个 ConstraintViolationException 并且我正在使用 SkipPolicy 跳过该异常，并且我已经实现了 @OnWriteError 方法。因此它可以很好地捕获和跳过异常并在侦听器中调用 @OnWriteError 方法。在@OnWriteError 方法中，当捕获到异常时，我正在调用另一个方法来将事件标记为失败。

@OnWriteError

public void onWriteError(Exception exception,List item) {

    log.info("WRITE ERROR LISTENER CALLED");

    学生    学生 = items.get(items.size()-1);

    studnetManager.updateStatuss(student, "FAILED);

}

public void updateStatuss(Student student, Status status) {

        Student.setStatus(status);

        StudentRepository.save(Student);

}

updateStatuss() 成功调用，但学生记录未标记为 FAILED。 谁能帮我理解这个？

Answer 1

如 Javadoc 中所述，ItemWriteListener#onWriteError 将在将要回滚的事务中调用。

因此，您需要在单独的事务中调用该代码（使用 @Transactional(propagation = "REQUIRES_NEW") 注释 updateStatus 或使用 TransactionTemplate 以编程方式调用事务代码）。