如何解决使用RepositoryItemReader更新Spring Batch中的记录后出现问题
我有一个批处理,并且我正在使用spring数据JPA进行查询,然后更新记录。我用条件(代码为null)搜索表(RepositoryItemReader)的记录。我有一个处理逻辑(ProcessorBatch),最后,我更新代码值。之后,我更新记录(RepositoryItemWriter)。
但是此搜索每10个我就会进行10次。问题是,当我更新代码字段(在搜索条件中使用)时,发生了该问题,即分页失败并跳过了10条记录。然后更新10条记录,然后跳过10条记录,直到结束。
在最终日志中,出现READ = 5000 WRITE = 5000 SKIP = 0
。但是数据库中有10000条记录
每次他返回查询记录时,他都会在执行查询之前
从示例中选择generatedAlias0 where generatedAlias0.code is null
的计数(generationAlias0)
随之,记录总数发生了变化,因为代码不再为空。
我进行了测试,是否在处理中更新了除代码字段以外的其他字段,它是否正常工作。
有人对我有什么建议,可以继续查找带有分页的记录,以免影响性能并正常更新吗?
我有以下代码:
批处理配置
@Configuration
@EnableBatchProcessing
public class BatchConfiguration {
@Bean
public Step exampleStep(ExampleRepository exampleRepository,ProcessorBatch processorBatch,StepBuilderFactory steps) {
RepositoryItemReader<Example> reader = getReader(exampleRepository);
RepositoryItemWriter<Example> writer = getWriter(exampleRepository);
return steps.get("exampleStep")
.<Example,Example> chunk(10)
.reader(reader)
.listener(new StepListener())
.processor(processorBatch)
.writer(writer)
.faultTolerant()
.skipPolicy(new CustomSkipPolicy())
.build();
}
private RepositoryItemReader<Example> getReader(ExampleRepository exampleRepository) {
RepositoryItemReader<Example> reader = new RepositoryItemReader<>();
reader.setRepository(exampleRepository);
reader.setMethodName("findByCodeIsNull");
reader.setSort(Collections.singletonMap("code",Sort.Direction.ASC));
reader.setPageSize(10);
return reader;
}
private RepositoryItemWriter<Example> getWriter(ExampleRepository exampleRepository) {
RepositoryItemWriter<Example> writer = new RepositoryItemWriter<>();
writer.setRepository(exampleRepository);
writer.setMethodName("save");
return writer;
}
@Bean
public Job job(JobBuilderFactory jobBuilderFactory,ExampleRepository exampleRepository,JobBuilderFactory jobs,StepBuilderFactory steps) {
BatchConfiguration batchConfiguration = new BatchConfiguration();
return jobs.get("job")
.incrementer(new RunIdIncrementer())
.start(batchConfiguration.exampleStep(exampleRepository,processorBatch,steps))
.build();
}
}
ProcessorBatch
public Example process(Example example) throws StepSkipException {
example.setCode("code");
return example;
}
Movimento存储库
@Repository
public interface ExampleRepository extends JpaRepository<Example,Integer> {
Page<Movimento> findByCodeIsNull(Pageable pageable);
}
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。