Déterminer si les données modifiées sont prêtes

Sous l'onglet Flux de contrôle du concepteur SSIS, ajoutez un conteneur de boucles For au flux de contrôle.

Connectez la tâche d'exécution SQL qui calcule les points de terminaison de l'intervalle au conteneur de boucles For.

Dans l'Éditeur de boucle For, sélectionnez les options suivantes :

1. Pour InitExpression, entrez @DataReady = 0.

   Cette expression définit la valeur initiale de la variable de boucle.

2. Pour EvalExpression, entrez @DataReady == 0.

   Lorsque cette expression donne False, l'exécution sort de la boucle et le chargement incrémentiel démarre.

Dans le conteneur de boucles For, ajoutez une tâche d'exécution SQL.

Dans l'Éditeur de tâche d'exécution SQL, dans la page Général, sélectionnez les options suivantes :

1. Pour ResultSet, sélectionnez Ligne unique.

2. Configurez une connexion valide à la base de données source.

3. Pour SQLSourceType, sélectionnez Entrée directe.

4. Pour SQLStatement, entrez l'instruction SQL suivante :

   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
   

Dans la page Mappage de paramètre de l'Éditeur de tâche d'exécution SQL, effectuez les mappages suivants :

1. Mappez la variable ExtractEndTime au paramètre 0.

2. Mappez la variable IntervalID au paramètre 1.

3. Mappez la variable ExtractStartTime au paramètre 2.

4. Mappez la variable TimeoutCount au paramètre 3.

5. Mappez la variable TimeoutCeiling au paramètre 4.

Dans la page Ensemble de résultats de l'Éditeur de tâche d'exécution SQL, mappez le résultat de DataReady à la variable DataReady, et le résultat de TimeoutCount à la variable TimeoutCount.

Dans le conteneur de boucles For, ajoutez une tâche de script.

Connectez la tâche d'exécution SQL utilisée pour déterminer si les données modifiées sont prêtes à la nouvelle tâche de script.

Pour la contrainte de précédence qui connecte la tâche d'exécution SQL à la tâche de script, ouvrez l'Éditeur de contrainte de précédence et sélectionnez les options suivantes :

1. Pour Opération d'évaluation, sélectionnez Expression et contrainte.

2. Pour Valeur, sélectionnez Succès.

   La valeur de contrainte de Succès fait référence au succès de la tâche précédente, dans le cas présent le succès de la tâche d'exécution SQL.

3. Pour Expression, entrez @DataReady == 0 && @TimeoutCount <= @TimeoutCeiling.

4. Sélectionnez Opérateur logique AND. Toutes les contraintes doivent avoir la valeur True si ce n'est déjà fait.

Dans l'Éditeur de tâche de script, dans la page Script, pour ReadOnlyVariables, sélectionnez la variable de type integer User::DelaySeconds dans la liste.

Dans l'Éditeur de tâche de script, dans la page Script, cliquez sur Modifier le script pour ouvrir l'environnement de développement de script.

Dans la procédure Main, entrez l'une des lignes de code suivantes :

• Si vous programmez en C#, entrez la ligne de code suivante :

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

  - ou -

• Si vous programmez en Visual Basic, entrez la ligne de code suivante :

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

  Notes

  La méthode Thread.Sleep attend un argument spécifié en millisecondes.

Laissez la ligne de code par défaut qui retourne DtsExecResult.Success après l'exécution du script.

Fermez l'environnement de développement de script et l'Éditeur de tâche de script.

Dans le conteneur de boucles For, ajoutez une tâche d'exécution SQL.

Connectez la tâche d'exécution SQL utilisée pour déterminer si les données modifiées sont prêtes à la nouvelle tâche d'exécution SQL.

Pour la contrainte de précédence qui connecte les deux tâches d'exécution SQL, ouvrez l'Éditeur de contrainte de précédence et sélectionnez les options suivantes :

1. Pour Opération d'évaluation, sélectionnez Expression et contrainte.

2. Pour Valeur, sélectionnez Succès.

   La valeur de contrainte de Succès fait référence au succès de la tâche d'exécution SQL précédente.

3. Pour Expression, entrez @DataReady == 0.

4. Sélectionnez Opérateur logique AND. Toutes les contraintes doivent avoir la valeur True si ce n'est déjà fait.

   Cette sélection requiert que les deux conditions, la contrainte et l'expression, soient vraies.

Dans l'Éditeur de tâche d'exécution SQL, dans la page Général, sélectionnez les options suivantes :

1. Pour ResultSet, sélectionnez Ligne unique.

2. Configurez une connexion valide à la base de données source.

3. Pour SQLSourceType, sélectionnez Entrée directe.

4. Pour SQLStatement, entrez l'instruction SQL suivante :

   WAITFOR DELAY ?
   

Dans la page Mappage de paramètre de l'éditeur, mappez la variable chaîne DelaySeconds au paramètre 0.

Si vous souhaitez signaler l'erreur ou le délai d'attente en écrivant un message dans le journal, configurez l'enregistrement pour le package. Pour plus d'informations, consultez Procédure : activer la journalisation dans un package.

Dans le conteneur de boucles For, ajoutez une tâche de script.

Connectez la tâche d'exécution SQL utilisée pour déterminer si les données modifiées sont prêtes à la nouvelle tâche de script.

Pour la contrainte de précédence qui connecte la tâche d'exécution SQL à la tâche de script, ouvrez l'Éditeur de contrainte de précédence et sélectionnez les options suivantes :

1. Pour Opération d'évaluation, sélectionnez Expression et contrainte.

2. Pour Valeur, sélectionnez Succès.

   La valeur de contrainte de Succès fait référence au succès de la tâche précédente, dans le cas présent le succès de la tâche d'exécution SQL.

3. Pour Expression, entrez @DataReady == 1 || @DataReady == 5.

4. Sélectionnez Opérateur logique AND. Toutes les contraintes doivent avoir la valeur True si ce n'est déjà fait.

   Cette sélection requiert que les deux conditions, la contrainte et l'expression, soient vraies.

Dans l'Éditeur de tâche de script, dans la page Script de l'éditeur, pour ReadOnlyVariables, sélectionnez User::DataReady et User::ExtractStartTime dans la liste pour mettre leurs valeurs à disposition du script.

Si vous souhaitez inclure les informations de certaines variables système (par exemple, System::PackageName) dans les informations que vous écrivez dans le journal, sélectionnez également ces variables.

Dans l'Éditeur de tâche de script, dans la page Script, cliquez sur Modifier le script pour ouvrir l'environnement de développement de script.

Dans la procédure Main, entrez le code soit pour enregistrer une erreur en appelant la méthode Dts.Log, soit pour déclencher un événement en appelant l'une des méthodes de l'interface Dts.Events. Informez le package de l'erreur en retournant Dts.TaskResult = Dts.Results.Failure.

L'exemple suivant montre comment écrire un message dans le journal. Pour plus d'informations, consultez Journalisation dans la tâche de script, Déclenchement d'événements dans la tâche de script et Retour de résultats de la tâche de script.

    ' 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

Fermez l'environnement de développement de script et l'Éditeur de tâche de script.