Sincronizar una suscripción push

En este tema se describe cómo sincronizar una suscripción de inserción en SQL Server 2014 mediante SQL Server Management Studio, agentes de replicación o objetos de administración de replicación (RMO).

Uso de SQL Server Management Studio

El Agente de distribución (para las instantáneas y la replicación transaccional) o el Agente de mezcla (para la replicación de mezcla) sincronizan las suscripciones. Los agentes pueden ejecutarse continuamente, a petición o según una programación. Para obtener más información sobre cómo especificar programaciones de sincronización, vea Especificar programaciones de sincronización.

Sincronice una suscripción a petición desde las carpetas Publicaciones locales y Suscripciones locales en Microsoft SQL Server Management Studio y la pestaña Todas las suscripciones del Monitor de replicación. Las suscripciones a publicaciones de Oracle no se pueden sincronizar a petición desde el suscriptor. Para obtener información sobre cómo iniciar el Monitor de replicación, consulte Iniciar el Monitor de replicación.

Para sincronizar una suscripción push bajo demanda en Management Studio (en el editor)

1. Conéctese al publicador en Management Studio y, a continuación, expanda el nodo de servidor.

2. Expanda la carpeta Replicación y, a continuación, expanda la carpeta Publicaciones locales .

3. Expanda la publicación para la que desea sincronizar las suscripciones.

4. Haga clic con el botón derecho en la suscripción que desea sincronizar y, a continuación, haga clic en Ver estado de sincronización.

5. En el cuadro de diálogo Ver estado de sincronización: <Suscriptor>:<SuscripciónBase de datos> , haga clic en Iniciar. Una vez completada la sincronización, se muestra el mensaje Sincronización completada .

6. Haga clic en Cerrar.

Para sincronizar una suscripción de envío a petición en Management Studio en el suscriptor

1. Conéctese al suscriptor en Management Studio y expanda el nodo de servidor.

2. Expanda la carpeta Replicación y, a continuación, expanda la carpeta Suscripciones locales .

3. Haga clic con el botón derecho en la suscripción que desea sincronizar y, a continuación, haga clic en Ver estado de sincronización.

4. Se muestra un mensaje sobre cómo establecer una conexión con el distribuidor. Haz clic en Aceptar.

5. En el cuadro de diálogo Ver estado de sincronización: <Suscriptor>:<SuscripciónBase de datos> , haga clic en Iniciar. Una vez completada la sincronización, se muestra el mensaje Sincronización completada .

6. Haga clic en Cerrar.

Para sincronizar una suscripción de inserción a petición en el Monitor de replicación

1. En el Monitor de replicación, expanda un grupo publicador en el panel izquierdo, expanda un publicador y, a continuación, haga clic en una publicación.

2. Haga clic en la pestaña Todas las suscripciones .

3. Haga clic con el botón derecho en la suscripción que desea sincronizar y, a continuación, haga clic en Iniciar sincronización.

4. Para ver el progreso de la sincronización, haga clic con el botón derecho en la suscripción y, a continuación, haga clic en Ver detalles.

Uso de agentes de replicación

Las suscripciones de inserción se pueden sincronizar programáticamente y a petición invocando el archivo ejecutable del agente de replicación adecuado desde la línea de comandos. El archivo ejecutable del agente de replicación invocado dependerá del tipo de publicación a la que pertenece la suscripción push.

Para iniciar el Agente de distribución para sincronizar una suscripción de inserción a una publicación transaccional

1. Desde el símbolo del sistema o en un archivo por lotes en el Distribuidor, ejecute distrib.exe. Especifique los argumentos de la línea de comandos siguientes:

   • -Editor

   • -PublisherDB

   • -Distribuidor

   • -Suscriptor

   • -SubscriberDB

   • -SubscriptionType = 0

   Si usa la autenticación de SQL Server, también debe especificar los argumentos siguientes:

   • -DistributorLogin

   • -DistributorPassword

   • -DistributorSecurityMode = 0

   • -PublisherLogin

   • -PublisherPassword

   • -PublisherSecurityMode = 0

   • -SubscriberLogin

   • -SubscriberPassword

   • -SubscriberSecurityMode = 0

     Importante

     Siempre que sea posible, utilice la autenticación de Windows.

