使用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 (将#修改为@）