Değiştir hazır veridir olup olmadığını belirleme

,Akış denetimi sekmesini SSISTasarımcısı, bir for döngüsü ekleme kapsayıcı denetim akışı.

yürütmek SQL for döngüsü için aralığın bitiş hesaplayan görevi bağlamak kapsayıcı.

,Döngü Düzenleyicisi için, aşağıdaki seçenekleri belirleyin:

1. İçinInitExpression, enter @DataReady = 0.

   Bu ifade döngünün değişkeninin başlangıç değeri belirler.

2. İçinEvalExpressionm, enter @DataReady == 0.

   Bu deyimin sonucu içinYanlışdöngü ve artan yükü başlar. , yürütme geçirir

Döngü için kapsayıcı içinde bir SQL yürütmek görev ekleyin.

,yürütmek SQL görev DüzenleyicisiGenel üzerinde sayfa, aşağıdaki seçenekleri belirleyin:

1. İçinResultSet, select Single row.

2. Kaynak veritabanı için geçerli bir bağlantı yapılandırın.

3. İçinSQLSourceType, seçme doğrudan giriş .

4. İçinSQLStatement, aşağıdaki SQL deyim girin:

   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
   

,Parametre eşleme sayfa yürütmek SQL görev Düzenleyicisi, şu eşlemeleri olun:

1. ExtractEndTime değişkeni 0 parametre olarak eşler.

2. IntervalID değişken parametre 1 eşleyin.

3. ExtractStartTime değişken parametre 2 eşleyin.

4. Parametre 3 TimeoutCount değişken eşleyin.

5. Parametre 4 TimeoutCeiling değişken eşleyin.

,Sonuç kümesi sayfa yürütmek SQL görev Düzenleyicisi'ni, DataReady değişkeni ve TimeoutCount değişkenini. TimeoutCount sonucu DataReady sonucu eşleme

Döngü için kapsayıcı içinde bir komut dosyası eklemek.

SQL yürütmek Görev değişikliği verileri yeni kod göreve hazır olup olmadığını belirlemek için sorguladığı bağlayın.

Açın komut dosyası göreve yürütmek SQL görev bağlayan öncelik kısıtlaması içinÖncelikli sınırlama Düzenleyicisi ve aşağıdaki seçeneklerden seçin:

1. İçinDeğerlendirme işlemi, seçin ifade ve kısıtlama .

2. İçinDeğer seçme başarılı .

   Kısıtlama değeriBaşarı başarısı için önceki görevi. gösterir Bu durumda, SQL yürütmek görevin başarısı.

3. İçinİfade, enter @DataReady == 0 && @TimeoutCount <= @TimeoutCeiling.

4. SeçinMantıksal AND. Tüm kısıtlamalar için doğru , seçili değilse değerlendirmelidir.

,Komut dosyası görev Düzenleyicisikomut dosyası üzerinde sayfa, listesi. User::DelaySeconds tamsayı değişkeni ReadOnlyVariables, seçmek için

,Komut dosyası görev Düzenleyicisikomut dosyası geliştirme ortamı. açmak için Komut dosyası Düzenle Script sayfasında tıklatın

Ana yordamda, aşağıdaki kod satırlarını birini girin:

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

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

  -ya da-

• Durumunda programlamaVisual Basic, aşağıdaki kod satırını girin:

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

  Not

  The Thread.Sleep method expects an argument that is specified in milliseconds.

Kod, sayı varsayılan satır bırakın.DtsExecResult.Successkomut yürütülmesi arasında

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

Döngü için kapsayıcı içinde bir SQL yürütmek görev ekleyin.

SQL yürütmek Görev değişikliği verileri yeni yürütmek SQL göreve hazır olup olmadığını belirlemek için sorguladığı bağlayın.

yürütmek SQL iki görevi birbirine bağlayan öncelik kısıtlaması için açıkÖncelikli sınırlama Düzenleyicisi ve aşağıdaki seçeneklerden seçin:

1. İçinDeğerlendirme işlemi, seçin ifade ve kısıtlama .

2. İçinDeğer, select Success.

   Kısıtlama değeriBaşarı başarısı için önceki SQL Yürüt görev. gösterir

3. İçinİfade, enter @DataReady == 0.

4. SeçinMantıksal AND. Tüm kısıtlamalar için doğru , seçili değilse değerlendirmelidir.

   Bu koşul, kısıtlama ve ifade olması gerektiğini doğru gerektirir.

,yürütmek SQL görev DüzenleyicisiGenel üzerinde sayfa, aşağıdaki seçenekleri belirleyin:

1. İçinResultSet, select Single row.

2. Kaynak veritabanı için geçerli bir bağlantı yapılandırın.

3. İçinSQLSourceType, seçme doğrudan giriş .

4. İçinSQLStatement, aşağıdaki SQL deyim girin:

   WAITFOR DELAY ?
   

,Parametre eşleme sayfa Düzenleyicisi, DelaySeconds dize değişkeni 0 parametre olarak eşleştirmek.

İleti günlüğe yazarak hata veya zaman aşımı bildirmek isterseniz, günlüğü paket için yapılandırın.Daha fazla bilgi için bkz:Nasıl Yapılır: Bir paket'nde günlüğü etkinleştir.

Döngü için kapsayıcı içinde bir komut dosyası eklemek.

SQL yürütmek Görev değişikliği verileri yeni kod göreve hazır olup olmadığını belirlemek için sorguladığı bağlayın.

Açın komut dosyası göreve yürütmek SQL görev bağlayan öncelik kısıtlaması içinÖncelikli sınırlama Düzenleyicisi ve aşağıdaki seçeneklerden seçin:

1. İçinDeğerlendirme işlemi, seçin ifade ve kısıtlama .

2. İçinDeğer, select Success.

   Kısıtlama değeriBaşarı başarısı için önceki görevi. gösterir Bu durumda, SQL yürütmek görevin başarısı.

3. İçinİfade, enter @DataReady == 1 || @DataReady == 5.

4. SeçinMantıksal AND. Tüm kısıtlamalar için doğru , seçili değilse değerlendirmelidir.

   Bu koşul, kısıtlama ve ifade olması gerektiğini doğru gerektirir.

,Komut dosyası görev Düzenleyicisikomut dosyası üzerinde sayfa ReadOnlyVariables, için düzenleyici, User::DataReadyUser::ExtractStartTime değerleri için script. kullanılabilir hale getirmek için listeden seçip

Bazı sistem değişkenlerini (örneğin, System::PackageName) bilgileri günlüğe yazma bilgileri eklemek isterseniz, bu değişkenleri de seçin.

,Komut dosyası görev Düzenleyicisikomut dosyası geliştirme ortamı. açmak için Komut dosyası Düzenle Script sayfasında tıklatın

Ana yordamda hata çağırarak oturum girmeyeDts.Logyöntem veya yöntemlerinden birini çağırarak bir olay oluşturmak içinDts.Eventsarabirim.Hata döndüren tarafından paket ınformDts.TaskResult = Dts.Results.Failure.

Aşağıdaki örnek, bir ileti günlüğe yazma gösterilmiştir.Daha fazla bilgi için bkz:Oturum açma komut dosyası görev,Komut dosyası görev olayları yükseltme, veKomut dosyası görevden sonuçları döndürülüyor.

    ' 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

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