Para iniciar el Agente de combinación para sincronizar una suscripción de inserción con una publicación de mezcla

1. Desde el símbolo del sistema o en un archivo por lotes en el Distribuidor, ejecute replmerg.exe. Especifique los argumentos de la línea de comandos siguientes:

   • -Editor

   • -PublisherDB

   • -Publicación

   • -Distribuidor

   • -Suscriptor

   • -SubscriberDB

   • -SubscriptionType = 0

   Si usa la autenticación de SQL Server, también debe especificar los argumentos siguientes:

   • -DistributorLogin

   • -DistributorPassword

   • -DistributorSecurityMode = 0

   • -PublisherLogin

   • -PublisherPassword

   • -PublisherSecurityMode = 0

   • -SubscriberLogin

   • -SubscriberPassword

   • -SubscriberSecurityMode = 0

     Importante

     Siempre que sea posible, utilice la autenticación de Windows.

Ejemplos (agentes de replicación)

En el ejemplo siguiente se inicia el Agente de distribución para sincronizar una suscripción push.

REM -- Declare the variables.  
SET Publisher=%instancename%  
SET Subscriber=%instancename%  
SET PublicationDB=AdventureWorks2012  
SET SubscriptionDB=AdventureWorks2012Replica   
SET Publication=AdvWorksProductsTran  
  
REM -- Start the Distribution Agent with four subscription streams.  
REM -- The following command must be supplied without line breaks.  
"C:\Program Files\Microsoft SQL Server\120\COM\DISTRIB.EXE" -Subscriber %Subscriber%   
-SubscriberDB %SubscriptionDB% -SubscriberSecurityMode 1 -Publication %Publication%   
-Publisher %Publisher% -PublisherDB %PublicationDB% -Distributor %Publisher%   
-DistributorSecurityMode 1 -Continuous -SubscriptionType 0 -SubscriptionStreams 4

En el ejemplo siguiente se inicia el Agente de mezcla para sincronizar una suscripción push.

REM -- Declare the variables.  
SET Publisher=%instancename%  
SET Subscriber=%instancename%  
SET PublicationDB=AdventureWorks2012  
SET SubscriptionDB=AdventureWorks2012Replica   
SET Publication=AdvWorksSalesOrdersMerge  
  
REM -- Start the Merge Agent.  
REM -- The following command must be supplied without line breaks.  
"C:\Program Files\Microsoft SQL Server\120\COM\REPLMERG.EXE"  -Publisher %Publisher%   
-Subscriber  %Subscriber%  -Distributor %Publisher% -PublisherDB  %PublicationDB%   
-SubscriberDB %SubscriptionDB% -Publication %Publication% -PublisherSecurityMode 1   
-OutputVerboseLevel 3  -Output -SubscriberSecurityMode 1  -SubscriptionType 0   
-DistributorSecurityMode 1

El uso de Replication Management Objects (RMO)

Puede sincronizar suscripciones de inserción de forma programática utilizando Replication Management Objects (RMO) y el acceso a las funcionalidades del agente de replicación mediante código administrado. Las clases que usas para sincronizar una suscripción push dependen del tipo de publicación al que pertenece la suscripción.

Para sincronizar una suscripción de inserción a una publicación instantánea o transaccional

1. Cree una conexión al distribuidor mediante la clase ServerConnection .

2. Cree una instancia de la TransSubscription clase y establezca las siguientes propiedades:

   • Nombre de la base de datos de publicación para DatabaseName.

   • Nombre de la publicación a la que pertenece la suscripción para PublicationName.

   • Nombre de la base de datos de suscripciones para SubscriptionDBName.

   • Nombre del suscriptor para SubscriberName.

   • La conexión creada en el paso 1 para ConnectionContext.

