準備查詢變更資料

在 [控制流程] 索引標籤上，將「指令碼」工作加入到「For 迴圈」容器後的封裝中，然後將「For 迴圈」容器連接到該工作。

在 [指令碼工作編輯器] 的 [指令碼] 頁面上，選取下列選項：

1. 針對 [ReadOnlyVariables]，選取 [User::DataReady]、[User::ExtractStartTime] 和 [User::ExtractEndTime]。

2. 針對 [ReadWriteVariables]，從清單中選取 [User::SqlDataQuery]。

在 [指令碼工作編輯器] 的 [指令碼] 頁面上，按一下 [編輯指令碼] 來開啟指令碼開發環境。

在 Main 程序中，輸入下列其中一個程式碼區段：

• 如果您是以 C# 撰寫程式，輸入下列程式碼行：

      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;
  

  -或-

• 如果您是以 Visual Basic 撰寫程式，輸入下列程式碼行：

      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
  

保留從指令碼之執行傳回 DtsExecResult.Success 的預設程式碼行。

關閉指令碼開發環境以及 [指令碼工作編輯器]。

在 [控制流程] 索引標籤上，將「執行 SQL」工作加入到「For 迴圈」容器後的封裝中，然後將「For 迴圈」容器連接到該工作。

在 [執行 SQL 工作編輯器] 的 [一般] 頁面上，選取下列選項：

1. 針對 [ResultSet]，選取 [單一資料列]。

2. 將有效的連接設定到來源資料庫。

3. 針對 [SQLSourceType]，選取 [直接輸入]。

4. 針對 [SQLStatement]，輸入下列 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
   

   [!附註]

   此範例中的 else 子句會傳遞開始日期和時間的 null 值，藉以產生變更資料之初始載入的查詢。此範例不處理啟用異動資料擷取前所進行之變更也必須上傳到資料倉儲的狀況。

在 [執行 SQL 工作編輯器] 的 [參數對應] 頁面上，進行下列對應：

1. 將 DataReady 變數對應到參數 0。

2. 將 ExtractStartTime 變數對應到參數 1。

3. 將 ExtractEndTime 變數對應到參數 2。

在 [執行 SQL 工作編輯器] 的 [結果集] 頁面上，將 [結果名稱] 對應到 SqlDataQuery 變數。

[結果名稱] 是所傳回之單一資料行的名稱，也就是 SqlDataQuery。