ItemWriter提交仅在第一个提交间隔内提交

Question

我试图从数据库中选择数据，更新每个对象，然后在项目管理器中更新数据库。

我试图在每次更新后刷新DAO，但没有任何改变。

该配置非常基本，有一个读写器，提交间隔为100。

读者正在按预期工作：

java prettyprint-override">@Override
public Order read() throws Exception, UnexpectedInputException, ParseException, NonTransientResourceException {
    if(iterator == null) {
        List<Order> all = findOrders();
        iterator = all.listIterator();
    }

    if (iterator.hasNext()) {
        return iterator.next();
    } else {
        return null;
    }
}

作者也很基本：

public void write(List<? extends Order> items) throws Exception {
    @SuppressWarnings("unchecked")
    List<Order> listOrder = (List<Order>) items;

    try {
        for(Order o : listOrder) {
            etatCommandeServiceImpl.updateEtatCommande(o);
        }
    }catch(Exception e) {
        if (log.isErrorEnabled()) {
            log.error("ERROR {}", e);
        }
        throw e;
    }
}

问题是，前100条记录已经提交，但其余的记录没有提交。Spring批处理表显示，它读取所有记录并多次提交，但当我签入数据库时，它只提交一次。

Spring batch的版本是2.2.6。

使现代化

我认为这个问题是由于与数据库的事务，因为现在它根本不提交给数据库。但我现在想不出来。

Answer 1

问题是您从ItemReader返回null。如果您返回null Spring批处理将假定提要已结束，它将终止作业。由于您在每个块（在您的情况下为100）后返回null，因此Sprint批处理在处理100条记录后被终止。

请使用@PostConstruct创建方法，获取所有要处理的记录，并将ItemReader更改为每次返回1，读取所有记录时返回null。