Мне нужно ограничить 14 записей. chunkSize составляет 10 страниц. Размер равен 2. Он охватывает только 10 записей.
Проверял разными способами. chunkSize = 5 pageSize = 10 По-прежнему ограничены только 10 записей, а не все 14.
он отлично работает, только если chunksize = 11 и pageSize = 10 или chunkSize = 10 и pageSize = 20
build.gradle
partition:
defaultPartitionSize: 5
partitionScopeChunkSize: 10
jobs:
jpaPagingSize: 2
===================ReaderClass============================
public class PagingItemReader extends
JpaPagingItemReader<ScopeParams> {
public PagingItemReader (
EntityManager entityManager,
EntityManagerFactory entityManagerFactory,
@Value("${spring.jobs.jpaPagingSize}") int jpaPagingSize)
Map<String, Object> parameterValues = new HashMap<>();
this.setQueryProvider(
ScopeParamsQueryProvider.buildForContinuousMatchScoping(
entityManager,
IndustryCodes.valueFromCode(industryCd)));
this.setEntityManagerFactory(entityManagerFactory);
this.setPageSize(jpaPagingSize);
this.setSaveState(true);
this.setParameterValues(parameterValues);
}
}
==============WriterClass==========
public class JpaItemWriter<T> extends JpaItemWriter<T> {
private JpaRepository<T, ? extends Serializable> repository;
public JpaItemWriter(JpaRepository<T, ?> repository) {
this.repository = repository;
}
@Override
@Transactional
public void write(List<? extends T> items) {
persistEntities(items);
}
private void persistEntities(List<? extends T> list) {
list.stream()
.peek(item -> log.info("Writing={}", item))
.forEach(repository::save);
}
}
===================Step Configuration========
public Step WorkStep(StepBuilderFactory stepBuilderFactory,
PagingItemReader ItemReader,
ItemProcessor ItemProcessor,
JpaItemWriter<Scope> itemWriter) {
return stepBuilderFactory.get(WORK_MATCH)
.<Scope, ExecutionScope>chunk(10)
.reader(ItemReader)
.processor(ItemProcessor)
.writer(itemWriter)
.build();
}
код процессора,
public class MatchItemProcessor implements ItemProcessor<Scope,ExecutionScope> {
public ExecutionScope process(Scope financialTransaction) throws Exception {
return batchExecutionScope;
}
}
private ExecutionScope prepareData(Scope transaction) { ExecutionScope executionScope = new ExecutionScope(); executionScope .setIndustryTypeCode(financialTransaction.getIndustryTypeCode()); return executionScope ; }
Я обновляю другой объект в процессоре с теми же полями, в которых происходит чтение. Итак, я читаю объект «Область» в классе читателя. В классе процессора создание объекта execitionScope и обновление значений на основе области действия и сохранение execitionScope в БД.
Обе сущности указывают на разные таблицы. ScopeParam
нажмите на таблицу fin_t и ExecutionScope
нажмите на таблицу exec_scope.
пожалуйста, предоставьте мне предложение.
ÒFFSET
иLIMIT
и отслеживает общее количество прочитанных элементов в любой момент времени. Общее количество прочитанных элементов делится на размер страницы, чтобы узнать текущий номер страницы. Поэтому, если вы продолжаете добавлять записи в таблицу после запуска задания, ваше задание будет продолжать выполняться и для новых элементов, добавленных после запуска задания. - person Sabir Khan   schedule 25.10.2018