如何从存储库项目读取器而不是实体 Spring 批处理返回实体列表

Question

我正在使用RepositoryItemReader作为阅读器。我需要一起处理该块的整个读取器值列表。

当我试图通过扩展读取器返回列表来执行块处理时，在我的处理器中，我收到错误

类Car不能转换为java.util.list(Car位于加载程序“app”的未命名模块中)；java.util.List位于加载程序“bootstrap”的java.base模块中

读者

 public class CarReader extends RepositoryItemReader<List<Car>>{
    
   @Autowired
   CarRepository carRepository;

   public CarReader(){
    super();
    this.setPageSize(100);
    this.setSort(CarSort());
    this.setRepository(carRepository);
    this.setMethodName("findAll");
    return repositoryItemReader;
  }

贮藏室ˌ仓库

public interface CarRepository extends PagingAndSortingRepository<Car,long>{
   Page<Car> findAll(Pageable pageable);
}

处理器

public class CarProcessor implements ItemProcessor<List<Car>,List<Car>>{
  @Override
  public List<Car> process(List<Car> cars){
    //prepare CarTransform
 }
}

步骤

@Bean
public Step step1() {
    return this.stepBuilderFactory.get("step1")
                .<List<Car>, List<CarTransform>>chunk(100)
                .reader(carReader)
                .processor(carProcessor)
                .writer(carWriter)
                .build();
}

Answer 1

看这个例子：https://html" target="_blank">github.com/emalock3/spring-batch-example/blob/master/src/main/java/com/github/emalock3/spring/example/BatchConfiguration.java

我不认为你应该在你的阅读器/处理器/编写器中使用列表......相反，只使用 Car 和 CarTransform 类。

Spring Batch将根据您设置的块大小处理所有分块。根据您的配置，它应该一次自动处理 100 条记录。

我认为您看到的错误是因为＜code＞findAll＜code＞方法返回了＜code＞页

您的步骤配置应如下所示：

@Bean
public Step step1() {
    return this.stepBuilderFactory.get("step1")
                .<Car, CarTransform>chunk(100)
                .reader(carReader)
                .processor(carProcessor)
                .writer(carWriter)
                .build();
}

读者:

public class CarReader extends RepositoryItemReader<Car> {

    @Autowired
    CarRepository carRepository;

    public CarReader() {
        super();
        this.setPageSize(100);
        this.setSort(CarSort());
        this.setRepository(carRepository);
        this.setMethodName("findAll");
    }
}

处理器：

public class CarProcessor implements ItemProcessor<Car, CarTransform> {
    @Override
    public CarTransform process(Car car) {
        // prepare CarTransform
    }
}