Início / dba / Perguntas / 182207
Accepted
ABS
Asked: 2017-07-31 05:01:23 +0800 CST

A replicação de mesclagem personaliza o ciclo de sincronização e seu desempenho

  • 772

Estou tentando implementar a replicação de mesclagem entre apenas dois servidores, um editor e um assinante.

Suponha estas tabelas:

--Main table in Publisher
Ticket (id, userId, reqId, blockedDate, usedDate, returnDate, transferDate, ...)

--On Subscriber (The fields are in Publication)
Ticket (id, userId, blockedDate, usedDate)

Devemos atribuir a data atual transferDatesempre que uma linha for para o Assinante e atribuir returnDatesempre que ela voltar do Assinante. Como temos que considerar uma sincronização de arquivo (transferência/retorno de dados de/para o assinante com um pendrive!), esses campos devem ser atribuídos na sincronização na sincronização de arquivo ou na replicação.

Eu sei que você pode adicionar sua lógica de negócios personalizada para resolução de conflitos (quando ocorre um conflito). Estou procurando algo como gatilhos para eventos de replicação, que me dão a capacidade de manipular alguns campos fora da Publicação (ou até mesmo outra tabela sempre que necessário).

Perguntas

  • É possível lidar com eventos de replicação (push e pull) manualmente?** (personalize ou substitua PULL/PUSH's. Não resolvedor de conflitos)**

  • Você pode me dar uma comparação entre implementar uma replicação de mesclagem personalizada e sincronizar com a ajuda de um distributed transactionSP?

Eu preciso que a sincronização seja agendada (à meia-noite quando não há carga no servidor de banco de dados), MAS é altamente necessário que possamos sincronizar manualmente (de dentro de nosso aplicativo da web).

Na segunda pergunta, preciso de seu desempenho, confiabilidade e, claro, sua capacidade de manutenção. Esses fatores, especialmente os dois primeiros, são uma grande preocupação. Suponha que o Publicador possa ter cerca de milhões de registros e o Assinante possa ter cerca de dez mil. Assim, a cada sincronização, cerca de dez mil registros serão transferidos.

A replicação de mesclagem verifica as linhas; se houver uma alteração e não houver um conflito, a linha será mesclada. se houver um conflito, um resolvedor de conflitos (pode ser seu resolvedor de procedimento armazenado personalizado) lidará com o conflito. Eu quero escrever minha própria lógica no primeiro caso (dados alterados sem conflito) em vez do mecanismo de mesclagem interno do SQL. Claramente eu quero personalizá-lo.

Há apenas id, userId, blockedDate, usedDatecolunas no artigo. Eu quero preencher returnDatesempre que a Ticketvoltar para o Publisher (em um pull ) e preencher transferDatesempre que Ticketfor para o Subscriber (em um push ).

sql-server replication

1 respostas

  1. Best Answer

    Para personalizar o processo de mesclagem, você precisará implementar um manipulador de lógica de negócios personalizado (requer código .NET - não pode ser implementado usando TSQL). Consulte Executar lógica de negócios durante sincronização de mesclagem na documentação. Ele está disponível no SQL Server 2012 e posterior.

    Substitua os métodos Update, Insert e Commit para transformar as linhas alteradas e o método de resolução de conflitos para modificar a lógica de conflito. Não pode usar T-SQL, deve ser feito com código .NET. A principal limitação é que cada método substituível é chamado uma vez para cada linha (como transformações de linha SSIS), até onde sei, não há um método chamado em todas as linhas alteradas.

    Existem algumas soluções alternativas para lidar com o seu caso, mas esta é a solução geral.

    Este é o modelo BOL C#:

    using System;
using System.Text;
using System.Data;
using System.Data.Common;
using Microsoft.SqlServer.Replication.BusinessLogicSupport;
using Microsoft.Samples.SqlServer.BusinessLogicHandler;

namespace Microsoft.Samples.SqlServer.BusinessLogicHandler
{
public class OrderEntryBusinessLogicHandler :
  Microsoft.SqlServer.Replication.BusinessLogicSupport.BusinessLogicModule
{
    // Variables to hold server names.
    private string publisherName;
    private string subscriberName;

    public OrderEntryBusinessLogicHandler()
    {
    }

    // Implement the Initialize method to get publication 
    // and subscription information.
    public override void Initialize(
        string publisher,
        string subscriber,
        string distributor,
        string publisherDB,
        string subscriberDB,
        string articleName)
    {
        // Set the Publisher and Subscriber names.
        publisherName = publisher;
        subscriberName = subscriber;
    }

    // Declare what types of row changes, conflicts, or errors to handle.
    override public ChangeStates HandledChangeStates
    {
        get
        {
            // Handle Subscriber inserts, updates and deletes.
            return ChangeStates.SubscriberInserts |
              ChangeStates.SubscriberUpdates | ChangeStates.SubscriberDeletes;
        }
    }

    public override ActionOnDataChange InsertHandler(SourceIdentifier insertSource,
      DataSet insertedDataSet, ref DataSet customDataSet, ref int historyLogLevel,
      ref string historyLogMessage)
    {
        // custom logic for updates                 
    }

    public override ActionOnDataChange UpdateHandler(SourceIdentifier updateSource,
      DataSet updatedDataSet, ref DataSet customDataSet, ref int historyLogLevel,
      ref string historyLogMessage)
    {
 // custom logic for updates 
  }
    public override ActionOnDataDelete DeleteHandler(SourceIdentifier deleteSource,
      DataSet deletedDataSet, ref int historyLogLevel, ref string historyLogMessage)
    {
     // custom logic for deletes 
}
}
    • 2

relate perguntas