Como reinicializar uma assinatura (Programação RMO)

Assinaturas individuais podem ser marcadas para reinicialização, para que durante a próxima sincronização, um novo instantâneo seja aplicado. As assinaturas podem ser reinicializadas programaticamente usando o RMO (Replication Management Objects). As classes que você usa dependem do tipo da publicação às quais as assinaturas pertencem e o tipo de assinatura (ou seja, uma assinatura push ou pull).

Para reinicializar uma assinatura pull para uma publicação transacional

1. Crie uma conexão com o Assinante usando a classe ServerConnection.

2. Crie uma instância da classe TransPullSubscription, defina PublicationName, DatabaseName, PublisherName, PublicationDBName e a conexão da etapa 1 para ConnectionContext.

3. Chame o método LoadProperties para obter as propriedades do objeto.

   Observação
   Se esse método retornar false, isso significa que as propriedades de assinatura na etapa 2 foram definidas incorretamente ou a assinatura pull não existe.

4. Chame o método Reinitialize. Esse método marca a assinatura para reinicialização.

5. Sincronize a assinatura pull. Para obter mais informações, consulte Como sincronizar uma assinatura pull (Programação RMO).

Para reinicializar uma assinatura push para uma publicação transacional

1. Crie uma conexão com o Publicador usando a classe ServerConnection.

2. Crie uma instância da classe TransSubscription, defina PublicationName, DatabaseName, SubscriberName, SubscriptionDBName e a conexão da etapa 1 para ConnectionContext.

3. Chame o método LoadProperties para obter as propriedades do objeto.

   Observação
   Se esse método retornar false, isso significa que as propriedades de assinatura na etapa 2 foram definidas incorretamente ou a assinatura push não existe.

4. Chame o método Reinitialize. Esse método marca a assinatura para reinicialização.

5. Sincronize a assinatura push. Para obter mais informações, consulte Como sincronizar uma assinatura push (Programação RMO).

Para reinicializar uma assinatura pull para uma publicação de mesclagem

1. Crie uma conexão com o Assinante usando a classe ServerConnection.

2. Crie uma instância da classe MergePullSubscription, defina PublicationName, DatabaseName, PublisherName, PublicationDBName e a conexão da etapa 1 para ConnectionContext.

3. Chame o método LoadProperties para obter as propriedades do objeto.

   Observação
   Se esse método retornar false, isso significa que as propriedades de assinatura na etapa 2 foram definidas incorretamente ou a assinatura pull não existe.

4. Chame o método Reinitialize. Passe o valor de true para carregar as alterações no Assinante antes da reinicialização ou um valor de false para reinicializar e perder as alterações pendentes no Assinante. Esse método marca a assinatura para reinicialização.

   Observação
   As alterações não poderão ser carregadas se a assinatura estiver vencida. Para obter mais informações, consulte Uma assinatura de mesclagem expirou e as alterações precisam ser carregadas.

5. Sincronize a assinatura pull. Para obter mais informações, consulte Como sincronizar uma assinatura pull (Programação RMO).

Para reinicializar uma assinatura push para uma publicação de mesclagem.

1. Crie uma conexão com o Publicador usando a classe ServerConnection.

2. Crie uma instância da classe MergeSubscription, defina PublicationName, DatabaseName, SubscriberName, SubscriptionDBName e a conexão da etapa 1 para ConnectionContext.

3. Chame o método LoadProperties para obter as propriedades do objeto.

   Observação
   Se esse método retornar false, isso significa que as propriedades de assinatura na etapa 2 foram definidas incorretamente ou a assinatura push não existe.

4. Chame o método Reinitialize. Passe o valor de true para carregar as alterações no Assinante antes da reinicialização ou um valor de false para reinicializar e perder as alterações pendentes no Assinante. Esse método marca a assinatura para reinicialização.

   Observação
   As alterações não poderão ser carregadas se a assinatura estiver vencida. Para obter mais informações, consulte Uma assinatura de mesclagem expirou e as alterações precisam ser carregadas.

5. Sincronize a assinatura push. Para obter mais informações, consulte Como sincronizar uma assinatura push (Programação RMO).

Exemplo

