Preparación para consultar datos modificados
En el flujo de control de un paquete de Integration Services que realice 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 extremo a extremo que muestren el uso de la captura de datos modificados en paquetes, vea el ejemplo Captura de datos modificados para el paquete de intervalo especificado y el ejemplo Captura de datos modificados desde el paquete de la última solicitud 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 Recuperación y descripción de datos de cambios.
Los componentes de origen de Integration Services utilizados con más frecuencia, incluidos 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:
Para ReadOnlyVariables, seleccione User::DataReady, User::ExtractStartTime y User::ExtractEndTime en la lista.
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 scripts.
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 scripts 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:
En ResultSet, seleccione Fila única.
Configure una conexión válida con una base de datos de origen.
En SQLSourceType, seleccione Entrada directa.
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:
Asigne la variable DataReady al parámetro 0.
Asigne la variable ExtractStartTime al parámetro 1.
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
|
.gif "Icono de Integration Services (pequeño)")
Manténgase al día con Integration Services