本文介紹了在春季批次的ItemWriter中無法捕獲異常的處理方法，對大家解決問題具有一定的參考價值，需要的朋友們下面隨著小編來一起學習吧！
問題描述
我正在編寫一個Spring批處理過程來將數據集從一個系統遷移到另一個系統。在本例中，這與使用RowMapper實現在將對象移交給ItemWriter之前從查詢構建對象一樣簡單。ItemWriter調用我的DAO上的save方法(定義為接口，由Spring數據處理)
問題是：我對MyItem表有一個唯一的約束，因此保存重復的記錄將導致DataIntegrityViolationException。我曾嘗試在ItemWriter中捕獲它，以允許我記錄沒有導入記錄，但是在執行過程中，它從未進入該catch語句。我也曾嘗試捕獲Exception和Throwable，但都無濟于事。
據我所知，在我的DAO的”save”方法上有一個@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: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>
推薦答案
這里有幾點：
-
刪除DAO上的
@Transactional批注。@Transactional和Spring Batch通常玩得不好。Spring Batch將事務作為框架功能的一部分進行管理，嘗試操作該功能可能會導致意想不到的副作用。正如M.Deinum所指出的，您的
ItemWriter，因此您的DAO正在參與Spring Batch管理的事務。因此，在事務提交之前，您不會獲得該異常。
考慮上述因素后，您有兩個選擇：
-
您可以配置跳過邏輯以跳過引發該異常的記錄。如果您需要記錄項目，可以將
SkipListener添加到混合中，以便記錄導致異常的項目。但是，此方法需要付出性能損失，因為拋出異常將導致事務回滾并一次重放一個項目。您可以通過
ItemProcessor對商品進行過濾點評。這可節省跳過邏輯的性能影響。
您可以在5.1.5節中閱讀有關Spring Batch跳過邏輯的更多信息：http://docs.spring.io/spring-batch/trunk/reference/html/configureStep.html
這篇關于在春季批次的ItemWriter中無法捕獲異常的文章就介紹到這了，希望我們推薦的答案對大家有所幫助，
