spring批处理中是否可以嵌套块

Question

嗨，我是新春批。

我有如下Spring批次的情况：

我需要运行所有促销的批处理[促销列表]

>

在这里，我想再次从batch中读取上面的动态查询，因为它返回的结果至少为5万条记录。

以下是我所期待的过程，这在Spring批次中是否可行？

• 阅读促销【读者逐一阅读促销】
  • 创建查询并将其放在上下文中
  • 传递给下一个读者
    • 读取器逐个读取事务
    • 处理交易并计算积分

    我这里的问题是不能写嵌套块[一个用于读取提升，一个用于读取事务]。

    一个备选办法是：

    为每个促销活动分区作业，在这种情况下，所有促销活动将同时运行，但我们需要一个接一个地运行。

    有人能提出任何解决办法吗？

Answer 1

你不能有嵌套块，这样你就可以编写自己的CompositeItemReader，比如（伪代码）：

class CompositeItemReader implements ItemReader<Transaction> {
  ItemReader<Promotion> promotions;
  ItemReader<Transaction> transactions;

  public void setPromotions(ItemReader<Promotion> promotions) {...}

  public Transaction read() {
    Transaction item = transactions.read();
    if(null == item) {
      Promotion p = promotions.read();
      if(null != p) {
        // Close transactions reader, create dynamic query and open transaction reader
        // Re-read item!
        item = this.read();
      }
    }

   return item;
  }
}

但是记住将促销和交易注册为流，并记住管理可重启性。
或者，如果您确定每个促销活动都有一个有限的列表

class PromotionProcessor implements ItemProcessor<Promotion,List<Transaction>> {
  public List<Transaction> process(Promotion item) {
    Query q = <create dynamic query>;
    return q.list();
  }
}

还有一个基于PeekableItemReader和data holder的解决方案，如本文所述

希望这些考虑能有所帮助！干得好