Добавочная загрузка с использованием АПД с отслеживанием изменений

Я построил конвейер в ADF, который постепенно загружает данные с сервера SQL в базу данных SQL Azure с помощью механизма отслеживания изменений. Вот ссылка, по которой я следил:https://www.sqlservercentral.com/articles/incremental-data-loading-through-adf-using-change-tracking Как мне изменить исходный запрос в активности копирования данных для несколько таблиц. Ниже приводится запрос, который я использую.

SELECT  
s.*,
c.SYS_CHANGE_VERSION, 
c.SYS_CHANGE_OPERATION,  
c.SYS_CHANGE_COLUMNS
FROM @{item().TABLE_SCHEMA}.@{item().TABLE_NAME} AS s 
RIGHT OUTER JOIN CHANGETABLE(
CHANGES @{item().TABLE_SCHEMA}.@{item().TABLE_NAME}, 
@{activity('lkupLastChngTrackVer').output.firstRow.SYS_CHANGE_VERSION}) as c 
ON s.[studentId] = c.[studentId] 
where c.SYS_CHANGE_VERSION <= 
@{activity('lkupCurChngTrackVer').output.firstRow.CurrentChangeTrackingVersion}

Этот запрос не работает в случае удаления. Также данные второй таблицы загружаются дважды, когда я запускаю конвейер. Благодарю за помощь

Спасибо Gauri pawse

0 ответов

Другие вопросы по тегам