Spring批处理编写器接收到错误的对象类型

Question

我有麻烦与Spring Batch关于配置我的自定义作家这基本上是一个RepositoryItemWriter

@Bean
@StepScope
public ItemReader<DTO> itemReader() {
    [...]Reading from database and mapping into DTO class
    return reader;
}

@Bean
@StepScope
public ItemProcessor<DTO, Entity> itemProcessor(mapper) {
        return dto-> {
            dto.check();
            return mapper.toEntity(dto);
        };
}

@Bean
@StepScope
public ItemWriter<Entity> itemWriter() {
   [...]Save into database from repository
   return writer;
}

@Bean
public Step step() {
    return stepBuilderFactory.get("step")
            .<DTO, Entity>chunk(500)
            .reader(itemReader)
            .writer(itemWriter)
            .build();
}

我使用mapstruct将DTO映射到处理器内的实体。尽管这似乎是正确的，但我的作者实际上接收的是DTO项而不是实体，因此无法持久化它们。

关于批次结构的一些补充但不相关的信息。我从一个大文件中读取，将其分成较小的文件。然后我用多资源分区器分区我的步骤，处理器正在做一些格式控制，然后写入器只是批量插入数据库。

编辑：我想我可以复制/粘贴生成的源代码，但MapperImpl非常简单：

   @Override
    public Entity toEntity(DTO dto) {
        if ( dto == null ) {
            return null;
        }
      Entity entity = new Entity();
      [Bunch of controls and mapping]
      return entity;
     }

差不多就是这样。

谢谢你的帮助

Answer 1

我猜是因为晚上的编码错误。没有为该步骤声明处理器，因此项直接从读卡器传递到写卡器，而没有作为实体进行处理和转换。

@Bean
@StepScope
public ItemReader<DTO> itemReader() {
    [...]Reading from database and mapping into DTO class
    return reader;
}

@Bean
@StepScope
public ItemProcessor<DTO, Entity> itemProcessor(mapper) {
        return dto-> {
            dto.check();
            return mapper.toEntity(dto);
        };
}

@Bean
@StepScope
public ItemWriter<Entity> itemWriter() {
   [...]Save into database from repository
   return writer;
}

@Bean
public Step step() {
    return stepBuilderFactory.get("step")
            .<DTO, Entity>chunk(500)
            .reader(itemReader)
            .processor(itemProcessor) //Edit with solution : This line was missing
            .writer(itemWriter)
            .build();
}

不过，我仍然想知道它是否应该被编译。

Answer 2

返回mapper.to实体（dto）；

也许，问题出在mapper实现上。如果没有实现源，很难说mapper是如何工作的