Bestimmen, ob die Änderungsdaten bereit sind

Fügen Sie auf der Registerkarte Ablaufsteuerung des SSIS-Designers der Ablaufsteuerung einen For-Schleifencontainer hinzu.

Verbinden Sie den Task "SQL ausführen", der die Endpunkte des Intervalls berechnet, mit dem For-Schleifencontainer.

Aktivieren Sie im For-Schleifen-Editor die folgenden Optionen:

1. Geben Sie für InitExpression@DataReady = 0 ein.

   Dieser Ausdruck legt den Anfangswert der Schleifenvariablen fest.

2. Geben Sie für EvalExpression@DataReady == 0 ein.

   Wenn dieser Ausdruck False ergibt, wird die Ausführung aus der Schleife weitergegeben, und das inkrementelle Laden beginnt.

Fügen Sie innerhalb des For-Schleifencontainers einen Task "SQL ausführen" hinzu.

Aktivieren Sie im Skripttask-Editor auf der Seite Skript die folgenden Optionen:

1. Wählen Sie für ResultSet die Option Einzelne Zeile aus.

2. Konfigurieren Sie zur Quelldatenbank eine gültige Verbindung.

3. Wählen Sie für SQLSourceType die Option Direkteingabe aus.

4. Geben Sie für SQLStatement die folgende SQL-Anweisung ein:

   declare @DataReady int, @TimeoutCount int
   
   if not exists (select tran_end_time from cdc.lsn_time_mapping
           where tran_end_time > ?  )
       select @DataReady = 0
   else
       if ? = 0
           select @DataReady = 3 
   else
       if not exists (select tran_end_time from cdc.lsn_time_mapping
               where tran_end_time <= ? )
           select @DataReady = 1 
   else
       select @DataReady = 2
   
   select @TimeoutCount = ?
   if (@DataReady = 0)
       select @TimeoutCount = @TimeoutCount + 1
   else
       select @TimeoutCount = 0
   
   if (@TimeoutCount > ?)
       select @DataReady = 5
   
   select @DataReady as DataReady, @TimeoutCount as TimeoutCount
   

Nehmen Sie auf der Seite Parameterzuordnung vom Editor für den Task 'SQL ausführen' die folgenden Zuordnungen vor:

1. Ordnen Sie dem Parameter 0 die ExtractEndTime-Variable zu.

2. Ordnen Sie dem Parameter 1 die IntervalID-Variable zu.

3. Ordnen Sie dem Parameter 2 die ExtractStartTime-Variable zu.

4. Ordnen Sie dem Parameter 3 die TimeoutCount-Variable zu.

5. Ordnen Sie dem Parameter 4 die TimeoutCeiling-Variable zu.

Ordnen Sie auf der Seite Resultset vom Editor für den Task 'SQL ausführen' das DataReady-Ergebnis der DataReady-Variablen und das TimeoutCount-Ergebnis der TimeoutCount-Variablen zu.

Fügen Sie innerhalb des For-Schleifencontainers einen Skripttask hinzu.

Verbinden Sie den abfragenden Task "SQL ausführen", um zu bestimmen, ob die Änderungsdaten für den neuen Skripttask bereit sind.

Für die Rangfolgeneinschränkung, die den Task "SQL ausführen" mit dem Skripttask verbindet, öffnen Sie den Rangfolgeneinschränkungs-Editor, und wählen Sie die folgenden Optionen aus:

1. Wählen Sie für AuswertungsvorgangAusdruck und Einschränkung aus.

2. Wählen Sie für WertErfolg aus.

   Der Einschränkungswert von Erfolg verweist auf den Erfolg des vorherigen Tasks. In diesem Fall auf den Erfolg des Tasks "SQL ausführen".

3. Geben Sie für Ausdruck@DataReady == 0 && @TimeoutCount <= @TimeoutCeiling ein.

4. Wählen Sie Logisches AND. Alle Einschränkungen müssen True ergeben aus, wenn dies nicht bereits ausgewählt wurde.

Wählen Sie im Skripttask-Editor auf der Seite Skript für ReadOnlyVariables die ganzzahlige Variable User::DelaySeconds aus der Liste aus.

Klicken Sie im Skripttask-Editor auf der Seite Skript auf Skript bearbeiten, um die Skriptentwicklungsumgebung zu öffnen.

Geben Sie in der Main-Prozedur eine der folgenden Codezeilen ein:

• Wenn Sie in C# programmieren, geben Sie die folgende Codezeile ein:

  System.Threading.Thread.Sleep((int)Dts.Variables["DelaySeconds"].Value * 1000);
  

  - Oder -

• Wenn Sie in Visual Basic programmieren, geben Sie die folgende Codezeile ein:

  System.Threading.Thread.Sleep(Ctype(Dts.Variables("DelaySeconds").Value, Integer) * 1000)
  

  Hinweis
  Die Thread.Sleep-Methode erwartet ein Argument, das in Millisekunden angegeben wird.

Verlassen Sie die Standardcodezeile, die DtsExecResult.Success von der Ausführung des Skripts zurückgibt.

Schließen Sie die Skriptentwicklungsumgebung und den Skripttask-Editor.

Fügen Sie innerhalb des For-Schleifencontainers einen Task "SQL ausführen" hinzu.

Verbinden Sie den abfragenden Task "SQL ausführen", um zu bestimmen, ob die Änderungsdaten für den neuen Task "SQL ausführen" bereit sind.

Für die Rangfolgeneinschränkung, die die zwei Tasks "SQL ausführen" verbindet, öffnen Sie den Rangfolgeneinschränkungs-Editor, und wählen Sie die folgenden Optionen aus:

