Aplicar as alterações no destino

Aplica-se a:SQL Server SSIS Integration Runtime no Azure Data Factory

No fluxo de dados de um pacote do Integration Services que executa uma carga incremental de dados de alterações, a terceira e última tarefa é aplicar as alterações ao destino. Você precisará de um componente para aplicar inserções, um para aplicar atualizações e um para aplicar exclusões.

Aplicando inserções

Para aplicar inserções, você usa um destino OLE DB, pois as linhas novas não requerem nenhuma manipulação especial.

Para processar inserções usando um destino OLE DB

1. Na guia Fluxo de Dados , adicione um destino OLE DB.

2. Conecte a saída que contém inserções da transformação de Divisão Condicional para o destino de OLE DB.

3. No Editor de Destino de OLE DB, na página Gerenciador de Conexões , selecione as seguintes opções:

   1. Selecione ou crie um Gerenciador de Conexões de OLE DB para o banco de dados de destino.

   2. Selecione uma opção Modo de acesso dos dados e selecione a tabela de destino ou digite uma instrução SQL que contenha as colunas de destino.

4. Na página Mapeamentos do editor, mapeie as colunas apropriadas a partir dos dados de alteração para a tabela de destino.

Aplicando atualizações

Para aplicar atualizações, você usa uma transformação de Comando do OLE DB. Você usa essa transformação porque precisa usar uma instrução parametrizada UPDATE para atualizar uma linha de cada vez com os novos valores de coluna.

Para processar atualizações usando uma transformação de Comando OLE DB

1. Na guia Fluxo de Dados , adicione uma transformação de Comando OLE DB.

2. Conecte a saída que contém atualizações a partir da transformação de Divisão Condicional para a transformação de Comando OLE DB.

3. Em Editor Avançado para o Comando OLE DB, no Gerenciador de Conexões selecione ou crie um gerenciador de conexões OLE DB para o banco de dados de destino.

4. No Editor Avançado para Comando OLE DB, na guia Propriedades do Componente, para SqlCommand, insira uma instrução SQL parametrizada UPDATE.

   Por exemplo, uma instrução UPDATE para uma tabela Customer pode ter a seguinte sintaxe:

   update CDCSample.Customer  
   set TerritoryID  = ?,  
       CustomerType  = ?,  
       rowguid  = ?,  
       ModifiedDate  = ?  
   where CustomerID = ?  
   
   

5. Na guia Mapeamentos de colunas do editor, mapeie as colunas apropriadas dos dados de mudança para os parâmetros na instrução UPDATE.

Aplicando exclusões

Para aplicar exclusões, você usa uma transformação de Comando OLE DB. Você usa essa transformação porque precisa usar uma instrução parametrizada DELETE que exclua uma única linha de cada vez com base no valor da coluna que identifica exclusivamente a linha.

Para processar exclusões usando uma transformação de Comando OLE DB

1. Na guia Fluxo de Dados , adicione uma transformação de Comando OLE DB ao fluxo de dados.

2. Conecte a saída que contém exclusões a partir da transformação de Divisão Condicional para a transformação de Comando OLE DB.

3. Abra o Editor Avançado para configurar a transformação.

4. Em Editor Avançado para o Comando OLE DB, no Gerenciador de Conexões selecione ou crie um gerenciador de conexões OLE DB para o banco de dados de destino.

5. No Editor Avançado do Comando OLE DB, na guia Propriedades do Componente do editor, em SqlCommand, digite uma instrução parametrizada DELETE.

   Por exemplo, uma DELETE instrução para uma tabela Customer pode ter a seguinte sintaxe:

   delete from Customer where CustomerID = ?  
   
   

6. Na guia Mapeamentos de Coluna do editor, mapeie a coluna apropriada a partir dos dados de alteração até o parâmetro na instrução DELETE.

Otimizando inserções e atualizações usando MERGE a funcionalidade

Você pode otimizar o processamento de inserções e atualizações combinando determinadas opções de captura de dados de alteração com o uso da palavra-chave Transact-SQL MERGE . Para obter mais informações sobre a MERGE palavra-chave, consulte MERGE (Transact-SQL).

Na instrução Transact-SQL que recupera os dados de alteração, é possível especificar all with merge como o valor do parâmetro row_filter_option ao chamar a função cdc.fn_cdc_get_net_changes_<capture_instance>. Essa função de captura de dados de alteração opera com mais eficiência quando não tem que realizar o processamento extra, necessário para distinguir inserções de atualizações. Ao especificar o valor do parâmetro all with merge , o valor de __$operation dos dados de alteração é 1 para exclusões ou 5 para alterações causadas por inserções ou atualizações. Para obter mais informações sobre a função Transact-SQL usada para recuperar os dados de alteração, consulte Recuperar e compreender os dados de alteração. Após recuperar as alterações com o valor de parâmetro all with merge , é possível aplicar exclusões e enviar as linhas restantes para uma tabela temporária ou uma tabela de preparo. Em seguida, em uma tarefa Executar SQL de downstream, é possível usar uma única instrução MERGE para aplicar todas as inserções ou atualizações da tabela de preparo para o destino.