Spring批处理可以分类返回多个写入器

Question

我是新来的Spring批我有一个大的主表。这个主表被合并到5个单独的表中。我的要求是我需要创建一个编写器，它将写入这5个单独的表。但这些写入程序将根据以下条件调用：例如：如果我有一个未在主表中设置的字段，我将调用2个写入程序并跳过其他3个写入程序。

我使用带有分类器的复合写入器来检查条件，但分类器只返回1个写入器。分类器可以返回多个作家吗？或者有其他类可以满足我的要求吗？

Answer 1

您可以创建一个自定义ItemWriter，它结合了多个ItemWriter来处理特定情况。例如，假设有两种情况需要不同的ItemWriter。Case1需要写入table1和table2：

@Component
public class Case1ItemWriter implements ItemWriter<Foo> {

    @Autowired
    private JdbcBatchItemWriter writer1;  //write to table1

    @Autowired
    private JdbcBatchItemWriter writer2;  //write to table2

    @Override
    public void write(List<? extends T> items) throws Exception{
        writer1.write(items);
        wrtire2.write(items)
    }
}

案例2需要写入表3和表4：

@Component
public class Case2ItemWriter implements ItemWriter<Foo> {

    @Autowired
    private JdbcBatchItemWriter writer3;  //write to table3

    @Autowired
    private JdbcBatchItemWriter writer4;  //write to table4

    @Override
    public void write(List<? extends T> items) throws Exception{
        writer3.write(items);
        wrtire4.write(items)
    }
}

然后实现一个分类器，以确定不同的情况，以返回它们自己的ItemWriter：

@Component
public class MyClassifier implements Classifier<Foo ,ItemWriter<Foo>> {

    @Autowired
    private Case1ItemWriter case1ItemWriter;

    @Autowired
    private Case2ItemWriter case2ItemWriter;  

    @Override
    public ItemWriter<Foo> classify(Foo foo){

      if(foo.isBlabBlaBla()){
        return case1ItemWriter;
      }else{
        ......
        return case2ItemWriter;
      }
    }
}

并将此分类器配置为分类器CompositeItemWriter。