Cómo reinicializar una suscripción (programación con RMO)
Las suscripciones individuales se pueden marcar para reinicialización de manera que, durante la siguiente sincronización, se aplique una nueva instantánea. Las suscripciones se pueden reinicializar mediante programación usando Objetos de administración de replicación (RMO). Las clases RMO que usa dependen del tipo de publicación a la que pertenece la suscripción y del tipo de suscripción (es decir, una suscripción de inserción o de extracción).
Para reinicializar una suscripción de extracción a una publicación transaccional
Cree una conexión al suscriptor mediante la clase ServerConnection.
Cree una instancia de la clase TransPullSubscription y establezca PublicationName, DatabaseName, PublisherName, PublicationDBName y la conexión del paso 1 para ConnectionContext.
Llame al método LoadProperties para obtener las propiedades del objeto.
[!NOTA]
Si este método devuelve false, significa que las propiedades de suscripción del paso 2 se definieron incorrectamente o que la suscripción de extracción no existe.
Llame al método Reinitialize. Este método marca la suscripción para la reinicialización.
Sincronice la suscripción de extracción. Para obtener más información, vea Cómo sincronizar una suscripción de extracción (programación con RMO).
Para reinicializar una suscripción de inserción a una publicación transaccional
Cree una conexión al Publicador mediante la clase ServerConnection.
Cree una instancia de la clase TransSubscription y establezca PublicationName, DatabaseName, SubscriberName, SubscriptionDBName y la conexión del paso 1 para ConnectionContext.
Llame al método LoadProperties para obtener las propiedades del objeto.
[!NOTA]
Si este método devuelve false, significa que las propiedades de suscripción del paso 2 se definieron incorrectamente o que la suscripción de inserción no existe.
Llame al método Reinitialize. Este método marca la suscripción para la reinicialización.
Sincronice la suscripción de inserción. Para obtener más información, vea Cómo sincronizar una suscripción de inserción (programación con RMO).
Para reinicializar una suscripción de extracción a una publicación de mezcla
Cree una conexión al suscriptor mediante la clase ServerConnection.
Cree una instancia de la clase MergePullSubscription y establezca PublicationName, DatabaseName, PublisherName, PublicationDBName y la conexión del paso 1 para ConnectionContext.
Llame al método LoadProperties para obtener las propiedades del objeto.
[!NOTA]
Si este método devuelve false, significa que las propiedades de suscripción del paso 2 se definieron incorrectamente o que la suscripción de extracción no existe.
Llame al método Reinitialize. Pase un valor de true para cargar cambios en el Suscriptor antes de la reinicialización o un valor de false para reinicializar y perder cualquier cambio pendiente en el Suscriptor. Este método marca la suscripción para la reinicialización.
[!NOTA]
No se pueden cargar los cambios si caduca la suscripción. Para obtener más información, vea Caducó una suscripción de mezcla y es necesario cargar cambios.
Sincronice la suscripción de extracción. Para obtener más información, vea Cómo sincronizar una suscripción de extracción (programación con RMO).
Para reinicializar una suscripción de inserción a una publicación de mezcla
Cree una conexión al Publicador mediante la clase ServerConnection.
Cree una instancia de la clase MergeSubscription y establezca PublicationName, DatabaseName, SubscriberName, SubscriptionDBName y la conexión del paso 1 para ConnectionContext.
Llame al método LoadProperties para obtener las propiedades del objeto.
[!NOTA]
Si este método devuelve false, significa que las propiedades de suscripción del paso 2 se definieron incorrectamente o que la suscripción de inserción no existe.
Llame al método Reinitialize. Pase un valor de true para cargar cambios en el Suscriptor antes de la reinicialización o un valor de false para reinicializar y perder cualquier cambio pendiente en el Suscriptor. Este método marca la suscripción para la reinicialización.
[!NOTA]
No se pueden cargar los cambios si caduca la suscripción. Para obtener más información, vea Caducó una suscripción de mezcla y es necesario cargar cambios.
Sincronice la suscripción de inserción. Para obtener más información, vea Cómo sincronizar una suscripción de inserción (programación con RMO).
Ejemplo
En este ejemplo reinicializa una suscripción de extracción para una publicación transaccional.
// 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
Este ejemplo reinicializa una suscripción de extracción a una publicación de mezcla después de cargar primero los cambios pendientes en el Suscriptor.
// 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