次の方法で共有

サブスクリプションを再初期化する方法 (RMO プログラミング)

  • [アーティクル]

次回の同期で新しいスナップショットが適用されるように、個別のサブスクリプションに再初期化のマークを付けることができます。レプリケーション管理オブジェクト (RMO) を使用することで、プログラムによってサブスクリプションを再初期化できます。使用するクラスは、サブスクリプションが属するパブリケーションの種類と、サブスクリプションの種類 (プッシュ サブスクリプションまたはプル サブスクリプション) に応じて変わります。

トランザクション パブリケーションに対するプル サブスクリプションを再初期化するには

  1. ServerConnection クラスを使用して、サブスクライバへの接続を作成します。

  2. TransPullSubscription クラスのインスタンスを作成し、PublicationName、DatabaseName、PublisherName、PublicationDBName を設定して、手順 1. の接続を ConnectionContext に設定します。

  3. LoadProperties メソッドを呼び出して、オブジェクトのプロパティを取得します。

    ms146923.note(ja-jp,SQL.90).gifメモ :
    このメソッドが false を返す場合、手順 2. でサブスクリプション プロパティを不適切に設定したか、プル サブスクリプションが存在していません。

  4. Reinitialize メソッドを呼び出します。このメソッドにより、サブスクリプションを再初期化するようにマークされます。

  5. プル サブスクリプションを同期します。詳細については、「プル サブスクリプションを同期する方法 (RMO プログラミング)」を参照してください。

トランザクション パブリケーションに対するプッシュ サブスクリプションを再初期化するには

  1. ServerConnection クラスを使用して、パブリッシャへの接続を作成します。

  2. TransSubscription クラスのインスタンスを作成し、PublicationName、DatabaseName、SubscriberName、SubscriptionDBName を設定して、手順 1. の接続を ConnectionContext に設定します。

  3. LoadProperties メソッドを呼び出して、オブジェクトのプロパティを取得します。

    ms146923.note(ja-jp,SQL.90).gifメモ :
    このメソッドが false を返す場合、手順 2. でサブスクリプション プロパティを不適切に設定したか、プッシュ サブスクリプションが存在していません。

  4. Reinitialize メソッドを呼び出します。このメソッドにより、サブスクリプションを再初期化するようにマークされます。

  5. プッシュ サブスクリプションを同期します。詳細については、「プッシュ サブスクリプションを同期する方法 (RMO プログラミング)」を参照してください。

マージ パブリケーションに対するプル サブスクリプションを再初期化するには

  1. ServerConnection クラスを使用して、サブスクライバへの接続を作成します。

  2. MergePullSubscription クラスのインスタンスを作成し、PublicationName、DatabaseName、PublisherName、PublicationDBName を設定して、手順 1. の接続を ConnectionContext に設定します。

  3. LoadProperties メソッドを呼び出して、オブジェクトのプロパティを取得します。

    ms146923.note(ja-jp,SQL.90).gifメモ :
    このメソッドが false を返す場合、手順 2. でサブスクリプション プロパティを不適切に設定したか、プル サブスクリプションが存在していません。

  4. Reinitialize メソッドを呼び出します。再初期化の前に true を渡してサブスクライバの変更をアップロードするか、false を渡して再初期化し、サブスクライバの保留中の変更をすべて破棄します。このメソッドにより、サブスクリプションを再初期化するようにマークされます。

    ms146923.note(ja-jp,SQL.90).gifメモ :
    サブスクリプションの有効期限が切れると、変更をアップロードできません。詳細については、「マージ サブスクリプションの有効期限切れおよび変更のアップロード」を参照してください。

  5. プル サブスクリプションを同期します。詳細については、「プル サブスクリプションを同期する方法 (RMO プログラミング)」を参照してください。

マージ パブリケーションに対するプッシュ サブスクリプションを再初期化するには

  1. ServerConnection クラスを使用して、パブリッシャへの接続を作成します。

  2. MergeSubscription クラスのインスタンスを作成し、PublicationName、DatabaseName、SubscriberName、SubscriptionDBName を設定して、手順 1. の接続を ConnectionContext に設定します。

  3. LoadProperties メソッドを呼び出して、オブジェクトのプロパティを取得します。

    ms146923.note(ja-jp,SQL.90).gifメモ :
    このメソッドが false を返す場合、手順 2. でサブスクリプション プロパティを不適切に設定したか、プッシュ サブスクリプションが存在していません。

  4. Reinitialize メソッドを呼び出します。再初期化の前に true を渡してサブスクライバの変更をアップロードするか、false を渡して再初期化し、サブスクライバの保留中の変更をすべて破棄します。このメソッドにより、サブスクリプションを再初期化するようにマークされます。

    ms146923.note(ja-jp,SQL.90).gifメモ :
    サブスクリプションの有効期限が切れると、変更をアップロードできません。詳細については、「マージ サブスクリプションの有効期限切れおよび変更のアップロード」を参照してください。

  5. プッシュ サブスクリプションを同期します。詳細については、「プッシュ サブスクリプションを同期する方法 (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)
サブスクリプションの再初期化

ヘルプおよび情報

SQL Server 2005 の参考資料の入手