De wijzigingen toepassen op de bestemming

Van toepassing op:SQL Server SSIS Integration Runtime in Azure Data Factory

In de gegevensstroom van een Integration Services-pakket dat een incrementele belasting van wijzigingsgegevens uitvoert, is de derde en laatste taak het toepassen van de wijzigingen op uw bestemming. U hebt één onderdeel nodig om invoegingen toe te passen, één om updates toe te passen en één om verwijderingen toe te passen.

Invoegen toepassen

Als u invoegingen wilt toepassen, gebruikt u een OLE DB-bestemming omdat voor de nieuwe rijen geen speciale verwerking is vereist.

Invoegingen verwerken met behulp van een OLE DB-bestemming

1. Voeg op het tabblad Gegevensstroom een OLE DB-bestemming toe.

2. Verbind de uitvoer die invoegingen bevat van de transformatie Conditionele splitsing met de OLE DB-doelbestemming.

3. Selecteer in de OLE DB-doeleditor op de pagina Verbindingsbeheer de volgende opties:

   1. Selecteer of maak een OLE DB-Verbindingsbeheer voor de doeldatabase.

   2. Selecteer een optie voor gegevenstoegang en selecteer vervolgens de doeltabel of voer een SQL-instructie in die de doelkolommen bevat.

4. Wijs op de pagina Toewijzingen van de editor de juiste kolommen van de wijzigingsgegevens toe aan de doeltabel.

Updates toepassen

Als u updates wilt toepassen, gebruikt u een OLE DB-opdrachttransformatie. U gebruikt deze transformatie omdat u een geparameteriseerde UPDATE instructie moet gebruiken om één rij tegelijk bij te werken met de nieuwe kolomwaarden.

Updates verwerken met behulp van een OLE DB-opdrachttransformatie

1. Voeg op het tabblad Gegevensstroom een OLE DB-opdrachttransformatie toe.

2. Verbind de uitvoer die updates van de transformatie voorwaardelijk splitsen bevat met de OLE DB-opdrachttransformatie.

3. Selecteer of maak in de Geavanceerde editor voor OLE DB-opdracht op het tabblad Verbindingsbeheer een OLE DB-Verbindingsbeheer voor de doeldatabase.

4. Voer in de Geavanceerde editor voor OLE DB-opdracht, op het tabblad Eigenschappen van onderdelen, voor SqlCommand, een geparameteriseerde UPDATE instructie in.

   Een UPDATE-instructie voor een tabel Customer kan er bijvoorbeeld als volgt uitzien:

   update CDCSample.Customer  
   set TerritoryID  = ?,  
       CustomerType  = ?,  
       rowguid  = ?,  
       ModifiedDate  = ?  
   where CustomerID = ?  
   
   

5. Wijs op het tabblad Kolomtoewijzingen van de editor de juiste kolommen uit de wijzigingsgegevens toe aan de parameters in het UPDATE statement.

Verwijderbewerkingen toepassen

Als u verwijderingen wilt toepassen, gebruikt u een OLE DB-opdrachttransformatie. U gebruikt deze transformatie omdat u een geparameteriseerde DELETE instructie moet gebruiken waarmee één rij tegelijk wordt verwijderd op basis van de kolomwaarde die de rij uniek identificeert.

Verwijderingen verwerken met behulp van een OLE DB-opdrachttransformatie

1. Voeg op het tabblad Gegevensstroom een OLE DB-opdrachttransformatie toe aan de gegevensstroom.

2. Verbind de uitvoer met verwijderingen uit de transformatie voorwaardelijk splitsen met de OLE DB-opdrachttransformatie.

3. Open de Geavanceerde editor om de transformatie te configureren.

4. Selecteer of maak in de Geavanceerde editor voor OLE DB-opdracht op het tabblad Verbindingsbeheer een OLE DB-Verbindingsbeheer voor de doeldatabase.

5. Voer in de Geavanceerde editor voor OLE DB-opdracht, op het tabblad Eigenschappen van onderdelen van de editor, voor SqlCommand, een geparameteriseerde DELETE instructie in.

   Een DELETE statement voor een klanttabel kan bijvoorbeeld de volgende syntaxis hebben:

   delete from Customer where CustomerID = ?  
   
   

6. Koppel op het tabblad Kolomtoewijzingen van de editor de juiste kolom uit de wijzigingsdata aan de parameter in de DELETE statement.

Invoegen en updates optimaliseren met behulp van MERGE functionaliteit

U kunt de verwerking van invoegingen en updates optimaliseren door bepaalde opties voor het vastleggen van wijzigingsgegevens te combineren met het gebruik van het Transact-SQL MERGE trefwoord. Zie (Transact-SQL) voor meer informatie over het MERGE trefwoordMERGE.

In de Transact-SQL-instructie waarmee de wijzigingsgegevens worden opgehaald, kunt u alles opgeven met samenvoegen als de waarde van de parameter row_filter_option wanneer u de functie cdc.fn_cdc_get_net_changes_<capture_instance> aanroept. Deze functie voor het vastleggen van wijzigingsgegevens werkt efficiënter wanneer deze niet de extra verwerking hoeft uit te voeren die nodig is om invoegingen te onderscheiden van updates. Wanneer u de parameterwaarde all with merge opgeeft, is de waarde van __$operation van de wijzigingsdata 1 voor verwijderingen of 5 voor wijzigingen die zijn veroorzaakt door invoegingen of updates. Zie Ophalen en begrijpen van de wijzigingsgegevens voor meer informatie over de functie Transact-SQL die wordt gebruikt om de wijzigingsgegevens op te halen. Nadat u wijzigingen met alles hebt opgehaald met de parameterwaarde voor samenvoegen, kunt u verwijderingen toepassen en de resterende rijen uitvoeren op een tijdelijke tabel of een faseringstabel. Vervolgens kunt u in een volgende Execute SQL Task één enkele MERGE-instructie gebruiken om alle invoegingen of updates vanuit de stagingtabel op de bestemming door te voeren.