Предварительные записи SSIS перед извлечением

Question

Мне нужно перенести записи из таблицы в Oracle в SQL Server 2008 R2. Я уже разработал решение, которое позволяет мне перемещать данные и сохранять копию перенесенных идентификаторов в таблицу сцен.
Благодаря компоненту Lookup и таблице этапов я могу обеспечить, чтобы избежать дубликатов, поскольку миграция выполняется в несколько разных моментов, а перенесенные объекты не соответствуют определенному порядку последовательности.

Ниже моей SSIS схеме:

Я использую выражение и две переменные для сбора данных из Oracle в слотах:

SELECT * 
FROM ORDERS 
WHERE OrderID > [@User::Start] AND OrderID <= [@User::End] 
AND STATUS <> 'Open' 

Когда все заказы, которые не statsu " Open "были перенесены, мы перенесем оставшуюся дельту. Для этого мне нужно найти данные, перенесенные на сцену. Таким образом, запрос для источника данных будет:

SELECT * 
FROM ORDERS 
WHERE OrderID NOT IN ([@User::AlreadyMigratedIDs]) 

Моя потребность будет иметь возможность хранить в переменной «AlreadyMigratedIDs» все идентификаторы, присутствующие в таблицу Stage.

Как можно использовать информацию в таблице сцен (на SQL Server) в качестве условия для запроса, используемого в компоненте ADO.net, для сбора исходных данных из Oracle? Могу ли я использовать любой другой SSIS, например, поиск до объекта ADO.net?

Answer 1

Использование Execute SQL Task до вашего потока данных для хранения значений пользователя :: Start и End User :: из промежуточной таблицы SQL сервера

Name  Data Type 
StartID int 
EndID  int 

Используйте ResultSet, как Single Row

Для образца I принял запрос от Adventure Works 2008 R2

Select max([BusinessEntityID]) as StartID 
     ,max([DepartmentID]) as EndID 
FROM [AdventureWorks2008R2].[HumanResources].[EmployeeDepartmentHistory] 

изменить приведенную выше запрос в соответствии с вашими потребностями, чтобы получить значения ID из таблицы перевалочных

В результирующем совпадают результаты с переменными, созданных

Теперь использовать 2 переменные в оракула запросе

SELECT * 
FROM ORDERS 
WHERE OrderID > [@User::StartID] AND OrderID <= [@User::EndID] 
AND STATUS <> 'Open'