Блог

У меня есть приложение для Spring batch, я использовал программирование, ориентированное на блоки, в котором я расширил класс FlatFileItemWriter для генерации выходного файла.

Проблема в том, что у меня будет более 1000 записей в качестве входных данных, а значение блока равно 100. Таким образом, 10 раз будет вызван customFlatFileItemWriter . Но проблема в том, что каждая запись взаимосвязана, я должен проверить предыдущий идентификатор со следующим идентификатором записи.

Ввод в пакет

 123, sample1
123, sample2 // Here I have to check 123 is same as 123 which is previous id
124, sample3 // Here I have to check 124 is same as 123 which is previous id
125, sample4 // Here I have to check 125 is same as 124 which is previous id
  

Для этого, если блок завершается с id — 124, мы не можем получить идентификатор записи ‘124’ при выполнении манипуляций с идентификатором записи ‘125’.

В StepExecution мы можем сохранить объект в выполнении и перейти к следующей задаче, но здесь, в этом сценарии, мы не получаем StepExecution, так что в любом случае можно получить объект для следующей манипуляции с блоком.

Код моего пользовательского FlatFileItemWriter

 public class FileIW<T> extends FlatFileItemWriter<T> {

    @Override
    public String doWrite(List<? extends T> items) {
        StringBuilder lines = new StringBuilder();
        for (T item : items) {
            User user = (User)item;
            System.out.println(user.getId());
            lines.append(this.lineAggregator.aggregate(item)).append(this.lineSeparator);
        }
        return lines.toString();
    }

}