Określanie, czy zmiany są gotowe

Na Przepływ sterowania Karta SSIS Projektant, dodać przepływ sterowania kontener pętli for.

Połącz zadania SQL wykonać oblicza punkty końcowe interwał w kontenerze pętli for.

W W edytorze pętli, zaznacz następujące opcje:

1. Dla InitExpression, enter @DataReady = 0.

   To wyrażenie ustawia jako wartość początkowa zmiennej pętli.

2. Dla EvalExpressionm, enter @DataReady == 0.

   Gdy to wyrażenie jest oceniane jako Fałszywe, wykonanie przekazuje z pętli i rozpoczyna się dodatkowe obciążenie.

Wewnątrz kontener pętli For Dodawanie zadania dotyczącego wykonać instrukcji SQL.

W Uruchomić Edytor zadań SQL, on the Ogólne strona, należy wybrać następujące opcje:

1. Dla ResultSet, select Jeden wiersz.

2. Należy skonfigurować poprawne połączenie ze źródłową bazą danych.

3. Dla SQLSourceType, select Bezpośredniego wprowadzania.

4. Dla SQLStatement, należy wprowadzić następującą instrukcję SQL:

   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
   

Na Parametr mapowania stronaEdytor zadań wykonać SQL, sprawdź następujące mapowania:

1. Mapować zmiennej ExtractEndTime parametru 0.

2. Parametr 1 mapować IntervalID zmiennej.

3. Mapować zmiennej ExtractStartTime parametr 2.

4. Mapować zmiennej TimeoutCount parametr 3.

5. Mapować zmiennej TimeoutCeiling parametr 4.

Na Zestaw wyników stronaUruchomić Edytor zadań SQL, mapowanie wynik DataReady do zmiennej DataReady i wynik TimeoutCount do zmiennej TimeoutCount.

Wewnątrz kontener pętli for dodać zadanie skryptu.

Łączenie zadań wykonać instrukcji SQL tej kwerendy w celu ustalenia, czy zmiana danych jest gotowy do nowego zadania skryptu.

Ograniczenia pierwszeństwo łączący zadanie wykonać instrukcji SQL z zadań skryptów, należy otworzyć Edytor ograniczenie pierwszeństwa i wybierz następujące opcje:

1. Dla Operacja oceny, select Wyrażenie i ograniczenia.

2. Dla Wartość, select SUKCES.

   Wartość ograniczenia SUKCES odnosi się do pomyślnego zakończenia poprzedniego zadania.W tym przypadek powodzenia zadanie wykonać instrukcji SQL.

3. Dla Wyrażenie, enter @DataReady == 0 && @TimeoutCount <= @TimeoutCeiling.

4. Wybierz opcję Logiczne and. Wszystkie ograniczenia musi dawać w wyniku wartość PRAWDA, , jeśli nie są już wybrane.

W Edytor zadań skryptu, on the Skrypt strona, for ReadOnlyVariables, zaznacz User::DelaySeconds liczba całkowita zmienną z listy.

W Edytor zadań skryptu, on the Skrypt strona, kliknij przycisk Edytowanie skryptu , aby otworzyć środowiska programistycznego skryptu.

W procedurze głównej należy wprowadzić jedną z następujących wierszy kodu:

• Jeśli programowaniu w języku C# wprowadzić następujący wiersz kodu:

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

  - lub -

• Jeśli użytkownik jest programowanie w Visual Basic, wpisz następujący wiersz kodu:

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

  Uwaga

  The Thread.Sleep metoda expects an argument that is specified in milliseconds.

Pozostaw domyślną linię kodu, która zwraca DtsExecResult.Success z wykonania skryptu.

Zamknij środowiska programistycznego skryptu, Edytor zadań skryptu.

Wewnątrz kontener pętli For Dodawanie zadania dotyczącego wykonać instrukcji SQL.

Łączenie zadań wykonać instrukcji SQL tej kwerendy w celu ustalenia, czy zmiana danych jest gotowy do nowego zadania wykonać instrukcji SQL.

