変更データのクエリの準備

[制御フロー] タブで、スクリプト タスクをパッケージの For ループ コンテナーの後に追加し、For ループ コンテナーをこのタスクに連結します。

注意
この手順では、パッケージによって 1 つのテーブルから増分読み込みが実行されることを前提としています。複数のテーブルから読み込みが実行され、パッケージに親パッケージと複数の子パッケージが存在する場合、このタスクは最初のコンポーネントとして各子パッケージに追加されます。詳細については、「複数のテーブルの増分読み込みの実行」を参照してください。

[スクリプト タスク エディター] の [スクリプト] ページで、次のオプションを選択します。

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 ループ コンテナーをこのタスクに連結します。

注意
この手順では、パッケージによって 1 つのテーブルから増分読み込みが実行されることを前提としています。複数のテーブルから読み込みが実行され、パッケージに親パッケージと複数の子パッケージが存在する場合、このタスクは最初のコンポーネントとして各子パッケージに追加されます。詳細については、「複数のテーブルの増分読み込みの実行」を参照してください。

[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 になります。