java - 有条件地将数据发送到 Spring Batch 中的多个写入器

Question

我的处理器中有一些逻辑，基于此我需要决定是否需要在 TableA (WriterA) 或 TableB(writer) 中写入项目

例如 Item 已提交 type，并且 type 的值可以为 A 或 B，并且基于 type 中的值>提交我需要决定我需要在哪个表中写入数据。

Answer 1

这可以通过使用分类器来实现。以下是配置:

Writer - Writer 将设置 Classifer 来决定我们需要使用哪个 writer。根据分类器的输出，编写器将被决定。

@Bean
public ItemWriter<Pojo> itemWriter() {
    BackToBackPatternClassifier classifier = new BackToBackPatternClassifier();
    classifier.setRouterDelegate(new MyClassifier());
    classifier.setMatcherMap(new HashMap<String, ItemWriter<? extends Pojo>>() {
        {
            put("A", WriterA);
            put("B", WriterB);

        }
    });
    ClassifierCompositeItemWriter<Pojo> writer = new ClassifierCompositeItemWriter<Pojo>();
    writer.setClassifier(classifier);
    return writer;      
}

分类器

public class MyClassifier {

    @Classifier
    public String classify(Pojo Pojo) {
        return Pojo.getType();
    }
}