Ograniczenia priorytetu, który łączy dwa zadania wykonać instrukcji SQL, należy otworzyć Edytor ograniczenie pierwszeństwa i wybierz następujące opcje:

1. Dla Operacja oceny, select Wyrażenie i ograniczenia.

2. Dla Wartość, select SUKCES.

   Wartość ograniczenia SUKCES odnosi się do pomyślnego zakończenia poprzedniego zadania wykonać instrukcji SQL.

3. Dla Wyrażenie, enter @DataReady == 0.

4. Wybierz opcję Logiczne and. Wszystkie ograniczenia musi dawać w wyniku wartość PRAWDA, , jeśli nie są już wybrane.

   Wybranie tej opcji wymaga, aby oba warunki, ograniczenia i wyrażenie, muszą być spełnione.

W Uruchomić Edytor zadań SQL, on the Ogólne strona, należy wybrać następujące opcje:

1. Dla ResultSet, select Jeden wiersz.

2. Należy skonfigurować poprawne połączenie ze źródłową bazą danych.

3. Dla SQLSourceType, select Bezpośredniego wprowadzania.

4. Dla SQLStatement, należy wprowadzić następującą instrukcję SQL:

   WAITFOR DELAY ?
   

Na Parametr mapowania Strona edytora, mapować zmiennej tekstowej DelaySeconds parametru 0.

Aby zgłosić błąd lub limitu czasu pisząc wiadomości w dzienniku, należy skonfigurować rejestrowania dla pakiet.Aby uzyskać więcej informacji zobaczHow to: Enable Logging in a Package.

Wewnątrz kontener pętli for dodać zadanie skryptu.

Łączenie zadań wykonać instrukcji SQL tej kwerendy w celu ustalenia, czy zmiana danych jest gotowy do nowego zadania skryptu.

Ograniczenia pierwszeństwo łączący zadanie wykonać instrukcji SQL z zadań skryptów, należy otworzyć Edytor ograniczenie pierwszeństwa i wybierz następujące opcje:

1. Dla Operacja oceny, select Wyrażenie i ograniczenia.

2. Dla Wartość, select SUKCES.

   Wartość ograniczenia SUKCES odnosi się do pomyślnego zakończenia poprzedniego zadania.W tym przypadek powodzenia zadanie wykonać instrukcji SQL.

3. Dla Wyrażenie, enter @DataReady == 1 || @DataReady == 5.

4. Wybierz opcję Logiczne and. Wszystkie ograniczenia musi dawać w wyniku wartość PRAWDA, , jeśli nie są już wybrane.

   Wybranie tej opcji wymaga, aby oba warunki, ograniczenia i wyrażenie, muszą być spełnione.

W Edytor zadań skryptu, on the Skrypt Edytor stronaReadOnlyVariables, select User::DataReady and User::ExtractStartTime z listy w celu udostępnienia ich wartości do skryptu.

Jeśli chcesz dołączyć informacje z określonych zmiennych systemowych (na przykład System::PackageName), informacje wpisywane w dzienniku, należy także wybrać tych zmiennych.

W Edytor zadań skryptu, on the Skrypt strona, kliknij przycisk Edytowanie skryptu , aby otworzyć środowiska programistycznego skryptu.

W procedurze głównej, należy wprowadzić kod do logowania się, wywołując błąd Dts.Log Metoda, lub aby podnieść zdarzenie, wywołując metody Dts.Events interfejs. Informuje pakiet błędu przywracając Dts.TaskResult = Dts.Results.Failure.

Poniższy przykład pokazuje, jak napisać wiadomość do dziennika.Aby uzyskać więcej informacji zobacz Logging in the Script Task, Podnoszenie zdarzenia w zadaniu skryptów, a Zwraca wyniki do zadania skryptu.

    ' 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

Zamknij środowiska programistycznego skryptu, Edytor zadań skryptu.