Наше пакетное приложение Spring имеет: пользовательский JdbcCursorItemReader, который читает из базы данных, и пользовательский JmsItemWriter, который позволяет добавлять заголовки к каждому сообщению.
Идея состоит в том, что каждое сообщение будет иметь идентификатор корреляции и быть частью набора. В JmsItemWriter нам нужно получить доступ к общему количеству строк, полученных средством чтения элементов.
Каков наилучший подход для этого?
Спасибо
Если вам нужно получить доступ к ОБЩЕМУ количеству строк (например, select count(*) from table), лучше всего создать предыдущий шаг, на котором вы выполняете подсчет и помещаете результат в контекст выполнения, чтобы получить к нему доступ на следующих шагах.
Если вы нужен номер текущей записи JdbcCursorItemReader наследует эти средства от AbstractItemCountingItemStreamItemReader
Самый простой способ - использовать StepListener, см. следующий пример:
@Component
public class StepListener extends StepExecutionListenerSupport {
@Override
public ExitStatus afterStep(StepExecution stepExecution) {
// here, you can debug stepExecution to get some values like "readCount" :
logger.info(stepExecution.getReadCount());
// you also have commitCount, writeCount, rollbackCount, readSkipCount, writeSkipCount, processSkipCount, filterCount
// check stepExecution.getSummary for a nice one line info
logger.info(stepExecution.getSummary());
return null;
}
}
Не забудьте настроить stepListener на шаге пакетной конфигурации.
StepExecutionListener.beforeStep()для выполненияselect count, если вы не хотите создавать дополнительный шаг) 30.04.2014