判斷變更資料是否就緒

在 SSIS 設計師的 [控制流程] 索引標籤上，將「For 迴圈」容器加入到控制流程中。

將計算間隔端點的「執行 SQL」工作連接到「For 迴圈」容器。

在 [For 迴圈編輯器] 中，選取下列選項：

1. 針對 InitExpression，輸入 @DataReady = 0。

   此運算式會設定迴圈變數的初始值。

2. 針對 EvalExpressionm，輸入 @DataReady == 0。

   當此運算式評估為 False 時，執行會通過迴圈之外，而且會開始累加式載入。

在「For 迴圈」容器的內部，加入「執行 SQL」工作。

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

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

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

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

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

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

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

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

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

4. 將 TimeoutCount 變數對應到參數 3。

5. 將 TimeoutCeiling 變數對應到參數 4。

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

在「For 迴圈」容器的內部，加入「指令碼」工作。

將查詢以判斷變更資料是否就緒的「執行 SQL」工作連接到新的「指令碼」工作。

針對將「執行 SQL」工作連接到「指令碼」工作的優先順序條件約束，開啟 [優先順序條件約束編輯器]，然後選取下列選項：

1. 針對 [評估作業]，選取 [運算式與條件約束]。

2. 針對 [數值]，選取 [成功]。

   [成功] 的條件約束值會參考前一個工作的成功。在這個情況下是「執行 SQL」工作的成功。

3. 針對 [運算式]，輸入 @DataReady == 0 && @TimeoutCount <= @TimeoutCeiling。

4. 選取 [邏輯 AND。所有的條件約束都必須評估為 True] (如果尚未選取)。

在 [指令碼工作編輯器] 的 [指令碼] 頁面上，針對 [ReadOnlyVariables]，選取清單中的 [User::DelaySeconds] 整數變數。

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

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

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

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

  -或-

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

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

  [!附註]

  Thread.Sleep 方法應為以毫秒指定的引數。

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

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

在「For 迴圈」容器的內部，加入「執行 SQL」工作。

將查詢以判斷變更資料是否就緒的「執行 SQL」工作連接到新的「執行 SQL」工作。

針對連接兩個「執行 SQL」工作的優先順序條件約束，開啟 [優先順序條件約束編輯器]，然後選取下列選項：

1. 針對 [評估作業]，選取 [運算式與條件約束]。

2. 針對 [數值]，選取 [成功]。

   [成功] 的條件約束值會參考前一個「執行 SQL」工作的成功。

3. 針對 [運算式]，輸入 @DataReady == 0。

4. 選取 [邏輯 AND。所有的條件約束都必須評估為 True] (如果尚未選取)。

   此選項需要條件約束和運算式兩個條件必須同時為 true。

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

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

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

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

4. 針對 [SQLStatement]，輸入下列 SQL 陳述式：

   WAITFOR DELAY ?
   

在編輯器的 [參數對應] 頁面上，將 DelaySeconds 字串變數對應到參數 0。

如果您要將訊息寫入記錄檔藉以報告錯誤或逾時，請設定封裝的記錄。如需詳細資訊，請參閱＜如何：啟用封裝中的記錄＞。

在「For 迴圈」容器的內部，加入「指令碼」工作。

將查詢以判斷變更資料是否就緒的「執行 SQL」工作連接到新的「指令碼」工作。

針對將「執行 SQL」工作連接到「指令碼」工作的優先順序條件約束，開啟 [優先順序條件約束編輯器]，然後選取下列選項：

1. 針對 [評估作業]，選取 [運算式與條件約束]。

2. 針對 [數值]，選取 [成功]。

   [成功] 的條件約束值會參考前一個工作的成功。在這個情況下是「執行 SQL」工作的成功。

3. 針對 [運算式]，輸入 @DataReady == 1 || @DataReady == 5。

4. 選取 [邏輯 AND。所有的條件約束都必須評估為 True] (如果尚未選取)。

   此選項需要條件約束和運算式兩個條件必須同時為 true。

在 [指令碼工作編輯器] 的 [指令碼] 頁面上，針對 [ReadOnlyVariables]，從清單選取 [User::DataReady] 和 [User::ExtractStartTime]，讓其值可以用於指令碼中。

如果您要將來自特定系統變數 (例如，System::PackageName) 的資訊加入到您要寫入記錄檔的資訊，請同時選取這些變數。

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

在 Main 程序中，呼叫 Dts.Log 方法來輸入程式碼以記錄錯誤，或呼叫 Dts.Events 介面的其中一個方法來引發事件。傳回 Dts.TaskResult = Dts.Results.Failure 以通知封裝發生錯誤。

下列範例顯示如何將訊息寫入到記錄檔中。如需詳細資訊，請參閱＜在指令碼工作中記錄＞、＜在指令碼工作中引發事件＞和＜從指令碼工作中傳回結果＞。

    ' 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

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