サブスクリプションを再初期化する方法 (RMO プログラミング)
次回の同期で新しいスナップショットが適用されるように、個別のサブスクリプションに再初期化のマークを付けることができます。レプリケーション管理オブジェクト (RMO) を使用することで、プログラムによってサブスクリプションを再初期化できます。使用するクラスは、サブスクリプションが属するパブリケーションの種類と、サブスクリプションの種類 (プッシュ サブスクリプションまたはプル サブスクリプション) に応じて変わります。
トランザクション パブリケーションに対するプル サブスクリプションを再初期化するには
ServerConnection クラスを使用して、サブスクライバへの接続を作成します。
TransPullSubscription クラスのインスタンスを作成し、PublicationName、DatabaseName、PublisherName、PublicationDBName を設定して、手順 1. の接続を ConnectionContext に設定します。
LoadProperties メソッドを呼び出して、オブジェクトのプロパティを取得します。
メモ :
このメソッドが false を返す場合、手順 2. でサブスクリプション プロパティを不適切に設定したか、プル サブスクリプションが存在していません。 Reinitialize メソッドを呼び出します。このメソッドにより、サブスクリプションを再初期化するようにマークされます。
プル サブスクリプションを同期します。詳細については、「プル サブスクリプションを同期する方法 (RMO プログラミング)」を参照してください。
トランザクション パブリケーションに対するプッシュ サブスクリプションを再初期化するには
ServerConnection クラスを使用して、パブリッシャへの接続を作成します。
TransSubscription クラスのインスタンスを作成し、PublicationName、DatabaseName、SubscriberName、SubscriptionDBName を設定して、手順 1. の接続を ConnectionContext に設定します。
LoadProperties メソッドを呼び出して、オブジェクトのプロパティを取得します。
メモ :
このメソッドが false を返す場合、手順 2. でサブスクリプション プロパティを不適切に設定したか、プッシュ サブスクリプションが存在していません。 Reinitialize メソッドを呼び出します。このメソッドにより、サブスクリプションを再初期化するようにマークされます。
プッシュ サブスクリプションを同期します。詳細については、「プッシュ サブスクリプションを同期する方法 (RMO プログラミング)」を参照してください。
マージ パブリケーションに対するプル サブスクリプションを再初期化するには
ServerConnection クラスを使用して、サブスクライバへの接続を作成します。
MergePullSubscription クラスのインスタンスを作成し、PublicationName、DatabaseName、PublisherName、PublicationDBName を設定して、手順 1. の接続を ConnectionContext に設定します。
LoadProperties メソッドを呼び出して、オブジェクトのプロパティを取得します。
メモ :
このメソッドが false を返す場合、手順 2. でサブスクリプション プロパティを不適切に設定したか、プル サブスクリプションが存在していません。 Reinitialize メソッドを呼び出します。再初期化の前に true を渡してサブスクライバの変更をアップロードするか、false を渡して再初期化し、サブスクライバの保留中の変更をすべて破棄します。このメソッドにより、サブスクリプションを再初期化するようにマークされます。
メモ :
サブスクリプションの有効期限が切れると、変更をアップロードできません。詳細については、「マージ サブスクリプションの有効期限切れおよび変更のアップロード」を参照してください。 プル サブスクリプションを同期します。詳細については、「プル サブスクリプションを同期する方法 (RMO プログラミング)」を参照してください。
マージ パブリケーションに対するプッシュ サブスクリプションを再初期化するには
ServerConnection クラスを使用して、パブリッシャへの接続を作成します。
MergeSubscription クラスのインスタンスを作成し、PublicationName、DatabaseName、SubscriberName、SubscriptionDBName を設定して、手順 1. の接続を ConnectionContext に設定します。
LoadProperties メソッドを呼び出して、オブジェクトのプロパティを取得します。
メモ :
このメソッドが false を返す場合、手順 2. でサブスクリプション プロパティを不適切に設定したか、プッシュ サブスクリプションが存在していません。 Reinitialize メソッドを呼び出します。再初期化の前に true を渡してサブスクライバの変更をアップロードするか、false を渡して再初期化し、サブスクライバの保留中の変更をすべて破棄します。このメソッドにより、サブスクリプションを再初期化するようにマークされます。
メモ :
サブスクリプションの有効期限が切れると、変更をアップロードできません。詳細については、「マージ サブスクリプションの有効期限切れおよび変更のアップロード」を参照してください。 プッシュ サブスクリプションを同期します。詳細については、「プッシュ サブスクリプションを同期する方法 (RMO プログラミング)」を参照してください。
使用例
次の例では、トランザクション パブリケーションに対するプル サブスクリプションを再初期化します。
// 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
次の例では、最初にサブスクライバの保留中の変更をアップロードした後、マージ パブリケーションに対するプル サブスクリプションを初期化します。
// 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
参照
処理手順
サブスクリプションを再初期化する方法 (レプリケーション Transact-SQL プログラミング)
概念
その他の技術情報
SQL Server Compact Edition サブスクリプションを再初期化する方法 (プログラム)
サブスクリプションを再初期化する方法 (SQL Server Management Studio)
サブスクリプションの再初期化