Artículo
03/30/2012

Preparación para consultar datos modificados

En el flujo de control de un paquete de Integration Services que realiza una carga incremental de datos modificados, la tercera y última tarea consiste en preparar la consulta de los datos modificados y agregar una tarea Flujo de datos.

Nota

La segunda tarea para el flujo de control consiste en asegurarse de que están listos los datos modificados para el intervalo seleccionado. Para obtener más información acerca de esta tarea, vea Determinar si los datos modificados están preparados. Para obtener una descripción del proceso general de diseño del flujo de control, vea Mejorar las cargas incrementales con la captura de datos modificados.

Para ver ejemplos completos de principio a fin que muestran el uso de la captura de datos modificados en paquetes, vea los ejemplos de Integration Services en Codeplex.

Consideraciones de diseño

Para recuperar los datos modificados, se llama a una función con valores de tabla de Transact-SQL que acepta los extremos del intervalo como parámetros de entrada y devuelve los datos modificados para el intervalo especificado. Un componente de origen del flujo de datos llama a esta función. Para obtener información sobre este componente de origen, vea Recuperar y describir datos de cambios.

Los componentes de origen de Integration Services utilizados con más frecuencia, como son el origen de OLE DB, el origen de ADO y el origen de ADO .NET, no pueden derivar información de parámetros para una función con valores de tabla. Por consiguiente, la mayoría de los orígenes no pueden llamar directamente a una función con parámetros.

Dispone de dos opciones de diseño para pasar los parámetros de entrada a la función:

Ensamblar la consulta con parámetros como una cadena. Puede utilizar una tarea Script o una tarea Ejecutar SQL para ensamblar una cadena SQL dinámica cuyos valores de parámetros estén codificados de forma rígida en la cadena. A continuación, puede almacenar esta cadena en una variable de paquete y utilizarla para establecer la propiedad SqlCommand de un componente de origen. Este enfoque tiene éxito porque el componente de origen ya no requiere la información de los parámetros.

Nota

Un script precompilado produce menos sobrecarga que una tarea Ejecutar SQL.
Utilizar un contenedor con parámetros. También puede crear un procedimiento almacenado con parámetros como un contenedor que llama a la función con valores de tabla con parámetros. Este enfoque tiene éxito porque un componente de origen puede derivar correctamente la información de parámetros para un procedimiento almacenado.

En este tema se utiliza la primera opción de diseño y se ensambla una consulta con parámetros como una cadena.

Preparar la consulta

Antes de poder concatenar los valores de los parámetros de entrada en una sola cadena de consulta, se deben establecer las variables de paquete necesarias para la consulta.

Para establecer las variables de paquetes

En Business Intelligence Development Studio, en la ventana Variables, cree una variable con un tipo de datos de cadena para guardar la cadena de consulta devuelta por la tarea Ejecutar SQL.

En este ejemplo se utiliza el nombre de variable SqlDataQuery.

Una vez creada la variable de paquete, puede utilizar una tarea Script o una tarea Ejecutar SQL para concatenar los valores de los parámetros de entrada. En los dos procedimientos siguientes se describe cómo configurar estos componentes.

Para utilizar una tarea Script para concatenar la cadena de consulta

En la ficha Flujo de control, agregue una tarea Script al paquete después del contenedor de bucles For y conecte dicho contenedor a la tarea.

Nota

En este procedimiento se supone que el paquete realiza una carga incremental desde una única tabla. Si el paquete carga de varias tablas y tiene un paquete primario con varios paquetes secundarios, esta tarea se agregaría como primer componente a cada paquete secundario. Para obtener más información, vea Realizar una carga incremental de varias tablas.
En el Editor de la tarea Script, en la página Script, seleccione las opciones siguientes:
1. Para ReadOnlyVariables, seleccione User::DataReady, User::ExtractStartTime y User::ExtractEndTime en la lista.
2. Para ReadWriteVariables, seleccione User::SqlDataQuery 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 uno de los segmentos de código siguientes:

Si está programando en C#, escriba las líneas de código siguientes:

    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;

O bien

Si está programando en Visual Basic, escriba las líneas de código siguientes:

    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

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.

Para utilizar una tarea Ejecutar SQL para concatenar la cadena de consulta

En la ficha Flujo de control, agregue una tarea Ejecutar SQL al paquete después del contenedor de bucles For y conecte dicho contenedor a esta tarea.

Nota

En este procedimiento se supone que el paquete realiza una carga incremental desde una única tabla. Si el paquete carga de varias tablas y tiene un paquete primario con varios paquetes secundarios, esta tarea se agregaría como primer componente a cada paquete secundario. Para obtener más información, vea Realizar una carga incremental de varias tablas.
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 siguiente instrucción 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
```
  Nota
  
  La cláusula else de este ejemplo genera una consulta para la carga inicial de los datos modificados pasando un valor NULL para la fecha y hora de inicio. En este ejemplo no se contempla el escenario en el que los cambios que se realizaron antes de habilitar la captura de datos modificados también deben cargarse en el almacenamiento de datos.
En la página Asignación de parámetros del Editor de la tarea Ejecutar SQL, haga la asignación siguiente:
1. Asigne la variable DataReady al parámetro 0.
2. Asigne la variable ExtractStartTime al parámetro 1.
3. Asigne la variable ExtractEndTime al parámetro 2.
En la página Conjunto de resultados del Editor de la tarea Ejecutar SQL, asigne el nombre del resultado a la variable SqlDataQuery.

El nombre del resultado es el nombre de la única columna que se devuelve, SqlDataQuery.

Los procedimientos anteriores configuran una tarea que prepara una cadena de consulta con valores de cadena codificados de forma rígida para los parámetros de entrada. El código siguiente es un ejemplo de este tipo de cadena de consulta:

select * from CDCSample. uf_Customer('2007-06-11 14:21:58', '2007-06-12 14:21:58')

Agregar una tarea Flujo de datos

El último paso para diseñar el flujo de control para el paquete consiste en agregar una tarea Flujo de datos.

Para agregar una tarea Flujo de datos y completar el flujo de control

En la ficha Flujo de control, agregue una tarea Flujo de Datos y conecte la tarea que concatenó la cadena de consulta.

Paso siguiente

Después de preparar la cadena de consulta y configurar la tarea Flujo de Datos, el paso siguiente consiste en crear la función con valores de tabla que recuperará los datos modificados de la base de datos.

Tema siguiente: Crear la función para recuperar los datos modificados

Manténgase al día con Integration Services

Para obtener las más recientes descargas, artículos, ejemplos y vídeos de Microsoft, así como soluciones seleccionadas de la comunidad, visite la página de Integration Services en MSDN o TechNet:

Para recibir notificaciones automáticas de estas actualizaciones, suscríbase a las fuentes RSS disponibles en la página.

Share via