Sorgu Değiştir veriler için hazırlanılıyor

Üzerinde denetim akışı sekmesinde, bir komut dosyası görev paket için döngü kapsayıcı sonra ekleyip için döngü kapsayıcı göreve bağlandığınızda.

Içinde Komut dosyası görev Düzenleyicisi, on the Komut dosyası sayfasında, aşağıdaki seçenekleri işaretleyin:

1. Için ReadOnlyVariables, select User::DataReady, User::ExtractStartTime, and User::ExtractEndTime gelen.

2. Için ReadWriteVariables, listeden seçim User::SqlDataQuery.

Içinde Komut dosyası görev Düzenleyicisi, on the Komut dosyası sayfasında, tıklatın.Komut dosyası Düzenle komut dosyası geliştirme ortamı'nı açın.

Ana yordamda, aşağıdaki kod kesimi birini girin:

• C# programlama, aşağıdaki kod satırlarını girin:

      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;
  

  -ya da-

• Içinde programlama, Visual Basic, aşağıdaki kod satırlarını girin:

      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
  

Varsayılan satır döndüren bir kod bırak DtsExecResult.Success komut dosyasının yürütülmesine.

Komut dosyası geliştirme ortamı'nı kapatın ve Komut dosyası görev Düzenleyicisi.

Üzerinde denetim akışı sekmesinde, bir SQL Yürüt) görevi için döngü kapsayıcı sonra pakete eklemek ve için döngü kapsayıcı bu göreve bağlamak.

Içinde Görev Düzenleyicisi SQL Yürüt, on the Genel sayfasında, aşağıdaki seçenekleri işaretleyin:

1. Için ResultSet, select Tek satır.

2. Geçerli bir kaynak veritabanı bağlantısını yapılandırın.

3. Için SQLSourceType, select Doğrudan giriş.

4. Için SQLStatement, aşağıdaki SQL deyim girin:

   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
   

   Not

   The else yan tümce in this sample generates a query for the initial load of change data by passing a null value for the starting tarih and saat. Bu örnek değişiklik veri yakalama etkinleştirilmeden önce yapılan değişiklikler de veri ambarı için karşıya yüklenecek olduğu senaryonun gidermez.

Üzerinde Parametre eşleme sayfaSQL yürütmek görev Düzenleyicisi, aşağıdaki eşleme yapmak:

1. DataReady değişkeni 0 parametre eşleyin.

2. Parametre 1 ExtractStartTime değişkeni ile eşleştirin.

3. ExtractEndTime değişkeni 2 parametre eşleyin.

Üzerinde Sonuç küme sayfaGörev Düzenleyicisi SQL Yürüt, sonucu SqlDataQuery değişkenine eşleyen.

Sonuç, SqlDataQuery döndürülen tek sütun adını addır.