Pentaho DI - Как использовать «все» результаты предыдущего шага на следующем шаге в качестве запроса «IN»

Question

У меня есть вход из таблицы A в базе данных A, которую я хотел бы присоединиться к другой таблице B в базе данных B.

Это были мои два варианта:

1. Использование базы данных Регистрация: Для каждого входа из таблицы в базе данных а, запустите присоединиться запрос в B. базы данных
2. Используйте два ввода таблицы (talbeA + TableB) и сделать merge join on key.

Я пошел с опцией № 1, так как я хочу, чтобы не читать в tableA и tableB целиком.

Мой вопрос: Как я могу использовать все результаты с предыдущего шага как один запрос «IN»?

Например

select * 
from tableB b 
where b.id IN (all_rows_from_prior_step) 

по сравнению с (там, где он работает для каждой входной строки)

select * 
from tableB b 
where b.id = ? 

Answer 1

использовать 'Группы по' для выравнивания строк в одну строку с полем ' all_rows_from_prior_step 'из разделенных запятыми идентификаторов (поле группы: пустое, имя: all_rows_from_prior_step, Subject: id, Тип:' объединить строки, разделенные символом '). Затем, используя 'User Defined Java Expression' для построения запроса SQL:

"select * from tableB b where b.id IN (" + all_rows_from_prior_step + ")"

Последнее, используйте 'Dynamic SQL строки' для выполнения запроса. Шаблон SQL может быть

select * from tableB b where 1=0