3. Llame al LoadProperties método para obtener las propiedades de suscripción restantes. Si este método devuelve false, compruebe que la suscripción existe.

4. Inicie el Agente de distribución en el distribuidor de una de las maneras siguientes:

   • Llame al método SynchronizeWithJob en la instancia de TransSubscription del paso 2. Este método inicia el Agente de distribución de forma asincrónica y el control vuelve inmediatamente a la aplicación mientras se ejecuta el trabajo del agente. No puede llamar a este método si la suscripción se creó con un valor de false para CreateSyncAgentByDefault.

   • Obtenga una instancia de la clase TransSynchronizationAgent de la propiedad SynchronizationAgent, y llame al método Synchronize. Este método inicia el agente de forma sincrónica y el control permanece con el trabajo del agente en ejecución. Durante la ejecución sincrónica, puede controlar el Status evento mientras se ejecuta el agente.

Para sincronizar una suscripción de inserción a una publicación de fusión

1. Cree una conexión al distribuidor mediante la clase ServerConnection .

2. Cree una instancia de la MergeSubscription clase y establezca las siguientes propiedades:

   • Nombre de la base de datos de publicación para DatabaseName.

   • Nombre de la publicación a la que pertenece la suscripción para PublicationName.

   • Nombre de la base de datos de suscripciones para SubscriptionDBName.

   • Nombre del suscriptor para SubscriberName.

   • La conexión creada en el paso 1 para ConnectionContext.

3. Llame al LoadProperties método para obtener las propiedades de suscripción restantes. Si este método devuelve false, compruebe que la suscripción existe.

4. Inicie el Agente de mezcla en el distribuidor de una de las maneras siguientes:

   • Llame al método SynchronizeWithJob en la instancia de MergeSubscription del paso 2. Este método inicia el Agente de mezcla de forma asincrónica y el control vuelve inmediatamente a la aplicación mientras se ejecuta el trabajo del agente. No puede llamar a este método si la suscripción se creó con un valor de false para CreateSyncAgentByDefault.

   • Obtenga una instancia de la clase MergeSynchronizationAgent de la propiedad SynchronizationAgent, y llame al método Synchronize. Este método inicia el Agente de mezcla de forma sincrónica y el control permanece con el trabajo del agente en ejecución. Durante la ejecución sincrónica, puede controlar el Status evento mientras se ejecuta el agente.

Ejemplos (RMO)

En este ejemplo se sincroniza una suscripción push a una publicación transaccional, donde el agente se inicia de forma asincrónica mediante la tarea del agente.

// Define the server, publication, and database names.
string subscriberName = subscriberInstance;
string publisherName = publisherInstance;
string publicationName = "AdvWorksProductTran";
string subscriptionDbName = "AdventureWorks2012Replica";
string publicationDbName = "AdventureWorks2012";

/// Create a connection to the Publisher.
ServerConnection conn = new ServerConnection(publisherName);

TransSubscription subscription;

try
{
    // Connect to the Publisher.
    conn.Connect();

    // Instantiate the push subscription.
    subscription = new TransSubscription();
    subscription.ConnectionContext = conn;
    subscription.DatabaseName = publicationDbName;
    subscription.PublicationName = publicationName;
    subscription.SubscriptionDBName = subscriptionDbName;
    subscription.SubscriberName = subscriberName;

    // If the push subscription and the job exists, start the agent job.
    if (subscription.LoadProperties() && subscription.AgentJobId != null)
    {
        // Start the Distribution Agent asynchronously.
        subscription.SynchronizeWithJob();
    }
    else
    {
        // Do something here if the subscription does not exist.
        throw new ApplicationException(String.Format(
            "A subscription to '{0}' does not exists on {1}",
            publicationName, subscriberName));
    }
}
catch (Exception ex)
{
    // Implement appropriate error handling here.
    throw new ApplicationException("The subscription could not be synchronized.", ex);
}
finally
{
    conn.Disconnect();
}

