Anwenden der Änderungen auf das Ziel

Gilt für:SQL Server SSIS Integration Runtime in Azure Data Factory

Im Datenfluss eines Integration Services-Pakets, das Änderungsdaten inkrementell lädt, besteht die dritte und letzte Aufgabe darin, die Änderungen auf das Ziel anzuwenden. Sie benötigen jeweils eine Komponente, um Einfügungen, Updates und Löschungen anzuwenden.

Anwenden von Einfügungen

Zum Anwenden von Einfügungen verwenden Sie ein OLE DB-Ziel, da die neuen Zeilen keine besondere Behandlung erfordern.

So verarbeiten Sie Einfügungen mit einem OLE DB-Ziel

1. Fügen Sie auf der Registerkarte Datenfluss ein OLE DB-Ziel hinzu.

2. Verbinden Sie die Ausgabe, die Einfügevorgänge aus der Transformation „Bedingter Split“ enthält, mit dem OLE DB-Ziel.

3. Aktivieren Sie im Ziel-Editor für OLE DBauf der Seite Verbindungs-Manager die folgenden Optionen:

   1. Wählen Sie einen OLE DB-Verbindungs-Manager für die Zieldatenbank aus oder erstellen Sie einen.

   2. Wählen Sie eine Option für den Datenzugriffsmodus aus, und wählen Sie dann die Zieltabelle aus, oder geben Sie eine SQL-Anweisung mit den Zielspalten ein.

4. Ordnen Sie auf der Seite Zuordnungen des Editors die entsprechenden Spalten aus den Änderungsdaten der Zieltabelle zu.

Anwenden von Updates

Um Aktualisierungen anzuwenden, verwenden Sie eine OLE DB-Befehlstransformation. Sie verwenden diese Transformation, da Sie eine parametrisierte UPDATE Anweisung verwenden müssen, um jeweils eine Zeile mit den neuen Spaltenwerten zu aktualisieren.

Updates mit einer OLE DB-Befehl-Transformation verarbeiten

1. Fügen Sie auf der Registerkarte Datenfluss eine Transformation für OLE DB-Befehl hinzu.

2. Verbinden Sie die Ausgabe, die Updates aus der Transformation „Bedingter Split“ enthält, mit der OLE DB-Befehlstransformation.

3. Wählen Sie auf der Registerkarte Verbindungs-Managerim Erweiterten Editor für OLE DB-Befehl für die Zieldatenbank einen OLE DB-Verbindungs-Manager aus, oder erstellen Sie einen.

4. Geben Sie im Erweiterten Editor für den OLE DB-Befehl auf der Registerkarte Komponenteneigenschaften für SqlCommand eine parametrisierte UPDATE Anweisung ein.

   Eine UPDATE-Anweisung für eine Kundentabelle könnte beispielsweise folgende Syntax haben:

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

5. Ordnen Sie auf der Registerkarte "Spaltenzuordnungen" des Editors die entsprechenden Spalten aus den Änderungsdaten den Parametern in der UPDATE Anweisung zu.

Anwenden von Löschungen

Zum Anwenden von Löschvorgängen verwenden Sie eine OLE DB-Befehl-Transformation. Sie verwenden diese Transformation, da Sie eine parametrisierte DELETE Anweisung verwenden müssen, die eine einzelne Zeile gleichzeitig basierend auf dem Spaltenwert löscht, der die Zeile eindeutig identifiziert.

Löschvorgänge mithilfe einer OLE DB-Befehl-Transformation verarbeiten

1. Fügen Sie auf der Registerkarte Datenfluss dem Datenfluss eine OLE DB-Befehlstransformation hinzu.

2. Verbinden Sie die Ausgabe, die Löschvorgänge aus der Transformation „Bedingter Split“ enthält, mit der Transformation „OLE DB-Befehl“.

3. Öffnen Sie den erweiterten Editor, um die Transformation zu konfigurieren.

4. Wählen Sie auf der Registerkarte Verbindungs-Managerim Erweiterten Editor für OLE DB-Befehl für die Zieldatenbank einen OLE DB-Verbindungs-Manager aus, oder erstellen Sie einen.

5. Geben Sie im Erweiterter Editor für OLE DB-Befehl auf der Registerkarte "Komponenteneigenschaften" des Editors für SqlCommand eine parametrisierte DELETE Anweisung ein.

   Beispielsweise könnte eine DELETE Anweisung für eine Kundentabelle die folgende Syntax haben:

   delete from Customer where CustomerID = ?  
   
   

6. Ordnen Sie auf der Registerkarte "Spaltenzuordnungen " des Editors die entsprechende Spalte aus den Änderungsdaten dem Parameter in der DELETE Anweisung zu.

Optimierung von Einfügungen und Aktualisierungen mithilfe der MERGE-Funktionalität

Sie können die Verarbeitung von Einfügungen und Aktualisierungen optimieren, indem Sie bestimmte Änderungsoptionen für die Datenerfassung mit der Verwendung des Schlüsselworts Transact-SQL MERGE kombinieren. Weitere Informationen zum MERGE Schlüsselwort finden Sie unter MERGE (Transact-SQL).

In der Transact-SQL-Anweisung, mit der die Änderungsdaten abgerufen werden, können Sie all with merge als den Wert des row_filter_option-Parameters festlegen, wenn Sie die cdc.fn_cdc_get_net_changes_<capture_instance>-Funktion aufrufen. Diese Change Data Capture-Funktion arbeitet effizienter, wenn sie nicht die zusätzliche Verarbeitung ausführen muss, die erforderlich ist, um Einfügungen von Updates zu unterscheiden. Wenn Sie den all with merge -Parameterwert angeben, ist der __$operation -Wert der Änderungsdaten 1 für Löschungen oder 5 für Änderungen, die durch Einfügungen oder Updates verursacht wurden. Weitere Informationen zur Transact-SQL-Funktion, die zum Abrufen der Änderungsdaten verwendet wird, finden Sie unter Abrufen und Verstehen der Änderungsdaten. Nachdem Sie Änderungen mit dem all with merge -Parameterwert abgerufen haben, können Sie Löschungen anwenden und die übrigen Zeilen in eine temporäre Tabelle oder eine Stagingtabelle ausgeben. Anschließend können Sie in einer nachgeschalteten Execute SQL Task eine einzelne MERGE Anweisung verwenden, um alle Einfügungen oder Aktualisierungen aus der Stagingtabelle auf das Ziel anzuwenden.