本文介紹了在春季批次的ItemWriter中無(wú)法捕獲異常的處理方法，對(duì)大家解決問(wèn)題具有一定的參考價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)吧！
問(wèn)題描述
我正在編寫一個(gè)Spring批處理過(guò)程來(lái)將數(shù)據(jù)集從一個(gè)系統(tǒng)遷移到另一個(gè)系統(tǒng)。在本例中，這與使用RowMapper實(shí)現(xiàn)在將對(duì)象移交給ItemWriter之前從查詢構(gòu)建對(duì)象一樣簡(jiǎn)單。ItemWriter調(diào)用我的DAO上的save方法(定義為接口，由Spring數(shù)據(jù)處理)
問(wèn)題是：我對(duì)MyItem表有一個(gè)唯一的約束，因此保存重復(fù)的記錄將導(dǎo)致DataIntegrityViolationException。我曾嘗試在ItemWriter中捕獲它，以允許我記錄沒(méi)有導(dǎo)入記錄，但是在執(zhí)行過(guò)程中，它從未進(jìn)入該catch語(yǔ)句。我也曾嘗試捕獲Exception和Throwable，但都無(wú)濟(jì)于事。
據(jù)我所知，在我的DAO的”save”方法上有一個(gè)@Transactional注釋，我希望在其中發(fā)生提交和刷新。Spring Batch會(huì)以任何方式改變這個(gè)事務(wù)嗎？以便@Transactional批注應(yīng)用于ItemWriter？
的‘write’方法
我甚至可以捕獲此類中的異常嗎？
我在下面提供了代碼片段，如果您需要更多信息，請(qǐng)讓我知道。
非常感謝您能提供的任何幫助
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>
推薦答案
這里有幾點(diǎn)：
-
刪除DAO上的
@Transactional批注。@Transactional和Spring Batch通常玩得不好。Spring Batch將事務(wù)作為框架功能的一部分進(jìn)行管理，嘗試操作該功能可能會(huì)導(dǎo)致意想不到的副作用。正如M.Deinum所指出的，您的
ItemWriter，因此您的DAO正在參與Spring Batch管理的事務(wù)。因此，在事務(wù)提交之前，您不會(huì)獲得該異常。
考慮上述因素后，您有兩個(gè)選擇：
-
您可以配置跳過(guò)邏輯以跳過(guò)引發(fā)該異常的記錄。如果您需要記錄項(xiàng)目，可以將
SkipListener添加到混合中，以便記錄導(dǎo)致異常的項(xiàng)目。但是，此方法需要付出性能損失，因?yàn)閽伋霎惓?dǎo)致事務(wù)回滾并一次重放一個(gè)項(xiàng)目。您可以通過(guò)
ItemProcessor對(duì)商品進(jìn)行過(guò)濾點(diǎn)評(píng)。這可節(jié)省跳過(guò)邏輯的性能影響。
您可以在5.1.5節(jié)中閱讀有關(guān)Spring Batch跳過(guò)邏輯的更多信息：http://docs.spring.io/spring-batch/trunk/reference/html/configureStep.html
這篇關(guān)于在春季批次的ItemWriter中無(wú)法捕獲異常的文章就介紹到這了，希望我們推薦的答案對(duì)大家有所幫助，
