1

在实现 ClassifierCompositeItemwriter 时遇到问题...

我正在阅读一个基本的 CSV 文件，我想把它们写成一个数据库。根据数据（名称+名称1）将其写入简单的ItemWriter或使用compositeItemwriter（写入两个不同的表）......

这是我的：ClassifierCompositeItemwriter请参阅 > 下面的错误消息

public ClassifierCompositeItemWriter<MyObject> classifierCompositeItemWriter() {
ClassifierCompositeItemWriter<MyObject> writer = new ClassifierCompositeItemWriter<MyObject>();
writer.setClassifier(new MySpecialClassifier());
return writer;
}

我尝试使用分类器接口实现分类器 

import org.springframework.batch.item.ItemWriter;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.classify.Classifier;

@SuppressWarnings("serial")
public class MySpecialClassifier implements Classifier<MyObject, ItemWriter<MyObject>> {

@Autowired
ItemWriter<MyObject> writer1;

@Autowired
ItemWriter<MyObject> writer2;

@Override
public ItemWriter<MyObject> classify(MyObject obj) {

    if (!obj.getName().isEmpty() && !obj.getName1().isEmpty()) {
        return writer1;
    } else {
        return writer2;
    }
}
}

Eclipse 不断告诉我：ClassifierCompositeItemWriter 类型中的 setClassifier(Classifier>) 不适用于参数 (MySpecialClassifier)

4

1 回答 1

4

你的分类器应该是这样的：

public class MySpecialClassifier implements Classifier<MyObject, ItemWriter<? super MyObject>> {

    @Autowired
    ItemWriter<MyObject> writer1;

    @Autowired
    ItemWriter<MyObject> writer2;

    @Override
    public ItemWriter<MyObject> classify(MyObject obj) {

        if (!obj.getName().isEmpty() && !obj.getName1().isEmpty()) {
            return writer1;
        } else {
            return writer2;
        }
    }

}

唯一的区别是implements Classifier<MyObject, ItemWriter<? super MyObject>>代替implements Classifier<MyObject, ItemWriter<MyObject>>.

这是因为项目编写者不仅可以编写MyObject项目，还可以编写 的超类的项目MyObject。

于 2018-11-27T14:52:19.527 回答