Aplicar as alterações ao destino

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

No fluxo de dados de um pacote de Serviços de Integração que realiza uma carga incremental de dados de alteração, a terceira e última tarefa é aplicar as alterações ao seu destino. Precisará de um componente para aplicar inserções, um para aplicar atualizações e um para aplicar eliminações.

Aplicação de insertos

Para aplicar inserts, utiliza-se um destino OLE DB porque as novas linhas não requerem qualquer tratamento especial.

Para processar as inserções utilizando um OLE DB Destination

1. No separador de fluxo de dados , adicione um destino de base de dados OLE.

2. Ligue a saída que contém inserções da transformação de Divisão Condicional ao destino da base de dados OLE.

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

   1. Selecione ou crie um OLE DB Gestor de Ligações para a base de dados de destino.

   2. Selecione uma opção de modo de acesso a dados e depois selecione a tabela de destino ou introduza uma instrução SQL que contenha as colunas de destino.

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

Atualizações de Candidatura

Para aplicar atualizações, utiliza-se uma transformação de comandos OLE DB. Usas esta transformação porque tens de usar uma instrução parametrizada UPDATE para atualizar uma linha de cada vez com os novos valores das colunas.

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

1. No separador de fluxo de dados , adicione uma transformação de comandos OLE DB.

2. Ligue a saída que contém atualizações da transformação Condicional Split à transformação OLE DB Command.

3. No Editor Avançado for OLE DB Command, no separador Gestor de Ligações, selecione ou crie um OLE DB Gestor de Ligações para a base de dados de destino.

4. No Editor Avançado for OLE DB Command, no separador Propriedades do Componente, para SqlCommand, introduza uma instrução parametrizadaUPDATE.

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

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

5. No separador Mapeamentos de colunas do editor, mapeie as colunas apropriadas dos dados das alterações para os parâmetros na instrução UPDATE.

Aplicação de Eliminações

Para aplicar eliminações, utiliza-se uma transformação de comandos OLE DB. Usas esta transformação porque tens de usar uma instrução parametrizada DELETE que apaga uma única linha de cada vez com base no valor da coluna que identifica unicamente a linha.

Para processar eliminações usando uma transformação de comandos OLE DB

1. No separador de fluxo de dados , adicione uma transformação de comando OLE DB ao fluxo de dados.

2. Ligue a saída que contém eliminações da transformação Condicional Split à transformação OLE DB Command.

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

4. No Editor Avançado for OLE DB Command, no separador Gestor de Ligações, selecione ou crie um OLE DB Gestor de Ligações para a base de dados de destino.

5. No Editor Avançado for OLE DB Command, no separador Propriedades do Componente do editor, para SqlCommand, introduza uma instrução parametrizadaDELETE.

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

   delete from Customer where CustomerID = ?  
   
   

6. No separador Mapeamentos de Colunas do editor, associe a coluna apropriada dos dados de alterações ao parâmetro na instrução DELETE.

Otimizar inserções e atualizações com a funcionalidade MERGE

Pode otimizar o processamento de inserções e atualizações combinando certas opções de captura de dados alterados com o uso da palavra-chave Transact-SQL MERGE . Para mais informações sobre a palavra-chave MERGE, consulte MERGE (Transact-SQL).

Na instrução Transact-SQL que recupera os dados de alterações, pode 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>. Esta função de captura de dados de alteração funciona de forma mais eficiente quando não tem de realizar o processamento extra necessário para distinguir inserções de atualizações. Quando especifica o valor do parâmetro all with merge, o valor __$operation dos dados de alterações é 1 para eliminações ou 5 para alterações causadas por inserções ou atualizações. Para mais informações sobre a função Transact-SQL utilizada para recuperar os dados de alteração, consulte Recuperar e Compreender os Dados de Alteração. Depois de recuperar alterações com o valor do parâmetro all with merge , podes aplicar deletes e enviar as linhas restantes para uma tabela temporária ou uma tabela de staging. Depois, numa Tarefa Executar SQL subsequente, pode utilizar uma única instrução MERGE para aplicar todas as inserções ou atualizações da tabela de preparação na tabela de destino.