' Define the server, publication, and database names.
Dim subscriberName As String = subscriberInstance
Dim publisherName As String = publisherInstance
Dim publicationName As String = "AdvWorksProductTran"
Dim subscriptionDbName As String = "AdventureWorks2012Replica"
Dim publicationDbName As String = "AdventureWorks2012"

' Create a connection to the Publisher.
Dim conn As ServerConnection = New ServerConnection(publisherName)

Dim subscription As TransSubscription

Try
    ' Connect to the Publisher.
    conn.Connect()

    ' Instantiate the push subscription.
    subscription = New TransSubscription()
    subscription.ConnectionContext = conn
    subscription.DatabaseName = publicationDbName
    subscription.PublicationName = publicationName
    subscription.SubscriptionDBName = subscriptionDbName
    subscription.SubscriberName = subscriberName

    ' If the push subscription and the job exists, start the agent job.
    If subscription.LoadProperties() And Not subscription.AgentJobId Is Nothing Then
        ' Start the Distribution Agent asynchronously.
        subscription.SynchronizeWithJob()
    Else
        ' Do something here if the subscription does not exist.
        Throw New ApplicationException(String.Format( _
         "A subscription to '{0}' does not exists on {1}", _
         publicationName, subscriberName))
    End If
Catch ex As Exception
    ' Implement appropriate error handling here.
    Throw New ApplicationException("The subscription could not be synchronized.", ex)
Finally
    conn.Disconnect()
End Try

En este ejemplo se sincroniza una suscripción push a una publicación transaccional, y el agente se inicia de manera sincrónica.

// Define the server, publication, and database names.
string subscriberName = subscriberInstance;
string publisherName = publisherInstance;
string publicationName = "AdvWorksProductTran";
string subscriptionDbName = "AdventureWorks2012Replica";
string publicationDbName = "AdventureWorks2012";

// Create a connection to the Publisher.
ServerConnection conn = new ServerConnection(publisherName);

TransSubscription subscription;

try
{
    // Connect to the Publisher.
    conn.Connect();

    // Define the push subscription.
    subscription = new TransSubscription();
    subscription.ConnectionContext = conn;
    subscription.DatabaseName = publicationDbName;
    subscription.PublicationName = publicationName;
    subscription.SubscriptionDBName = subscriptionDbName;
    subscription.SubscriberName = subscriberName;

    // If the push subscription exists, start the synchronization.
    if (subscription.LoadProperties())
    {
        // Check that we have enough metadata to start the agent.
        if (subscription.SubscriberSecurity != null)
        {
            // Synchronously start the Distribution Agent for the subscription.
            subscription.SynchronizationAgent.Synchronize();
        }
        else
        {
            throw new ApplicationException("There is insufficent metadata to " +
                "synchronize the subscription. Recreate the subscription with " +
                "the agent job or supply the required agent properties at run time.");
        }
    }
    else
    {
        // Do something here if the push subscription does not exist.
        throw new ApplicationException(String.Format(
            "The subscription to '{0}' does not exist on {1}",
            publicationName, subscriberName));
    }
}
catch (Exception ex)
{
    // Implement appropriate error handling here.
    throw new ApplicationException("The subscription could not be synchronized.", ex);
}
finally
{
    conn.Disconnect();
}

' Define the server, publication, and database names.
Dim subscriberName As String = subscriberInstance
Dim publisherName As String = publisherInstance
Dim publicationName As String = "AdvWorksProductTran"
Dim subscriptionDbName As String = "AdventureWorks2012Replica"
Dim publicationDbName As String = "AdventureWorks2012"

' Create a connection to the Publisher.
Dim conn As ServerConnection = New ServerConnection(publisherName)

Dim subscription As TransSubscription

