Preparando para consultar pelos dados de alteração

Na guia Fluxo de Controle, adicione uma tarefa Script ao pacote após o contêiner Loop For e conecte o contêiner Loop For à tarefa.

Observação
Este procedimento assume que o pacote executa uma carga incremental a partir de uma tabela simples. Caso o pacote faça os carregamentos a partir de várias tabelas e tenha um pacote pai com vários pacotes filhos, a tarefa será adicionada como o primeiro componente para cada pacote filho. Para obter mais informações, consulte Executando uma carga incremental de várias tabelas.

No Editor da Tarefa Script, na página Script, selecione as seguintes opções:

1. Para ReadOnlyVariables, selecione User::DataReady, User::ExtractStartTime e User::ExtractEndTime.

2. Para ReadWriteVariables, selecione User::SqlDataQuery na lista.

No Editor da Tarefa Script, na página Script, clique em Editar Script para abrir o ambiente de desenvolvimento de script.

No procedimento Principal, digite um dos seguintes segmentos de código:

• Se você estiver programando em C#, digite a seguinte linha de código:

      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;
  

  - ou -

• Se você estiver programando em Visual Basic, digite as seguintes linhas de código:

      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
  

Tire a linha padrão de código que retorna DtsExecResult.Success da execução do script.

Feche o ambiente de desenvolvimento de script e o Editor da Tarefa Script.

Na guia Fluxo de Controle, adicione uma tarefa Executar SQL ao pacote após o contêiner Loop For e conecte o contêiner Loop For à essa tarefa.

Observação
Este procedimento assume que o pacote executa uma carga incremental a partir de uma tabela simples. Caso o pacote faça os carregamentos a partir de várias tabelas e tenha um pacote pai com vários pacotes filhos, a tarefa será adicionada como o primeiro componente para cada pacote filho. Para obter mais informações, consulte Executando uma carga incremental de várias tabelas.

Em Editor da Tarefa Executar SQL, na página Geral, selecione as seguintes opções:

1. Para Conjuntos de Resultados, selecione Linha simples.

2. Configure uma conexão válida com o banco de dados de origem.

3. Para SQLSourceType, selecione Entrada direta.

4. Para SQLStatement, digite a seguinte instrução 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
   

   Observação
   Neste exemplo, a cláusula else gera uma consulta para a carga inicial dos dados de alteração indicando um valor nulo para a data e hora iniciais. Este exemplo não indica o cenário em que as alterações realizadas antes da captura dos dados de alteração também tenham que ser carregadas para o Data Warehouse.

Na página Mapeamento de Parâmetros do Editor de tarefa Executar SQL, faça o seguinte mapeamento:

1. Mapeie a variável DataReady para o parâmetro 0.

2. Mapeie a variável ExtractStartTime para o parâmetro 1.

3. Mapeie a variável ExtractEndTime para o parâmetro 2.

Na página Conjunto de Resultados do Editor de Tarefa Executar SQL, mapeie o Nome do Resultado para a variável SqlDataQuery.

O Nome do Resultado é o nome da única coluna que é retornada, SqlDataQuery.