変更データが準備できているかどうかの判断

SSIS デザイナーの [制御フロー] タブで、For ループ コンテナーを制御フローに追加します。

間隔のエンドポイントを計算する SQL 実行タスクを For ループ コンテナーに連結します。

[For ループ エディター] で、次のオプションを選択します。

1. [InitExpression] に「@DataReady = 0」と入力します。

   この式によって、ループ変数の初期値が設定されます。

2. [EvalExpression] に「@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 実行タスクに連結します。

2 つの 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

スクリプト開発環境と [スクリプト タスク エディター] を閉じます。