Try
    ' Connect to the Publisher.
    conn.Connect()

    ' Define the push subscription.
    subscription = New TransSubscription()
    subscription.ConnectionContext = conn
    subscription.DatabaseName = publicationDbName
    subscription.PublicationName = publicationName
    subscription.SubscriptionDBName = subscriptionDbName
    subscription.SubscriberName = subscriberName

    ' If the push subscription exists, start the synchronization.
    If subscription.LoadProperties() Then
        ' Check that we have enough metadata to start the agent.
        If Not subscription.SubscriberSecurity Is Nothing Then

            ' Synchronously start the Distribution Agent for the subscription.
            subscription.SynchronizationAgent.Synchronize()
        Else
            Throw New ApplicationException("There is insufficent metadata to " + _
             "synchronize the subscription. Recreate the subscription with " + _
             "the agent job or supply the required agent properties at run time.")
        End If
    Else
        ' Do something here if the push subscription does not exist.
        Throw New ApplicationException(String.Format( _
         "The subscription to '{0}' does not exist on {1}", _
         publicationName, subscriberName))
    End If
Catch ex As Exception
    ' Implement appropriate error handling here.
    Throw New ApplicationException("The subscription could not be synchronized.", ex)
Finally
    conn.Disconnect()
End Try

En este ejemplo se sincroniza una suscripción push a una publicación de mezcla, donde el agente se inicia de forma asincrónica mediante la tarea del agente.

// Define the server, publication, and database names.
string subscriberName = subscriberInstance;
string publisherName = publisherInstance;
string publicationName = "AdvWorksSalesOrdersMerge";
string subscriptionDbName = "AdventureWorks2012Replica";
string publicationDbName = "AdventureWorks2012";

// Create a connection to the Publisher.
ServerConnection conn = new ServerConnection(publisherName);

MergeSubscription subscription;

try
{
    // Connect to the Publisher.
    conn.Connect();

    // Define push subscription.
    subscription = new MergeSubscription();
    subscription.ConnectionContext = conn;
    subscription.DatabaseName = publicationDbName;
    subscription.PublicationName = publicationName;
    subscription.SubscriptionDBName = subscriptionDbName;
    subscription.SubscriberName = subscriberName;

    // If the push subscription and the job exists, start the agent job.
    if (subscription.LoadProperties() && subscription.AgentJobId != null)
    {
        // Start the Merge Agent asynchronously.
        subscription.SynchronizeWithJob();
    }
    else
    {
        // Do something here if the subscription does not exist.
        throw new ApplicationException(String.Format(
            "A subscription to '{0}' does not exists on {1}",
            publicationName, subscriberName));
    }
}
catch (Exception ex)
{
    // Implement appropriate error handling here.
    throw new ApplicationException("The subscription could not be synchronized.", ex);
}
finally
{
    conn.Disconnect();
}

' Define the server, publication, and database names.
Dim subscriberName As String = subscriberInstance
Dim publisherName As String = publisherInstance
Dim publicationName As String = "AdvWorksSalesOrdersMerge"
Dim subscriptionDbName As String = "AdventureWorks2012Replica"
Dim publicationDbName As String = "AdventureWorks2012"

' Create a connection to the Publisher.
Dim conn As ServerConnection = New ServerConnection(publisherName)

Dim subscription As MergeSubscription

Try
    ' Connect to the Publisher.
    conn.Connect()

    ' Define push subscription.
    subscription = New MergeSubscription()
    subscription.ConnectionContext = conn
    subscription.DatabaseName = publicationDbName
    subscription.PublicationName = publicationName
    subscription.SubscriptionDBName = subscriptionDbName
    subscription.SubscriberName = subscriberName

    ' If the push subscription and the job exists, start the agent job.
    If subscription.LoadProperties() And Not subscription.AgentJobId Is Nothing Then
        ' Start the Merge Agent asynchronously.
        subscription.SynchronizeWithJob()
    Else
        ' Do something here if the subscription does not exist.
        Throw New ApplicationException(String.Format( _
            "A subscription to '{0}' does not exists on {1}", _
            publicationName, subscriberName))
    End If
Catch ex As Exception
    ' Implement appropriate error handling here.
    Throw New ApplicationException("The subscription could not be synchronized.", ex)
