我试图读取具有数百万条记录的数据库表,因此我正在使用JdbcPagingItemReader。
但是,我现在正处于测试阶段,我试图限制使用JdbcPagingItemReader
可以读取的总记录数。
我知道这应该很简单,它只是藏在某个地方。
这是我的读者的样子:
@Bean (name = "metadataItemReader")
public ItemReader<DocumentMetadata> itemReader( @Value( "${count}" ) int count ) {
JdbcPagingItemReader<DocumentMetadata> reader = new JdbcPagingItemReader<>();
final SqlPagingQueryProviderFactoryBean sqlPagingQueryProviderFactoryBean = new SqlPagingQueryProviderFactoryBean();
sqlPagingQueryProviderFactoryBean.setDataSource(dataSource);
sqlPagingQueryProviderFactoryBean.setSelectClause("select id, file_path, file_name, extension, created_by, TO_CHAR(create_date, 'yyyy-mm-dd hh24:mi:ss') as create_date");
sqlPagingQueryProviderFactoryBean.setFromClause("from document_metadata");
//sqlPagingQueryProviderFactoryBean.l
sqlPagingQueryProviderFactoryBean.setSortKey("id");
try {
reader.setQueryProvider(sqlPagingQueryProviderFactoryBean.getObject());
} catch (Exception e) {
log.error(e.getMessage());
}
reader.setDataSource(dataSource);
reader.setPageSize(10);
reader.setRowMapper( new MetadataRowMapper() );
return reader;
}
最佳答案
JdbcPagingItemReader
是一个AbstractItemCountingItemStreamItemReader
bean,它具有一个maxItemCount
属性,您可以设置该属性以实现所需的功能。