1. Wählen Sie für AuswertungsvorgangAusdruck und Einschränkung aus.

2. Wählen Sie für WertErfolg aus.

   Der Einschränkungswert von Erfolg verweist auf den Erfolg des vorherigen Tasks "SQL ausführen".

3. Geben Sie für Ausdruck@DataReady == 0 ein.

4. Wählen Sie Logisches AND. Alle Einschränkungen müssen True ergeben aus, wenn dies nicht bereits ausgewählt wurde.

   Diese Auswahl erfordert, dass beide Bedingungen, die Einschränkung und der Ausdruck, den Wert true haben müssen.

Aktivieren Sie im Skripttask-Editor auf der Seite Skript die folgenden Optionen:

1. Wählen Sie für ResultSet die Option Einzelne Zeile aus.

2. Konfigurieren Sie zur Quelldatenbank eine gültige Verbindung.

3. Wählen Sie für SQLSourceType die Option Direkteingabe aus.

4. Geben Sie für SQLStatement die folgende SQL-Anweisung ein:

   WAITFOR DELAY ?
   

Ordnen Sie auf der Seite Parameterzuordnung des Editors dem Parameter 0 die DelaySeconds-Zeichenfolgenvariable zu.

Wenn Sie den Fehler oder das Timeout berichten möchten, indem Sie eine Meldung ins Protokoll schreiben, konfigurieren Sie die Protokollierung für das Paket. Weitere Informationen finden Sie unter Vorgehensweise: Aktivieren der Protokollierung in einem Paket.

Fügen Sie innerhalb des For-Schleifencontainers einen Skripttask hinzu.

Verbinden Sie den abfragenden Task "SQL ausführen", um zu bestimmen, ob die Änderungsdaten für den neuen Skripttask bereit sind.

Für die Rangfolgeneinschränkung, die den Task "SQL ausführen" mit dem Skripttask verbindet, öffnen Sie den Rangfolgeneinschränkungs-Editor, und wählen Sie die folgenden Optionen aus:

1. Wählen Sie für AuswertungsvorgangAusdruck und Einschränkung aus.

2. Wählen Sie für WertErfolg aus.

   Der Einschränkungswert von Erfolg verweist auf den Erfolg des vorherigen Tasks. In diesem Fall auf den Erfolg des Tasks "SQL ausführen".

3. Geben Sie für Ausdruck@DataReady == 1 || @DataReady == 5 ein.

4. Wählen Sie Logisches AND. Alle Einschränkungen müssen True ergeben aus, wenn dies nicht bereits ausgewählt wurde.

   Diese Auswahl erfordert, dass beide Bedingungen, die Einschränkung und der Ausdruck, den Wert true haben müssen.

Wählen Sie im Skripttask-Editor auf der Seite Skript des Editors für ReadOnlyVariablesUser::DataReady und User::ExtractStartTime aus der Liste aus, um deren Werte für das Skript verfügbar zu machen.

Wenn Sie Informationen von bestimmten Systemvariablen (z. B. System::PackageName) in die Informationen, die in das Protokoll geschrieben werden, einschließen möchten, wählen Sie auch diese Variablen aus.

Klicken Sie im Skripttask-Editor auf der Seite Skript auf Skript bearbeiten, um die Skriptentwicklungsumgebung zu öffnen.

Geben Sie in der Main-Prozedur Code ein, um einen Fehler zu protokollieren, indem Sie die Dts.Log-Methode aufrufen, oder um ein Ereignis auszulösen, indem Sie eine der Methoden der Dts.Events-Schnittstelle aufrufen. Informieren Sie das Paket über den Fehler, indem Sie Dts.TaskResult = Dts.Results.Failure zurückgeben.

Im folgenden Beispiel wird gezeigt, wie eine Meldung ins Protokoll geschrieben wird. Weitere Informationen finden Sie unter Protokollieren im Skripttask, Auslösen von Ereignissen im Skripttask und Zurückgeben von Ergebnissen aus dem Skripttask.

    ' User variables.
    Dim dataReady As Integer = _
      CType(Dts.Variables("DataReady").Value, Integer)
    Dim extractStartTime As Date = _
      CType(Dts.Variables("ExtractStartTime").Value, DateTime)

    ' System variables.
    Dim packageName As String = _
      Dts.Variables("PackageName").Value.ToString()
    Dim executionStartTime As Date = _
      CType(Dts.Variables("StartTime").Value, DateTime)

    Dim eventMessage As New System.Text.StringBuilder()

    If dataReady = 1 OrElse dataReady = 5 Then

      If dataReady = 1 Then
        eventMessage.AppendLine("Start Time Error")
      Else
        eventMessage.AppendLine("Timeout Error")
      End If

      With eventMessage
        .Append("The package ")
        .Append(packageName)
        .Append(" started at ")
        .Append(executionStartTime.ToString())
        .Append(" and ended at ")
        .AppendLine(DateTime.Now().ToString())
        If dataReady = 1 Then
          .Append("The specified ExtractStartTime was ")
          .AppendLine(extractStartTime.ToString())
        End If
      End With

      System.Windows.Forms.MessageBox.Show(eventMessage.ToString())

      Dts.Log(eventMessage.ToString(), 0, Nothing)

      Dts.TaskResult = Dts.Results.Failure

    Else

      Dts.TaskResult = Dts.Results.Success

    End If

Schließen Sie die Skriptentwicklungsumgebung und den Skripttask-Editor.