Esse exemplo reinicializa uma assinatura pull para uma publicação transacional.

         // Define server, publication, and database names.
            String subscriberName = subscriberInstance;
            String publisherName = publisherInstance;
            String publicationName = "AdvWorksProductTran";
            String publicationDbName = "AdventureWorks";
            String subscriptionDbName = "AdventureWorksReplica";

            // Create a connection to the Subscriber.
            ServerConnection conn = new ServerConnection(subscriberName);

            TransPullSubscription subscription;

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

                // Define subscription properties.
                subscription = new TransPullSubscription();
                subscription.ConnectionContext = conn;
                subscription.DatabaseName = subscriptionDbName;
                subscription.PublisherName = publisherName;
                subscription.PublicationDBName = publicationDbName;
                subscription.PublicationName = publicationName;

                // If the pull subscription and the job exists, mark the subscription
                // for reinitialization and start the agent job.
                if (subscription.LoadProperties() && subscription.AgentJobId != null)
                {
                    subscription.Reinitialize();
                    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)
            {
                // Do appropriate error handling here.
                throw new ApplicationException("The subscription could not be reinitialized.", ex);
            }
            finally
            {
                conn.Disconnect();
            }

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

' Create a connection to the Subscriber.
Dim conn As ServerConnection = New ServerConnection(subscriberName)

Dim subscription As TransPullSubscription

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

    ' Define subscription properties.
    subscription = New TransPullSubscription()
    subscription.ConnectionContext = conn
    subscription.DatabaseName = subscriptionDbName
    subscription.PublisherName = publisherName
    subscription.PublicationDBName = publicationDbName
    subscription.PublicationName = publicationName

    ' If the pull subscription and the job exists, mark the subscription
    ' for reinitialization and start the agent job.
    If subscription.LoadProperties() And (Not subscription.AgentJobId Is Nothing) Then
        subscription.Reinitialize()
        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
    ' Do appropriate error handling here.
    Throw New ApplicationException("The subscription could not be reinitialized.", ex)
Finally
    conn.Disconnect()
End Try

Esse exemplo reinicializa uma assinatura pull para uma publicação de mesclagem após o primeiro carregamento das alterações pendentes no Assinante.

          // Define server, publication, and database names.
            String subscriberName = subscriberInstance;
            String publisherName = publisherInstance;
            String publicationName = "AdvWorksSalesOrdersMerge";
            String publicationDbName = "AdventureWorks";
            String subscriptionDbName = "AdventureWorksReplica";

            // Create a connection to the Subscriber.
            ServerConnection conn = new ServerConnection(subscriberName);

            MergePullSubscription subscription;

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

                // Define subscription properties.
                subscription = new MergePullSubscription();
                subscription.ConnectionContext = conn;
                subscription.DatabaseName = subscriptionDbName;
                subscription.PublisherName = publisherName;
                subscription.PublicationDBName = publicationDbName;
                subscription.PublicationName = publicationName;

                // If the pull subscription and the job exists, mark the subscription
                // for reinitialization after upload and start the agent job.
                if (subscription.LoadProperties() && subscription.AgentJobId != null)
                {
                    subscription.Reinitialize(true);
                    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)
            {
                // Do appropriate error handling here.
                throw new ApplicationException("The subscription could not be synchronized.", ex);
            }
            finally
            {
                conn.Disconnect();
            }

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

' Create a connection to the Subscriber.
Dim conn As ServerConnection = New ServerConnection(subscriberName)

Dim subscription As MergePullSubscription

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

    ' Define subscription properties.
    subscription = New MergePullSubscription()
    subscription.ConnectionContext = conn
    subscription.DatabaseName = subscriptionDbName
    subscription.PublisherName = publisherName
    subscription.PublicationDBName = publicationDbName
    subscription.PublicationName = publicationName

    ' If the pull subscription and the job exists, mark the subscription
    ' for reinitialization after upload and start the agent job.
    If subscription.LoadProperties() And (Not subscription.AgentJobId Is Nothing) Then
        subscription.Reinitialize(True)
        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
    ' Do appropriate error handling here.
    Throw New ApplicationException("The subscription could not be synchronized.", ex)
Finally
    conn.Disconnect()
End Try

Consulte também

Tarefas

Como reinicializar uma assinatura (SQL Server Management Studio)

Como reinicializar uma assinatura (Programação Transact-SQL de replicação)

Conceitos

Reinicializando uma assinatura

Conceitos de Replication Management Objects