Determinando se os dados de alteração estão prontos

Na guia Fluxo de Controle do Designer SSIS, adicione um contêiner Loop For ao fluxo de controle.

Conecte a tarefa Executar SQL que calcula os pontos de extremidade do intervalo para o contêiner Loop For.

No Editor do Loop For, selecione as seguintes opções:

1. Para InitExpression, digite @DataReady = 0.

   Esta expressão define o valor inicial da variável de loop.

2. Para EvalExpressionm, digite @DataReady == 0.

   Quando esta expressão avaliar como Falso, a execução passará pelo loop e a carga incremental será iniciada.

Dentro do contêiner Loop For, adicione uma tarefa Executar SQL.

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 @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
   

Na página Mapeamentos de Parâmetros do Editor da Tarefa Executar SQL, faça os seguintes mapeamentos:

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

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

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

4. Mapeie a variável TimeoutCount para o parâmetro 3.

5. Mapeie a variável TimeoutCeiling para o parâmetro 4.

Na página Conjunto de Resultados do Editor da tarefa Executar SQL, mapeie o resultado de DataReady para a variável DataReady e o resultado de TimeoutCount para a variável TimeoutCount.

Dentro do contêiner Loop For, adicione uma tarefa Script.

Conecte a tarefa Executar SQL que realiza a consulta para determinar se os dados de alteração estão prontos para a nova tarefa Script.

Para a restrição de precedência que conecta a tarefa Executar SQL à tarefa Script, abra o Editor de Restrição de Precedência e selecione as seguintes opções:

1. Para Operação de avaliação, selecione Expressão e Restrição.

2. Para Valor, selecione Êxito.

   O valor de restrição de Êxito se refere ao sucesso da tarefa anterior. Neste caso, o sucesso da tarefa Executar SQL.

3. Para Expressão, digite @DataReady == 0 && @TimeoutCount <= @TimeoutCeiling.

4. Selecione E Lógico. Todas as restrições devem avaliar como Verdadeiro, se ainda não estiver selecionado.

Em Editor da Tarefa Script, na página Script, para ReadOnlyVariables, selecione a variável de número inteiro User::DelaySeconds da 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 uma das seguintes linhas de código:

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

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

  - ou -

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

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

  Observação
  O método Thread.Sleep espera um argumento especificado em milissegundos.

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.

Dentro do contêiner Loop For, adicione uma tarefa Executar SQL.

Conecte a tarefa Executar SQL que realiza a consulta para determinar se os dados de alteração estão prontos para a nova tarefa Executar SQL.

Para a restrição de precedência que conecta as duas tarefas Executar SQL, abra o Editor de Restrição de Precedência e selecione as seguintes opções:

1. Para Operação de avaliação, selecione Expressão e Restrição.

2. Para Valor, selecione Êxito.

   O valor de restrição de Êxito se refere ao êxito da tarefa Executar SQL anterior.

3. Para Expressão, digite @DataReady == 0.

4. Selecione E Lógico. Todas as restrições devem avaliar como Verdadeiro, se ainda não estiver selecionado.

   Esta seleção requer que ambas as condições, a restrição e a expressão, sejam verdadeiras.

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:

   WAITFOR DELAY ?
   

Na página Mapeamento de Parâmetro do editor, mapeie a variável de cadeia de caracteres DelaySeconds para o parâmetro 0.

Se quiser reportar o erro ou o tempo limite excedido gravando uma mensagem no log, configure o armazenamento em log para o pacote. Para obter mais informações, consulte Como habilitar registros em um pacote.

Dentro do contêiner Loop For, adicione uma tarefa Script.

Conecte a tarefa Executar SQL que realiza a consulta para determinar se os dados de alteração estão prontos para a nova tarefa Script.

Para a restrição de precedência que conecta a tarefa Executar SQL à tarefa Script, abra o Editor de Restrição de Precedência e selecione as seguintes opções:

1. Para Operação de avaliação, selecione Expressão e Restrição.

2. Para Valor, selecione Êxito.

   O valor de restrição de Êxito se refere ao sucesso da tarefa anterior. Neste caso, o sucesso da tarefa Executar SQL.

3. Para Expressão, digite @DataReady == 1 || @DataReady == 5.

4. Selecione E Lógico. Todas as restrições devem avaliar como Verdadeiro, se ainda não estiver selecionado.

   Esta seleção requer que ambas as condições, a restrição e a expressão, sejam verdadeiras.

No Editor da Tarefa Script, na página Script do editor, para ReadOnlyVariables, selecione User::DataReady e User::ExtractStartTime da lista para disponibilizar seus valores para o script.

Se você quiser incluir informações de determinadas variáveis do sistema (por exemplo, System::PackageName) nas informações gravadas no log, selecione também as variáveis.

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 o código para armazenar um erro chamando o método Dts.Log ou acione um evento chamando um dos métodos da interface Dts.Events. Informe o pacote do erro retornando Dts.TaskResult = Dts.Results.Failure.

A seguinte amostra mostra como gravar uma mensagem no log. Para obter mais informações, consulte Registrando a tarefa Script, Gerando eventos na tarefa Script e Retornando resultados da tarefa 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

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