Determinar si los datos modificados están preparados

En la ficha Flujo de control del Diseñador SSIS, agregue un contenedor de bucles For al flujo de control.

Conecte la tarea Ejecutar SQL que calcula los extremos del intervalo al contenedor de bucles For.

En el Editor de bucles For, seleccione las opciones siguientes:

1. Para InitExpression, escriba @DataReady = 0.

   Esta expresión establece el valor inicial de la variable de bucle.

2. Para EvalExpression, escriba @DataReady == 0.

   Cuando esta expresión se evalúa como False, la ejecución se transfiere al bucle y comienza la carga incremental.

Dentro del contenedor de bucles For, agregue una tarea Ejecutar SQL.

En el Editor de la tarea Ejecutar SQL, en la página General, seleccione las opciones siguientes:

1. En ResultSet, seleccione Fila única.

2. Configure una conexión válida con una base de datos de origen.

3. En SQLSourceType, seleccione Entrada directa.

4. En SQLStatement, escriba la instrucción SQL siguiente:

   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
   

En la página Asignación de parámetros del Editor de la tarea Ejecutar SQL, realice las asignaciones siguientes:

1. Asigne la variable ExtractEndTime al parámetro 0.

2. Asigne la variable IntervalID al parámetro 1.

3. Asigne la variable ExtractStartTime al parámetro 2.

4. Asigne la variable TimeoutCount al parámetro 3.

5. Asigne la variable TimeoutCeiling al parámetro 4.

En la página Conjunto de resultados del Editor de la tarea Ejecutar SQL, asigne el resultado de DataReady a la variable DataReady, y el resultado de TimeoutCount a la variable TimeoutCount.

Dentro del contenedor de bucles For, agregue una tarea Script.

Conecte a la nueva tarea Script la tarea Ejecutar SQL que hace la consulta para determinar si los datos modificados están preparados.

Para obtener la restricción de precedencia que conecta la tarea Ejecutar SQL a la tarea Script, abra el Editor de restricciones de precedencia y seleccione las opciones siguientes:

1. En Operación de evaluación, seleccione Expresión y restricción.

2. En Valor, seleccione Correcto.

   El valor de restricción Correcto se refiere a la tarea anterior. En este caso, la tarea Ejecutar SQL debe haberse realizado correctamente.

3. Para Expresión, escriba @DataReady == 0 && @TimeoutCount <= @TimeoutCeiling.

4. Seleccione AND lógico. Todas las restricciones deben evaluarse como True, si no está ya seleccionada.

En el Editor de la tarea Script, en la página Script, para ReadOnlyVariables, seleccione la variable de entero User::DelaySeconds en la lista.

En el Editor de la tarea Script, en la página Script, haga clic en Modificar script para abrir el entorno de desarrollo de script.

En el procedimiento Main, escriba una de las líneas de código siguientes:

• Si está programando en C#, escriba la línea de código siguiente:

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

  O bien

• Si está programando en Visual Basic, escriba la línea de código siguiente:

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

  Nota

  El método Thread.Sleep espera un argumento especificado en milisegundos.

Deje la línea de código predeterminada que devuelve DtsExecResult.Success de la ejecución del script.

Cierre el entorno de desarrollo de script y el Editor de la tarea Script.

Dentro del contenedor de bucles For, agregue una tarea Ejecutar SQL.

Conecte a la nueva tarea Ejecutar SQL la tarea Ejecutar SQL que hace la consulta para determinar si los datos modificados están preparados.

Para obtener la restricción de precedencia que conecta las dos tareas Ejecutar SQL, abra el Editor de restricciones de precedencia y seleccione las opciones siguientes:

1. En Operación de evaluación, seleccione Expresión y restricción.

2. En Valor, seleccione Correcto.

   El valor de restricción Correcto se refiere a la tarea Ejecutar SQL anterior.

3. Para Expresión, escriba @DataReady == 0.

4. Seleccione AND lógico. Todas las restricciones deben evaluarse como True, si no está ya seleccionada.

   Esta selección requiere que ambas condiciones, la restricción y la expresión, sean true.

En el Editor de la tarea Ejecutar SQL, en la página General, seleccione las opciones siguientes:

1. En ResultSet, seleccione Fila única.

2. Configure una conexión válida con una base de datos de origen.

3. En SQLSourceType, seleccione Entrada directa.

4. En SQLStatement, escriba la instrucción SQL siguiente:

   WAITFOR DELAY ?
   

En la página Asignación de parámetros del editor, asigne la variable de cadena DelaySeconds al parámetro 0.

Si desea informar del error o de que se ha superado el tiempo de espera escribiendo un mensaje en el registro, configure el registro para el paquete. Para obtener más información, vea Cómo habilitar el registro en un paquete.

Dentro del contenedor de bucles For, agregue una tarea Script.

Conecte a la nueva tarea Script la tarea Ejecutar SQL que hace la consulta para determinar si los datos modificados están preparados.

Para obtener la restricción de precedencia que conecta la tarea Ejecutar SQL a la tarea Script, abra el Editor de restricciones de precedencia y seleccione las opciones siguientes:

1. En Operación de evaluación, seleccione Expresión y restricción.

2. En Valor, seleccione Correcto.

   El valor de restricción Correcto se refiere a la tarea anterior. En este caso, la tarea Ejecutar SQL debe haberse realizado correctamente.

3. Para Expresión, escriba @DataReady == 1 || @DataReady == 5.

4. Seleccione AND lógico. Todas las restricciones deben evaluarse como True, si no está ya seleccionada.

   Esta selección requiere que ambas condiciones, la restricción y la expresión, sean true.

En el Editor de la tarea Script, en la página Script del editor, para ReadOnlyVariables, seleccione User::DataReady y User::ExtractStartTime en la lista para que sus valores estén disponibles para el script.

Si desea incluir datos de ciertas variables del sistema (por ejemplo, System::PackageName) en la información que escribe en el registro, seleccione también dichas variables.

En el Editor de la tarea Script, en la página Script, haga clic en Modificar script para abrir el entorno de desarrollo de script.

En el procedimiento Main, escriba el código para registrar un error llamando al método Dts.Log o el código para provocar un evento llamando a uno de los métodos de la interfaz Dts.Events. Para informar del error al paquete, devuelva Dts.TaskResult = Dts.Results.Failure.

El ejemplo siguiente muestra cómo escribir un mensaje en el registro. Para obtener más información, vea Registrar en la tarea Script, Provocar eventos en la tarea Script y Devolver los resultados de la tarea 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

Cierre el entorno de desarrollo de script y el Editor de la tarea Script.