Finally
    conn.Disconnect()
End Try

En este ejemplo se sincroniza una suscripción push a una publicación de mezcla, donde el agente se inicia sincrónicamente.

// Define the server, publication, and database names.
string subscriberName = subscriberInstance;
string publisherName = publisherInstance;
string publicationName = "AdvWorksSalesOrdersMerge";
string subscriptionDbName = "AdventureWorks2012Replica";
string publicationDbName = "AdventureWorks2012";

// Create a connection to the Publisher.
ServerConnection conn = new ServerConnection(publisherName);

MergeSubscription subscription;

try
{
    // Connect to the Publisher
    conn.Connect();

    // Define the subscription.
    subscription = new MergeSubscription();
    subscription.ConnectionContext = conn;
    subscription.DatabaseName = publicationDbName;
    subscription.PublicationName = publicationName;
    subscription.SubscriptionDBName = subscriptionDbName;
    subscription.SubscriberName = subscriberName;

    // If the push subscription exists, start the synchronization.
    if (subscription.LoadProperties())
    {
        // Check that we have enough metadata to start the agent.
        if (subscription.SubscriberSecurity != null)
        {
            // Synchronously start the Merge Agent for the subscription.
            subscription.SynchronizationAgent.Synchronize();
        }
        else
        {
            throw new ApplicationException("There is insufficent metadata to " +
                "synchronize the subscription. Recreate the subscription with " +
                "the agent job or supply the required agent properties at run time.");
        }
    }
    else
    {
        // Do something here if the push subscription does not exist.
        throw new ApplicationException(String.Format(
            "The subscription to '{0}' does not exist on {1}",
            publicationName, subscriberName));
    }
}
catch (Exception ex)
{
    // Implement appropriate error handling here.
    throw new ApplicationException("The subscription could not be synchronized.", ex);
}
finally
{
    conn.Disconnect();
}

' Define the server, publication, and database names.
Dim subscriberName As String = subscriberInstance
Dim publisherName As String = publisherInstance
Dim publicationName As String = "AdvWorksSalesOrdersMerge"
Dim subscriptionDbName As String = "AdventureWorks2012Replica"
Dim publicationDbName As String = "AdventureWorks2012"

' Create a connection to the Publisher.
Dim conn As ServerConnection = New ServerConnection(publisherName)

Dim subscription As MergeSubscription

Try
    ' Connect to the Publisher
    conn.Connect()

    ' Define the subscription.
    subscription = New MergeSubscription()
    subscription.ConnectionContext = conn
    subscription.DatabaseName = publicationDbName
    subscription.PublicationName = publicationName
    subscription.SubscriptionDBName = subscriptionDbName
    subscription.SubscriberName = subscriberName

    ' If the push subscription exists, start the synchronization.
    If subscription.LoadProperties() Then
        ' Check that we have enough metadata to start the agent.
        If Not subscription.SubscriberSecurity Is Nothing Then
            ' Synchronously start the Merge Agent for the subscription.
            ' Log agent messages to an output file.
            subscription.SynchronizationAgent.Output = "mergeagent.log"
            subscription.SynchronizationAgent.OutputVerboseLevel = 2
            subscription.SynchronizationAgent.Synchronize()
        Else
            Throw New ApplicationException("There is insufficent metadata to " + _
             "synchronize the subscription. Recreate the subscription with " + _
             "the agent job or supply the required agent properties at run time.")
        End If
    Else
        ' Do something here if the push subscription does not exist.
        Throw New ApplicationException(String.Format( _
         "The subscription to '{0}' does not exist on {1}", _
         publicationName, subscriberName))
    End If
Catch ex As Exception
    ' Implement appropriate error handling here.
    Throw New ApplicationException("The subscription could not be synchronized.", ex)
Finally
    conn.Disconnect()
End Try

Véase también

Conceptos de objetos de gestión de replicación
Sincronizar datos
Procedimientos recomendados de seguridad de replicación