在 AbstractJpaQueryProvider 中使用 Jakarta Persistence Query Language 获取前 n 行

如何解决在 AbstractJpaQueryProvider 中使用 Jakarta Persistence Query Language 获取前 n 行

我正在使用 Spring Batch 开发批处理程序。我正在尝试限制我的项目阅读器读取的查询数量，这是我目前依赖的免费 API 的限制。我的 JPAItemReader 正在使用这个 AbstractJpaQueryProvider：

public class CustomJpaQueryProvider extends AbstractJpaQueryProvider {

    @Override
    public Query createquery() {
        EntityManager manager = getEntityManager();
        Query query = manager.createquery("select c from CompanyDescriptor c where c.assetType = 'Stock'").setMaxResults(50);
        System.out.println("result size -> " + query.getResultList().size());
        return query;
    }

    @Override
    public void afterPropertiesSet() throws Exception {
    }

}

我试图将结果限制为 50，但日志显示尽管结果是 50，但此查询提供程序执行了多次（我以为它只使用了一次）。所以最后就像我与查询提供者“分块”一样。

我真正想要的是我的 ItemReader 只读取 50 个项目。我该怎么做？

这是步骤和项目读取器定义：

@Bean
public Step evaluateCompaniesstep() {
        return this.stepBuilderFactory.get("evaluatingStep").<CompanyDescriptor,CompanyscoreKeeper>chunk(100)
                .reader(jpaCompanyItemReader(null)).processor(compositeIemprocessor()).writer(itemWriter()).build();
    }

@Bean
public JpaPagingItemReader<CompanyDescriptor> jpaCompanyItemReader(EntityManagerFactory entityManagerFactory) {
        CustomJpaQueryProvider queryProvider = new CustomJpaQueryProvider();

        return new JpaPagingItemReaderBuilder<CompanyDescriptor>().name("companyItemReader")
                .entityManagerFactory(entityManagerFactory).queryProvider(queryProvider).build();
    }