Preparing to Query for the Change Data

Na Przepływ sterowania Karta dodać zadania skryptu do pakiet po kontener dla pętli i połączyć się z kontenera pętli dla zadania.

W Edytor zadań skryptu, on the Skrypt strona, należy wybrać następujące opcje:

1. Dla ReadOnlyVariables, select User::DataReady, User::ExtractStartTime, and User::ExtractEndTime z.

2. Dla ReadWriteVariables, User::SqlDataQuery wybierz 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ć jeden z następujących segmentów kodu:

• Jeśli programowaniu w języku C# wpisz następujące wiersze kodu:

      int dataReady;
      System.DateTime extractStartTime;
      System.DateTime extractEndTime;
      string sqlDataQuery;
  
      dataReady = (int)Dts.Variables["DataReady"].Value;
      extractStartTime = (System.DateTime)Dts.Variables["ExtractStartTime"].Value;
      extractEndTime = (System.DateTime)Dts.Variables["ExtractEndTime"].Value;
  
      if (dataReady == 2)
        {
        sqlDataQuery = "SELECT * FROM CDCSample.uf_Customer('" + string.Format("{0:yyyy-MM-dd hh:mm:ss}", extractStartTime) + "', '" + string.Format("{0:yyyy-MM-dd hh:mm:ss}", extractEndTime) + "')";
        }
      else
        {
        sqlDataQuery = "SELECT * FROM CDCSample.uf_Customer(null" + ", '" + string.Format("{0:yyyy-MM-dd hh:mm:ss}", extractEndTime) + "')";
        }
  
      Dts.Variables("SqlDataQuery").Value = sqlDataQuery;
  

  - lub -

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

      Dim dataReady As Integer
      Dim extractStartTime As Date
      Dim extractEndTime As Date
      Dim sqlDataQuery As String
  
      dataReady = CType(Dts.Variables("DataReady").Value, Integer)
      extractStartTime = CType(Dts.Variables("ExtractStartTime").Value, Date)
      extractEndTime = CType(Dts.Variables("ExtractEndTime").Value, Date)
  
      If dataReady = 2 Then
        sqlDataQuery = "SELECT * FROM CDCSample.uf_Customer('" & _
            String.Format("{0:yyyy-MM-dd hh:mm:ss}", extractStartTime) & _
            "', '" & _
            String.Format("{0:yyyy-MM-dd hh:mm:ss}", extractEndTime) & _
            "')"
      Else
        sqlDataQuery = "SELECT * FROM CDCSample.uf_Customer(null" & _
            ", '" & _
            String.Format("{0:yyyy-MM-dd hh:mm:ss}", extractEndTime) & _
            "')"
      End If
  
      Dts.Variables("SqlDataQuery").Value = sqlDataQuery
  

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

Zamknij środowiska programistycznego skryptu, Edytor zadań skryptu.

Na Przepływ sterowania Karta dodać zadania programu wykonać instrukcji SQL do pakiet po kontener pętli for i połączyć się z kontener pętli dla tego zadania.

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 @ExtractStartTime datetime,
   @ExtractEndTime datetime, 
   @DataReady int
   
   select @DataReady = ?, 
   @ExtractStartTime = ?, 
   @ExtractEndTime = ?
   
   if @DataReady = 2
   select N'select * from CDCSample.uf_Customer'
   + N'('''+ convert(nvarchar(30),@ExtractStartTime,120)
   + ''', '''
   + convert(nvarchar(30),@ExtractEndTime,120) + ''') ' 
   as SqlDataQuery
   else
   select N'select * from CDCSample.uf_Customer'
   + N'(null, '''
   + convert(nvarchar(30),@ExtractEndTime,120)
   + ''') '
   as SqlDataQuery
   

   Uwaga

   The else klauzula in this sample generates a query for the initial load of change data by passing a null value for the starting date and czas. W tym przykładzie nie dotyczy sytuacji, w których zmiany wprowadzone przed włączeniem przechwytywania danych zmiana również muszą zostać przekazany do magazyn danych.

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

1. Mapować zmiennej DataReady parametru 0.

2. Mapować zmiennej ExtractStartTime parametr 1.

3. Mapować zmiennej ExtractEndTime parametru 2.

Na Zestaw wyników stronaUruchomić Edytor zadań SQL, mapowanie nazwy wynik do zmiennej SqlDataQuery.

Nazwa wynik jest nazwą jednej kolumnie, która jest zwracana SqlDataQuery.