Spring Batch Динамический запрос JdbcPagingItemReader и передача данных между шагами

Question

У меня есть требование, используя Spring Boot и Spring Batch, где мне нужно прочитать данные из одной базы данных, которая возвращает записи, как показано ниже

Id1  Select * from Table1
Id2  Select * from Table2

Каждый запрос будет выполнен в другой базе данных и вернет более 100 тыс.записи Ниже приведены запросы, которые я застрял с

1. Передать запрос читателю (т. е. от одного шага к другому шагу)

2. Динамически читатьзапрашивает и извлекает записи, используя JdbcPagingItemReader, так как каждый запрос возвращает> 100 тыс. записей и пишет с помощью средства записи элементов.

Все запросы возвращают один и тот же элемент / pojo.

Answer 1

Первый запрос возвращает значение столбца, которое снова является SQL-запросом, который необходимо выполнить в другой базе данных и прочитать путем разбивки на страницы и вставить их в первую базу данных

В этом случаеВы можете выполнить два шага:

• Шаг 1 (тасклет): выполняет первый запрос и помещает его результат (запрос, выполняемый читателем) в контекст выполнения
• Шаг 2 (ориентированный на чанки): считывает запрос из контекста выполнения и динамически передает его читателю