パラメーター化されたフィルターを使用したパブリケーションのスナップショットの作成
適用対象:
SQL Server
このトピックでは、SQL Server Management Studio、Transact-SQL、またはレプリケーション管理オブジェクトまたはレプリケーション管理オブジェクト (RMO) を使用して、SQL Server のパラメーター化されたフィルターでマージ パブリケーションのスナップショットを作成する方法ついて説明します。
パラメーター化された行フィルターがマージ パブリケーションで使用される場合、レプリケーションは 2 つの要素から成るスナップショットを持つ各サブスクリプションを初期化します。 まず、レプリケーションに必要なすべてのオブジェクトとパブリッシュされたオブジェクトのスキーマが含まれるスキーマ スナップショットが作成されます。ただしデータは含まれません。 次に、スキーマ スナップショットからのオブジェクトとスキーマが含まれるスナップショットと、サブスクリプションのパーティションに属するデータを使用して、各サブスクリプションが初期化されます。 複数のサブスクリプションが特定のパーティションを受信する場合 (つまり、同じスキーマとデータを受信する場合)、そのパーティションのスナップショットは 1 回しか作成されません。複数のサブスクリプションは、同じスナップショットから初期化されます。 パラメーター化された行フィルターの詳細については、「 パラメーター化された行フィルター」を参照してください。
次の 3 つの方法のいずれかで、パラメーター化されたフィルターを使用して、パブリケーションのスナップショットを作成できます。
各パーティションのスナップショットを事前に生成します。 このオプションを使用すると、スナップショットが生成されたときに制御できます。
スナップショットがスケジュールに従って更新されるように選択することもできます。 スナップショットの作成対象となったパーティションをサブスクライブする新しいサブスクライバーは、最新のスナップショットを受信します。サブスクライバーが初めて同期されたときに、スナップショットの生成と適用を要求できるようにします。 このオプションを使用すると、新しいサブスクライバーは管理者の介入を必要とせずに同期できます (スナップショットを生成するには SQL Server エージェントがパブリッシャーで実行されている必要があります)。
Note
パブリケーション内の 1 つ以上のアーティクルにフィルターを適用して、各サブスクリプション固有の重複しないパーティションが得られる場合、マージ エージェントが実行されるたびにメタデータがクリーンアップされます。 これは、パーティション スナップショットの有効期間が短時間で切れてしまうことを意味します。 このオプションを使用する場合は、サブスクライバーに対してスナップショットの生成と配信を許可することを検討する必要があります。 フィルター オプションの詳細については、「 パラメーター化された行フィルター」を参照してください。
スナップショット エージェントを使用して、手動で各サブスクライバーのスナップショットを生成します。 サブスクライバーは、マージ エージェントが正しいスナップショットを取得および適用できるように、スナップショットの場所をマージ エージェントに提供する必要があります。
Note
このオプションは、旧バージョンとの互換性のためにサポートされており、FTP スナップショット共有を使用できません。
最も柔軟性の高い方法は、事前に生成され、サブスクライバーに要求されるスナップショット オプションの組み合わせを使用することです。スナップショットは、スケジュールに基づいて (通常はオフピーク時に) 事前生成および更新されますが、新しいパーティションを必要とするサブスクリプションが作成された場合は、サブスクライバーが独自のスナップショットを生成できます。
各店舗に在庫を配送する移動営業部署のある Adventure Works について考えてみましょう。 各営業担当者は、各自のログインに基づいてサブスクリプションを受信し、各自が担当する店舗についてのデータを取得します。 管理者は、スナップショットを事前に生成し、毎週日曜日に更新するように選択しています。 場合によっては、新しいユーザーがシステムに追加され、スナップショットを使用できないパーティションのデータが必要になります。 管理者の選択により、サブスクライバーが開始するスナップショットで、スナップショットがまだ使用できないためにサブスクライバーがパブリケーションをサブスクライブできない状況を回避することもできます。 新しいサブスクライバーが初めて接続すると、指定されたパーティションに対してスナップショットが生成され、サブスクライバーで適用されます (スナップショットを生成できるようにするには、SQL Server エージェントがパブリッシャーで実行されている必要があります)。
パラメーター化されたフィルターを使用してパブリケーションのスナップショットを作成するには、「 パラメーター化されたフィルターを使用したパブリケーションのスナップショットの作成」を参照してください。
スナップショット エージェントに対するセキュリティの設定
スナップショット エージェントは各パーティションのスナップショットを作成します。 事前に生成されるスナップショットとサブスクライバーによって要求されるスナップショットの場合、エージェントが実行され、パブリケーションのスナップショット エージェント ジョブ作成時に指定された資格情報に基づいて接続が作成されます (このジョブは、パブリケーションの新規作成ウィザードまたは sp_addpublication_snapshotによって作成されます)。 資格情報を変更するには、 sp_changedynamicsnapshot_jobを使用します。 詳しくは、「sp_changedynamicsnapshot_job (Transact-SQL)」をご覧ください。
推奨事項
パラメーター化されたフィルターを使用してマージ パブリケーションのスナップショットを生成する際には、最初にすべてのパブリッシュ済みデータとサブスクリプションのサブスクライバー メタデータを含む標準 (スキーマ) スナップショットを生成する必要があります。 詳しくは、「 初期スナップショットの作成および適用」をご覧ください。 スキーマ スナップショットを作成した後で、パブリッシュ済みデータのサブスクライバー固有のパーティションを含むスナップショットを作成できます。
パブリケーション内の 1 つ以上のアーティクルにフィルターを適用して、各サブスクリプション固有の重複しないパーティションが得られる場合、マージ エージェントが実行されるたびにメタデータがクリーンアップされます。 これは、パーティション スナップショットの有効期間が短時間で切れてしまうことを意味します。 このオプションを使用する場合は、サブスクライバーに対してスナップショットの生成と配信を許可することを検討する必要があります。
SQL Server Management Studio を使用する
[パブリケーションのプロパティ - <Publication]> ダイアログ ボックスの [データ パーティション] ページでパーティションのスナップショットを作成します。 このダイアログ ボックスへのアクセス方法の詳細については、「パブリケーション プロパティの表示および変更」を参照してください。 サブスクライバーには、スナップショットの生成と配信の開始や、スナップショットの生成を許可できます。
1 つ以上のパーティションに対してスナップショットを生成する前に、以下の作業を行う必要があります。
新規パブリーケーション ウィザードを使用してマージ パブリケーションを作成し、ウィザードの [フィルターの追加] ページで 1 つ以上のパラメーター化された行フィルターを指定します。 詳しくは、「 マージ アーティクルのパラメーター化された行フィルターの定義および変更」をご覧ください。
パブリケーションのスキーマ スナップショットを生成します。 既定では、新規パブリケーション ウィザードが完了すると、スキーマ スナップショットが生成されます。また、SQL Server Management Studio からスキーマ スナップショットを生成することもできます。
スキーマ スナップショットを生成するには
Management Studio でパブリッシャーに接続し、サーバー ノードを展開します。
[レプリケーション] フォルダーを展開し、 [パブリケーション] フォルダーを展開します。
スナップショットを作成するパブリケーションを右クリックして、 [スナップショット エージェントの状態の表示]をクリックします。
[スナップショット エージェントの状態の表示 - <Publication]> ダイアログ ボックスで [開始] をクリックします。
スナップショット エージェントによるスナップショットの生成が完了すると、"[100%] 17 個のアーティクルのスナップショットが生成されました。" などのメッセージが表示されます。
サブスクライバーにスナップショットの生成と配信を許可するには
[パブリケーションのプロパティ - <Publication]> ダイアログ ボックスの [データ パーティション] ページで、[新規サブスクライバーで同期を行うとき、パーティションを自動的に定義し、必要に応じてスナップショットを生成する] を選択します。
[OK] を選択します。
スナップショットの生成と更新を行うには
[パブリケーションのプロパティ - <Publication]> ダイアログ ボックスの [データ パーティション] ページで [追加] をクリックします。
スナップショットを作成するパーティションに関連付けられた HOST_NAME() と SUSER_SNAME() に値を入力します。
オプションでスナップショットの更新スケジュールを指定します。
[以下のスケジュールでこのパーティションのスナップショット エージェントを実行する]を選択します。
スナップショットの既定の更新スケジュールをそのまま使用するか、または [変更] をクリックして別のスケジュールを指定します。
[OK] をクリックして、[パブリケーションのプロパティ - <Publication]> ダイアログ ボックスに戻ります。
プロパティ グリッドでパーティションを選択し、 [今すぐ選択したスナップショットを生成する]をクリックします。
[OK] を選択します。
Transact-SQL の使用
ストアド プロシージャとスナップショット エージェントを使用して、次を実行できます。
サブスクライバーが初めて同期されたときに、スナップショットの生成と適用を要求できるようにします。
各パーティションのスナップショットを事前に生成します。
各サブスクライバーのスナップショットを手動で生成できます。
重要
可能であれば、実行時、ユーザーに対してセキュリティ資格情報の入力を要求します。 スクリプト ファイルに資格情報を格納する必要がある場合は、不正アクセスを防ぐために、ファイルを保護します。
サブスクライバーでスナップショットの生成と配信を開始するためのパブリケーションを作成するには
パブリッシャー側のパブリケーション データベースに対して、sp_addmergepublication (Transact-SQL) を実行します。 次のパラメーターを指定します。
@publicationに、パブリケーション名を指定します。
@allow_subscriber_initiated_snapshot に、 trueを指定します。これにより、サブスクライバーがスナップショット プロセスを開始できるようになります。
(省略可) @max_concurrent_dynamic_snapshotsに、同時に実行できる動的スナップショット プロセスの数を指定します。 最大限の数のプロセスが実行しているときに、サブスクライバーがスナップショットを生成しようとすると、そのプロセスはキューに格納されます。 既定では、同時プロセスの数に限度はありません。
パブリッシャーで sp_addpublication_snapshot (Transact-SQL) を実行します。 手順 1. で使用したパブリケーション名を @publication に指定し、レプリケーション スナップショット エージェントを実行するときに使用される Microsoft Windows 資格情報を @job_login と @password に指定します。 エージェントがパブリッシャーに接続する際に SQL Server 認証を使用する場合、さらに @publisher_security_mode に値 0 を指定し、@publisher_login と @publisher_password に Microsoft SQL Server ログイン情報を指定する必要があります。 これにより、パブリケーション用のスナップショット エージェント ジョブが作成されます。 初期スナップショットの作成と、スナップショット エージェントのカスタム スケジュールの定義については、「 Create and Apply the Initial Snapshot」を参照してください。
重要
リモート ディストリビューターを使用するパブリッシャーを構成する場合は、 job_login および job_passwordを含むすべてのパラメーターに指定された値がディストリビューターにプレーン テキストとして送信されます。 このストアド プロシージャを実行する前に、パブリッシャーとリモート ディストリビューターの間の接続を暗号化する必要があります。 詳細については、「データベース エンジンへの暗号化接続の有効化 (SQL Server 構成マネージャー)」を参照してください。
sp_addmergearticle (Transact-SQL) を実行して、パブリケーションにアーティクルを追加します。 このストアド プロシージャは、パブリケーション内の各アーティクルについて 1 回ずつ実行する必要があります。 パラメーター化されたフィルターを使用する場合には、 @subset_filterclause パラメーターを使用して 1 つ以上のアーティクルにパラメーター化された行フィルターを指定する必要があります。 詳しくは、「 マージ アーティクルのパラメーター化された行フィルターの定義および変更」をご覧ください。
他のアーティクルがパラメーター化された行フィルターに基づいてフィルター選択される場合、sp_addmergefilter (Transact-SQL) を実行して、アーティクル間の結合レコード リレーションシップまたは論理レコード リレーションシップを定義します。 このストアド プロシージャは、定義する各リレーションシップにつき 1 回ずつ実行する必要があります。 詳しくは、「 マージ アーティクル間の結合フィルターの定義および変更」をご覧ください。
マージ エージェントでサブスクライバーを初期化するためにスナップショットが必要な場合、要求側のサブスクリプションのパーティションのスナップショットが自動的に生成されます。
パブリケーションを作成し、スナップショットを事前に生成、または自動更新するには
sp_addmergepublication (Transact-SQL) を実行して、パブリケーションを作成します。 詳しくは、「 パブリケーションを作成」をご覧ください。
パブリッシャーで sp_addpublication_snapshot (Transact-SQL) を実行します。 手順 1. で使用したパブリケーション名を @publication に指定し、スナップショット エージェントを実行するときに使用される Windows 資格情報を @job_login と @passwordに指定します。 エージェントがパブリッシャーに接続する際に SQL Server 認証を使用する場合、さらに @publisher_security_mode に値 0 を指定し、@publisher_login と @publisher_password に SQL Server ログイン情報を指定する必要があります。 これにより、パブリケーション用のスナップショット エージェント ジョブが作成されます。 初期スナップショットの作成と、スナップショット エージェントのカスタム スケジュールの定義については、「 Create and Apply the Initial Snapshot」を参照してください。
重要
リモート ディストリビューターを使用するパブリッシャーを構成する場合は、 job_login および job_passwordを含むすべてのパラメーターに指定された値がディストリビューターにプレーン テキストとして送信されます。 このストアド プロシージャを実行する前に、パブリッシャーとリモート ディストリビューターの間の接続を暗号化する必要があります。 詳細については、「データベース エンジンへの暗号化接続の有効化 (SQL Server 構成マネージャー)」を参照してください。
sp_addmergearticle (Transact-SQL) を実行して、パブリケーションにアーティクルを追加します。 このストアド プロシージャは、パブリケーション内の各アーティクルについて 1 回ずつ実行する必要があります。 パラメーター化されたフィルターを使用する場合には、 @subset_filterclause パラメーターを使用して 1 つのアーティクルにパラメーター化された行フィルターを指定する必要があります。 詳しくは、「 マージ アーティクルのパラメーター化された行フィルターの定義および変更」をご覧ください。
他のアーティクルがパラメーター化された行フィルターに基づいてフィルター選択される場合、sp_addmergefilter (Transact-SQL) を実行して、アーティクル間の結合レコード リレーションシップまたは論理レコード リレーションシップを定義します。 このストアド プロシージャは、定義する各リレーションシップにつき 1 回ずつ実行する必要があります。 詳しくは、「 マージ アーティクル間の結合フィルターの定義および変更」をご覧ください。
パブリケーション データベースのパブリッシャーで sp_helpmergepublication (Transact-SQL) を実行し、手順 1 の @publication の値を指定します。 結果セットの snapshot_jobid の値を確認します。
手順 5. で得られた snapshot_jobid の値を、 uniqueidentifierに変換します。
パブリッシャーの msdb データベースに対して、sp_start_job (Transact-SQL) を実行します。@job_id には、手順 6 で得られた変換済みの値を指定します。
パブリッシャー側のパブリケーション データベースに対して、sp_addmergepartition (Transact-SQL) を実行します。 手順 1. のパブリケーション名を @publication に指定します。パーティションの定義に使用する値には、フィルター句で SUSER_SNAME (Transact-SQL) が使用されている場合は @suser_sname、フィルター句で HOST_NAME (Transact-SQL) が使用されている場合は @host_name を指定します。
パブリッシャー側のパブリケーション データベースに対して、sp_adddynamicsnapshot_job (Transact-SQL) を実行します。 手順 1. のパブリケーション名を @publicationに指定します。手順 8. で使用した @suser_sname または @host_name の値を指定し、ジョブのスケジュールを指定します。 これにより、指定されたパーティションにパラメーター化スナップショットを生成するジョブが作成されます。 詳細については、「 Specify Synchronization Schedules」を参照してください。
Note
このジョブは、手順 2. で定義した初期スナップショット ジョブと同じ Windows アカウントを使用して実行されます。 このパラメーター化されたスナップショット ジョブおよび関連するデータ パーティションを削除するには、sp_dropdynamicsnapshot_job (Transact-SQL) を実行します。
パブリッシャー側のパブリケーション データベースに対して、sp_helpmergepartition (Transact-SQL) を実行し、手順 1 の @publication の値および手順 8 の @suser_sname または @host_name の値を指定します。 結果セットの dynamic_snapshot_jobid の値を確認します。
ディストリビューターの msdb データベースに対して、sp_start_job (Transact-SQL) を実行します。@job_id には、手順 9 で得られた値を指定します。 これにより、そのパーティションに対してパラメーター化されたスナップショット ジョブが開始されます。
手順 8. ～ 11. を繰り返し実行して、各サブスクリプションについてパーティション スナップショットを生成します。
パブリケーションを作成し、各パーティションのスナップショットを手動で作成するには
sp_addmergepublication (Transact-SQL) を実行して、パブリケーションを作成します。 詳しくは、「 パブリケーションを作成」をご覧ください。
パブリッシャーで sp_addpublication_snapshot (Transact-SQL) を実行します。 手順 1. で使用したパブリケーション名を @publication に指定し、スナップショット エージェントを実行するときに使用される Windows 資格情報を @job_login と @passwordに指定します。 エージェントがパブリッシャーに接続する際に SQL Server 認証を使用する場合、さらに @publisher_security_mode に値 0 を指定し、@publisher_login と @publisher_password に SQL Server ログイン情報を指定する必要があります。 これにより、パブリケーション用のスナップショット エージェント ジョブが作成されます。 初期スナップショットの作成と、スナップショット エージェントのカスタム スケジュールの定義については、「 Create and Apply the Initial Snapshot」を参照してください。
重要
リモート ディストリビューターを使用するパブリッシャーを構成する場合は、 job_login および job_passwordを含むすべてのパラメーターに指定された値がディストリビューターにプレーン テキストとして送信されます。 このストアド プロシージャを実行する前に、パブリッシャーとリモート ディストリビューターの間の接続を暗号化する必要があります。 詳細については、「データベース エンジンへの暗号化接続の有効化 (SQL Server 構成マネージャー)」を参照してください。
sp_addmergearticle (Transact-SQL) を実行して、パブリケーションにアーティクルを追加します。 このストアド プロシージャは、パブリケーション内の各アーティクルについて 1 回ずつ実行する必要があります。 パラメーター化されたフィルターを使用する場合には、 @subset_filterclause パラメーターを使用して 1 つ以上のアーティクルにパラメーター化された行フィルターを指定する必要があります。 詳しくは、「 マージ アーティクルのパラメーター化された行フィルターの定義および変更」をご覧ください。
他のアーティクルがパラメーター化された行フィルターに基づいてフィルター選択される場合、sp_addmergefilter (Transact-SQL) を実行して、アーティクル間の結合レコード リレーションシップまたは論理レコード リレーションシップを定義します。 このストアド プロシージャは、定義する各リレーションシップにつき 1 回ずつ実行する必要があります。 詳しくは、「 マージ アーティクル間の結合フィルターの定義および変更」をご覧ください。
スナップショット ジョブを開始するか、コマンド プロンプトからレプリケーション スナップショット エージェントを実行して、標準のスナップショット スキーマおよびその他のファイルを生成します。 詳しくは、「 初期スナップショットの作成および適用」をご覧ください。
再びコマンド プロンプトからレプリケーション スナップショット エージェントを実行し、一括コピー (.bcp) ファイルを生成します。パーティション スナップショットの場所を -DynamicSnapshotLocation に指定し、次の 2 つのプロパティを指定して、パーティションを定義します。
-DynamicFilterHostName - HOST_NAME (Transact-SQL) が使用される場合の値。
-DynamicFilterLogin - SUSER_SNAME (Transact-SQL) が使用される場合の値。
手順 6. を繰り返し実行して、各サブスクリプションについてパーティション スナップショットを生成します。
サブスクリプションごとにマージ エージェントを実行して、初期のパーティション スナップショットをサブスクライバーに適用します。次のプロパティを指定します。
-Hostname - HOST_NAME の実際の値がオーバーライドされている場合にパーティションの定義に使用する値。
-DynamicSnapshotLocation - このパーティションの動的スナップショットの場所。
Note
レプリケーション エージェントのプログラミングの詳細については、「Replication Agent Executables Concepts」(レプリケーション エージェントの実行可能ファイルの概念) を参照してください。
例 (Transact-SQL)
次の例では、サブスクライバーによってスナップショット生成プロセスが開始される場合に、パラメーター化されたフィルターを使用してマージ パブリケーションを作成します。 @job_login および @job_password に指定する値は、スクリプト変数を使用して渡されます。
-- To avoid storing the login and password in the script file, the value
-- is passed into SQLCMD as a scripting variable. For information about
-- how to use scripting variables on the command line and in SQL Server
-- Management Studio, see the "Executing Replication Scripts" section in
-- the topic "Programming Replication Using System Stored Procedures".
--Add a new merge publication.
DECLARE @publicationdb AS sysname;
DECLARE @publication AS sysname;
DECLARE @table1 AS sysname;
DECLARE @table2 AS sysname;
DECLARE @filter AS sysname;
DECLARE @schema_hr AS sysname;
DECLARE @schema_sales AS sysname;
SET @publicationdb = N'AdventureWorks2022';
SET @publication = N'AdvWorksSalesPersonMerge';
SET @table1 = N'Employee';
SET @table2 = N'SalesPerson';
SET @filter = N'SalesPerson_Employee';
SET @schema_hr = N'HumanResources';
SET @schema_sales = N'Sales';
USE [AdventureWorks2022];
-- Enable AdventureWorks2022 for merge replication.
EXEC sp_replicationdboption
@dbname = @publicationdb,
@optname = N'merge publish',
@value = N'true';
-- Create new merge publication with Subscriber requested snapshot
-- and using the default agent schedule.
EXEC sp_addmergepublication
@publication = @publication,
@description = N'Merge publication of AdventureWorks2022.',
@allow_subscriber_initiated_snapshot = N'true',
@publication_compatibility_level = N'90RTM';
-- Create a new snapshot job for the publication, using the default schedule.
-- Pass credentials at runtime using sqlcmd scripting variables.
EXEC sp_addpublication_snapshot
@publication = @publication,
@job_login = $(login),
@job_password = $(password);
-- Add an article for the Employee table,
-- which is horizontally partitioned using
-- a parameterized row filter.
EXEC sp_addmergearticle
@publication = @publication,
@article = @table1,
@source_owner = @schema_hr,
@source_object = @table1,
@type = N'table',
@description = 'contains employee information',
@subset_filterclause = N'[LoginID] = HOST_NAME()';
-- Add an article for the SalesPerson table,
-- which is partitioned based on a join filter.
EXEC sp_addmergearticle
@publication = @publication,
@article = @table2,
@source_owner = @schema_sales,
@source_object = @table2,
@type = N'table',
@description = 'contains salesperson information';
-- Add a join filter between the two articles.
EXEC sp_addmergefilter
@publication = @publication,
@article = @table1,
@filtername = @filter,
@join_articlename = @table2,
@join_filterclause = N'[Employee].[BusinessEntityID] = [SalesPerson].[SalesPersonID]',
@join_unique_key = 1,
@filter_type = 1;
GO
-- Start the agent job to generate the full snapshot for the publication.
-- The filtered data snapshot is generated automatically the first time
-- the subscription is synchronized.
DECLARE @publication AS sysname;
SET @publication = N'AdvWorksSalesPersonMerge';
EXEC sp_startpublication_snapshot
@publication = @publication;
GO
次の例では、パラメーター化されたフィルターを使用してパブリケーションを作成します。各サブスクライバーでは sp_addmergepartition を実行することでパーティションを定義し、パーティション情報を渡して sp_adddynamicsnapshot_job を実行することで、フィルター選択したスナップショット ジョブを作成します。 @job_login および @job_password に指定する値は、スクリプト変数を使用して渡されます。
-- To avoid storing the login and password in the script file, the value
-- is passed into SQLCMD as a scripting variable. For information about
-- how to use scripting variables on the command line and in SQL Server
-- Management Studio, see the "Executing Replication Scripts" section in
-- the topic "Programming Replication Using System Stored Procedures".
--Add a new merge publication.
DECLARE @publicationdb AS sysname;
DECLARE @publication AS sysname;
DECLARE @table1 AS sysname;
DECLARE @table2 AS sysname;
DECLARE @filter AS sysname;
DECLARE @schema_hr AS sysname;
DECLARE @schema_sales AS sysname;
SET @publicationdb = N'AdventureWorks2022';
SET @publication = N'AdvWorksSalesPersonMerge';
SET @table1 = N'Employee';
SET @table2 = N'SalesPerson';
SET @filter = N'SalesPerson_Employee';
SET @schema_hr = N'HumanResources';
SET @schema_sales = N'Sales';
USE [AdventureWorks2022];
-- Enable AdventureWorks2022 for merge replication.
EXEC sp_replicationdboption
@dbname = @publicationdb,
@optname = N'merge publish',
@value = N'true';
-- Create new merge publication.
EXEC sp_addmergepublication
@publication = @publication,
@description = N'Merge publication of AdventureWorks2022.',
@allow_subscriber_initiated_snapshot = N'false';
-- Create a new snapshot job for the publication, using the
-- default schedule. Pass credentials at runtime using
-- sqlcmd scripting variables.
EXEC sp_addpublication_snapshot
@publication = @publication,
@job_login = $(Login),
@job_password = $(password);
-- Add an article for the Employee table,
-- which is horizontally partitioned using
-- a parameterized row filter.
EXEC sp_addmergearticle
@publication = @publication,
@article = @table1,
@source_owner = @schema_hr,
@source_object = @table1,
@type = N'table',
@description = 'contains employee information',
@subset_filterclause = N'[LoginID] = HOST_NAME()';
-- Add an article for the SalesPerson table,
-- which is partitioned based on a join filter.
EXEC sp_addmergearticle
@publication = @publication,
@article = @table2,
@source_owner = @schema_sales,
@source_object = @table2,
@type = N'table',
@description = 'contains customer information';
-- Add a join filter between the two articles.
EXEC sp_addmergefilter
@publication = @publication,
@article = @table1,
@filtername = @filter,
@join_articlename = @table2,
@join_filterclause = N'[Employee].[BusinessEntityID] = [SalesPerson].[SalesPersonID]',
@join_unique_key = 1,
@filter_type = 1;
GO
-- Start the snapshot agent job.
DECLARE @publication AS sysname;
SET @publication = N'AdvWorksSalesPersonMerge';
EXEC sp_startpublication_snapshot
@publication = @publication;
GO
PRINT '*** Waiting for the initial snapshot.';
GO
-- Create a temporary table to store the filtered data snapshot
-- job information.
CREATE TABLE #temp (id int,
job_name sysname,
job_id uniqueidentifier,
dynamic_filter_login sysname NULL,
dynamic_filter_hostname sysname NULL,
dynamic_snapshot_location nvarchar(255),
frequency_type int,
frequency_interval int,
frequency_subday_type int,
frequency_subday_interval int,
frequency_relative_interval int,
frequency_recurrence_factor int,
active_start_date int,
active_end_date int,
active_start_time int,
active_end_time int
)
-- Create each snapshot for a partition
-- The initial snapshot must already be generated.
DECLARE @publication AS sysname;
DECLARE @jobname AS sysname
DECLARE @hostname AS sysname
SET @publication = N'AdvWorksSalesPersonMerge';
SET @hostname = N'adventure-works\Fernando';
WHILE NOT EXISTS(SELECT * FROM sysmergepublications
WHERE [name] = @publication
AND snapshot_ready = 1)
BEGIN
WAITFOR DELAY '00:00:05'
END
-- Create a data partition by overriding HOST_NAME().
EXEC sp_addmergepartition
@publication = @publication,
@host_name = @hostname;
-- Create the filtered data snapshot job, and use the returned
-- information to start the job.
EXEC sp_adddynamicsnapshot_job
@publication = @publication,
@host_name = @hostname;
INSERT INTO #temp (id, job_name, job_id, dynamic_filter_login,
dynamic_filter_hostname, dynamic_snapshot_location,
frequency_type, frequency_interval, frequency_subday_type,
frequency_subday_interval, frequency_relative_interval,
frequency_recurrence_factor, active_start_date, active_end_date,
active_start_time,active_end_time)
EXEC sp_helpdynamicsnapshot_job;
SELECT @jobname = (SELECT DISTINCT job_name FROM #temp WHERE dynamic_filter_hostname = @hostname);
EXEC msdb..sp_start_job @job_name = @jobname;
DROP TABLE #temp;
GO
次の例では、各サブスクライバーでパーティション情報を入力してデータ パーティションとフィルター選択したスナップショット ジョブを作成する必要がある場合に、パラメーター化されたフィルターを使用してパブリケーションを作成します。 レプリケーション エージェントを手動で実行する場合、サブスクライバーではコマンド ライン パラメーターを使用してパーティション情報を入力します。 この例では、パブリケーションに対するサブスクリプションも作成されることを想定しています。
-- To avoid storing the login and password in the script file, the value
-- is passed into SQLCMD as a scripting variable. For information about
-- how to use scripting variables on the command line and in SQL Server
-- Management Studio, see the "Executing Replication Scripts" section in
-- the topic "Programming Replication Using System Stored Procedures".
--Add a new merge publication.
DECLARE @publicationdb AS sysname;
DECLARE @publication AS sysname;
DECLARE @table1 AS sysname;
DECLARE @table2 AS sysname;
DECLARE @filter AS sysname;
DECLARE @schema_hr AS sysname;
DECLARE @schema_sales AS sysname;
SET @publicationdb = N'AdventureWorks2022';
SET @publication = N'AdvWorksSalesPersonMerge';
SET @table1 = N'Employee';
SET @table2 = N'SalesPerson';
SET @filter = N'SalesPerson_Employee';
SET @schema_hr = N'HumanResources';
SET @schema_sales = N'Sales';
USE [AdventureWorks2022];
-- Enable AdventureWorks2022 for merge replication.
EXEC sp_replicationdboption
@dbname = @publicationdb,
@optname = N'merge publish',
@value = N'true';
-- Create new merge publication.
EXEC sp_addmergepublication
@publication = @publication,
@description = N'Merge publication of AdventureWorks2022.',
@allow_subscriber_initiated_snapshot = N'false';
-- Create a new snapshot job for the publication, using the
-- default schedule. Pass credentials at runtime using
-- sqlcmd scripting variables.
EXEC sp_addpublication_snapshot
@publication = @publication,
@job_login = $(Login),
@job_password = $(Password);
-- Add an article for the Employee table,
-- which is horizontally partitioned using
-- a parameterized row filter.
EXEC sp_addmergearticle
@publication = @publication,
@article = @table1,
@source_owner = @schema_hr,
@source_object = @table1,
@type = N'table',
@description = 'contains employee information',
@subset_filterclause = N'[LoginID] = HOST_NAME()';
-- Add an article for the SalesPerson table,
-- which is partitioned based on a join filter.
EXEC sp_addmergearticle
@publication = @publication,
@article = @table2,
@source_owner = @schema_sales,
@source_object = @table2,
@type = N'table',
@description = 'contains customer information';
-- Add a join filter between the two articles.
EXEC sp_addmergefilter
@publication = @publication,
@article = @table1,
@filtername = @filter,
@join_articlename = @table2,
@join_filterclause = N'[Employee].[BusinessEntityID] = [SalesPerson].[SalesPersonID]',
@join_unique_key = 1,
@filter_type = 1;
GO
REM Line breaks are added to improve readability.
REM In a batch file, commands must be made in a single line.
REM Run the Snapshot agent from the command line to generate the standard snapshot
REM schema and other files.
SET DistPub=%computername%
SET PubDB=AdventureWorks2022
SET PubName=AdvWorksSalesPersonMerge
"C:\Program Files\Microsoft SQL Server\120\COM\SNAPSHOT.EXE" -Publication %PubName%
-Publisher %DistPub% -Distributor %DistPub% -PublisherDB %PubDB% -ReplicationType 2
-OutputVerboseLevel 1 -DistributorSecurityMode 1
PAUSE
REM Run the Snapshot agent from the command line, this time to generate
REM the bulk copy (.bcp) data for each Subscriber partition.
SET DistPub=%computername%
SET PubDB=AdventureWorks2022
SET PubName=AdvWorksSalesPersonMerge
SET SnapshotDir=\\%DistPub%\repldata\unc\fernando
MD %SnapshotDir%
"C:\Program Files\Microsoft SQL Server\120\COM\SNAPSHOT.EXE" -Publication %PubName%
-Publisher %DistPub% -Distributor %DistPub% -PublisherDB %PubDB% -ReplicationType 2
-OutputVerboseLevel 1 -DistributorSecurityMode 1 -DynamicFilterHostName "adventure-works\Fernando"
-DynamicSnapshotLocation %SnapshotDir%
PAUSE
REM Run the Merge Agent for each subscription to apply the partitioned
REM snapshot for each Subscriber.
SET Publisher = %computername%
SET Subscriber = %computername%
SET PubDB = AdventureWorks2022
SET SubDB = AdventureWorks2022Replica
SET PubName = AdvWorksSalesPersonMerge
SET SnapshotDir=\\%DistPub%\repldata\unc\fernando
"C:\Program Files\Microsoft SQL Server\120\COM\REPLMERG.EXE" -Publisher %Publisher%
-Subscriber %Subscriber% -Distributor %Publisher% -PublisherDB %PubDB%
-SubscriberDB %SubDB% -Publication %PubName% -PublisherSecurityMode 1 -OutputVerboseLevel 3
-Output -SubscriberSecurityMode 1 -SubscriptionType 3 -DistributorSecurityMode 1
-Hostname "adventure-works\Fernando" -DynamicSnapshotLocation %SnapshotDir%
PAUSE
レプリケーション管理オブジェクト (RMO) の使用
パーティション スナップショットは、プログラムからレプリケーション管理オブジェクト (RMO) を使用して生成できます。その方法を次に示します。
サブスクライバーが初めて同期されたときに、スナップショットの生成と適用を要求できるようにします。
各パーティションのスナップショットを事前に生成します。
スナップショット エージェントを実行してサブスクライバーごとにスナップショットを手動で生成できます。
Note
アーティクルをフィルター選択して、サブスクリプションごとに一意の重複しないパーティションを取得する場合 (マージ アーティクルの作成時、 F:Microsoft.SqlServer.Replication.PartitionOptions.NonOverlappingSingleSubscription の値に P:Microsoft.SqlServer.Replication.MergeArticle.PartitionOption を指定した場合)、マージ エージェントの実行時に常にメタデータがクリーンアップされます。 これは、パーティション スナップショットの有効期間が短時間で切れてしまうことを意味します。 このオプションを使用する場合は、サブスクライバーからスナップショットの生成を要求できるようにする必要があります。 詳細については、「 Parameterized Row Filters」の「適切なフィルター選択オプションの使用」を参照してください。
重要
可能であれば、実行時、ユーザーに対してセキュリティ資格情報の入力を要求します。 資格情報を保存する必要がある場合は、Microsoft Windows .NET Framework に用意されている 暗号化サービス を使用します。
サブスクライバーでスナップショットの生成と配信を開始するためのパブリケーションを作成するには
ServerConnection クラスを使用して、パブリッシャーへの接続を作成します。
パブリケーション データベースに ReplicationDatabase クラスのインスタンスを作成するには、 ConnectionContext プロパティに手順 1. の ServerConnection インスタンスを設定し、 LoadProperties メソッドを呼び出します。 If LoadProperties から falseが返された場合は、データベースが存在していることを確認してください。
If EnabledMergePublishing プロパティが falseの場合は、このプロパティに \@allow_subscriber_initiated_snapshot を設定して、 CommitPropertyChanges」をご覧ください。
MergePublication クラスのインスタンスを作成し、このオブジェクトに次のプロパティを設定します。
手順 1. の ServerConnection を ConnectionContextに指定します。
パブリッシュするデータベースの名前を DatabaseNameに指定します。
Nameにパブリケーションの名前を指定します。
MaxConcurrentDynamicSnapshotsに、実行する動的スナップショット ジョブの最大数を指定します。 サブスクライバーがスナップショットを要求するタイミングは不定です。そのため、同時に複数のサブスクライバーがパーティション スナップショットを要求した場合に、このプロパティを使って、同時に実行できるスナップショット エージェント ジョブの数を制限します。 実行中のジョブが最大数に達した場合は、パーティション スナップショットに対するそれ以降の要求は、実行されているいずれかのジョブが完了するまでキューに格納されます。
ビットごとの論理和演算 (Visual C# の場合は| 、Visual Basic の場合は Or ) を使用して、 AllowSubscriberInitiatedSnapshot 値を Attributes」をご覧ください。
SnapshotGenerationAgentProcessSecurity の Login および Password フィールドに、スナップショット エージェント ジョブの実行に使用する Microsoft Windows アカウントの資格情報を指定します。
Note
パブリケーションが固定サーバー ロール SnapshotGenerationAgentProcessSecurity のメンバーによって作成された場合、 P:Microsoft.SqlServer.Replication.Publication.SnapshotGenerationAgentProcessSecurity を設定することをお勧めします。 詳細については、「 レプリケーション エージェント セキュリティ モデル」を参照してください。
Create メソッドを呼び出して、パブリケーションを作成します。
重要
リモート ディストリビューターを使用するパブリッシャーを構成する場合は、 SnapshotGenerationAgentProcessSecurityを含むすべてのプロパティに指定された値がディストリビューターにプレーンテキストとして送信されます。 Create メソッドを呼び出す前に、パブリッシャーとリモート ディストリビューター間の接続を暗号化する必要があります。 詳細については、「データベース エンジンへの暗号化接続の有効化 (SQL Server 構成マネージャー)」を参照してください。
MergeArticle プロパティを使用して、アーティクルをパブリケーションに追加します。 パラメーター化されたフィルターを定義する FilterClause プロパティを少なくとも 1 つのアーティクルについて指定します。 (省略可) アーティクル間の結合フィルターを定義する MergeJoinFilter オブジェクトを作成します。 詳しくは、「 アーティクルを定義」をご覧ください。
SnapshotAgentExists の値が false の場合は、CreateSnapshotAgent を呼び出して、このパブリケーション用の初期スナップショット エージェント ジョブを作成します。
手順 4. で作成した StartSnapshotGenerationAgentJob オブジェクトの MergePublication メソッドを呼び出します。 これにより、初期スナップショットを生成するエージェント ジョブが開始されます。 初期スナップショットの作成と、スナップショット エージェントのカスタム スケジュールの定義については、「 Create and Apply the Initial Snapshot」を参照してください。
(省略可) 初期スナップショットが使用できる状態にあるかを調べるには、 \@allow_subscriber_initiated_snapshot プロパティの値が SnapshotAvailable であることを確認します。
サブスクライバーのマージ エージェントの初回接続時に、パーティション スナップショットが自動的に生成されます。
パブリケーションを作成し、スナップショットを事前に生成したり、自動的に更新するには
MergePublication クラスのインスタンスを使用して、マージ パブリケーションを定義します。 詳しくは、「 パブリケーションを作成」をご覧ください。
MergeArticle プロパティを使用して、アーティクルをパブリケーションに追加します。 パラメーター化されたフィルターを定義する FilterClause プロパティを少なくとも 1 つのアーティクルについて指定し、さらに、必要に応じて、アーティクル間の結合フィルターを定義する MergeJoinFilter オブジェクトを作成します。 詳しくは、「 アーティクルを定義」をご覧ください。
SnapshotAgentExists の値が false の場合は、CreateSnapshotAgent を呼び出して、このパブリケーション用のスナップショット エージェント ジョブを作成します。
手順 1. で作成した StartSnapshotGenerationAgentJob オブジェクトの MergePublication メソッドを呼び出します。 このメソッドにより、初期スナップショットを生成するエージェント ジョブが開始されます。 初期スナップショットを生成する方法、およびスナップショット エージェントのカスタム スケジュールを定義する方法については、「 初期スナップショットの作成および適用」を参照してください。
SnapshotAvailable プロパティの値が true であることを確認し、初期スナップショットが使用できる状態にあるかを調べます。
MergePartition クラスのインスタンスを作成し、次のいずれかまたは両方のプロパティを使って、サブスクライバー用のパラメーター化されたフィルター条件を設定します。
サブスクライバーのパーティションが SUSER_SNAME (Transact-SQL) の結果によって定義される場合は、DynamicFilterLogin を使用します。
サブスクライバーのパーティションが HOST_NAME (Transact-SQL) またはこの関数のオーバーロードの結果によって定義される場合は、DynamicFilterHostName を使用します。
MergeDynamicSnapshotJob クラスのインスタンスを作成し、手順 6. と同じプロパティを設定します。
ReplicationAgentSchedule クラスを使用し、サブスクライバーのパーティションに対してフィルター選択されたスナップショットを生成するスケジュールを定義します。
手順 1. で作成した MergePublication のインスタンスを使用して、 AddMergePartitionを呼び出します。 手順 6. の MergePartition オブジェクトを渡します。
手順 1. で作成した MergePublication のインスタンスを使用して、 AddMergeDynamicSnapshotJob メソッドを呼び出します。 このとき、手順 7. の MergeDynamicSnapshotJob オブジェクトと、手順 8. の ReplicationAgentSchedule オブジェクトを引数として指定します。
EnumMergeDynamicSnapshotJobsを呼び出し、返された配列から MergeDynamicSnapshotJob オブジェクトを検索し、パーティション スナップショットを要求するジョブが新たに追加されていないか確認します。
このジョブの Name プロパティを取得します。
ServerConnection クラスを使用して、ディストリビューターへの接続を作成します。
SQL Server 管理オブジェクト (SMO) の Server クラスのインスタンスを作成し、手順 13. の ServerConnection オブジェクトを渡します。
Job クラスのインスタンスを作成し、手順 14. の JobServer オブジェクトの Server プロパティと、手順 12. のジョブ名を渡します。
Start メソッドを呼び出して、パーティション スナップショットを要求するジョブを開始します。
手順 6. から手順 16. を各サブスクライバーについて繰り返します。
パブリケーションを作成し、各パーティションのスナップショットを手動で作成するには
MergePublication クラスのインスタンスを使用して、マージ パブリケーションを定義します。 詳しくは、「 パブリケーションを作成」をご覧ください。
MergeArticle プロパティを使用して、パブリケーションにアーティクルを追加します。パラメーター化されたフィルターを定義する FilterClause プロパティを少なくとも 1 つのアーティクルについて指定し、さらに、必要に応じて、アーティクル間の結合フィルターを定義する MergeJoinFilter オブジェクトを作成します。 詳しくは、「 アーティクルを定義」をご覧ください。
初期スナップショットを生成します。 詳しくは、「 初期スナップショットの作成および適用」をご覧ください。
SnapshotGenerationAgent クラスのインスタンスを作成し、次の必須プロパティを設定します。
Publisher - パブリッシャーの名前
PublisherDatabase - パブリケーション データベースの名前
Publication - パブリケーションの名前
Distributor - ディストリビューターの名前
PublisherSecurityMode - 値 Integrated (Windows 統合認証を使用する場合) または値 Standard (SQL Server 認証を使用する場合)
DistributorSecurityMode - 値 Integrated (Windows 統合認証を使用する場合) または値 Standard (SQL Server 認証を使用する場合)
Merge に ReplicationTypeを設定します。
次に示したプロパティを少なくとも 1 つ設定し、パーティションのパラメーターを定義します。
サブスクライバーのパーティションが SUSER_SNAME (Transact-SQL) の結果によって定義される場合は、DynamicFilterLogin を使用します。
サブスクライバーのパーティションが HOST_NAME (Transact-SQL) またはこの関数のオーバーロードの結果によって定義される場合は、DynamicFilterHostName を使用します。
GenerateSnapshot メソッドを呼び出します。
手順 4. から手順 7. を各サブスクライバーについて繰り返します。
例 (RMO)
次の例では、サブスクライバーがスナップショット生成を要求できるマージ パブリケーションを作成します。
// Set the Publisher, publication database, and publication names.
string publisherName = publisherInstance;
string publicationName = "AdvWorksSalesOrdersMerge";
string publicationDbName = "AdventureWorks2022";
ReplicationDatabase publicationDb;
MergePublication publication;
// Create a connection to the Publisher.
ServerConnection conn = new ServerConnection(publisherName);
try
{
// Connect to the Publisher.
conn.Connect();
// Enable the database for merge publication.
publicationDb = new ReplicationDatabase(publicationDbName, conn);
if (publicationDb.LoadProperties())
{
if (!publicationDb.EnabledMergePublishing)
{
publicationDb.EnabledMergePublishing = true;
}
}
else
{
// Do something here if the database does not exist.
throw new ApplicationException(String.Format(
"The {0} database does not exist on {1}.",
publicationDb, publisherName));
}
// Set the required properties for the merge publication.
publication = new MergePublication();
publication.ConnectionContext = conn;
publication.Name = publicationName;
publication.DatabaseName = publicationDbName;
// Enable precomputed partitions.
publication.PartitionGroupsOption = PartitionGroupsOption.True;
// Specify the Windows account under which the Snapshot Agent job runs.
// This account will be used for the local connection to the
// Distributor and all agent connections that use Windows Authentication.
publication.SnapshotGenerationAgentProcessSecurity.Login = winLogin;
publication.SnapshotGenerationAgentProcessSecurity.Password = winPassword;
// Explicitly set the security mode for the Publisher connection
// Windows Authentication (the default).
publication.SnapshotGenerationAgentPublisherSecurity.WindowsAuthentication = true;
// Enable Subscribers to request snapshot generation and filtering.
publication.Attributes |= PublicationAttributes.AllowSubscriberInitiatedSnapshot;
publication.Attributes |= PublicationAttributes.DynamicFilters;
// Enable pull and push subscriptions.
publication.Attributes |= PublicationAttributes.AllowPull;
publication.Attributes |= PublicationAttributes.AllowPush;
if (!publication.IsExistingObject)
{
// Create the merge publication.
publication.Create();
// Create a Snapshot Agent job for the publication.
publication.CreateSnapshotAgent();
}
else
{
throw new ApplicationException(String.Format(
"The {0} publication already exists.", publicationName));
}
}
catch (Exception ex)
{
// Implement custom application error handling here.
throw new ApplicationException(String.Format(
"The publication {0} could not be created.", publicationName), ex);
}
finally
{
conn.Disconnect();
}
' Set the Publisher, publication database, and publication names.
Dim publisherName As String = publisherInstance
Dim publicationName As String = "AdvWorksSalesOrdersMerge"
Dim publicationDbName As String = "AdventureWorks2022"
Dim publicationDb As ReplicationDatabase
Dim publication As MergePublication
' Create a connection to the Publisher.
Dim conn As ServerConnection = New ServerConnection(publisherName)
Try
' Connect to the Publisher.
conn.Connect()
' Enable the database for merge publication.
publicationDb = New ReplicationDatabase(publicationDbName, conn)
If publicationDb.LoadProperties() Then
If Not publicationDb.EnabledMergePublishing Then
publicationDb.EnabledMergePublishing = True
End If
Else
' Do something here if the database does not exist.
Throw New ApplicationException(String.Format( _
"The {0} database does not exist on {1}.", _
publicationDb, publisherName))
End If
' Set the required properties for the merge publication.
publication = New MergePublication()
publication.ConnectionContext = conn
publication.Name = publicationName
publication.DatabaseName = publicationDbName
' Enable precomputed partitions.
publication.PartitionGroupsOption = PartitionGroupsOption.True
' Specify the Windows account under which the Snapshot Agent job runs.
' This account will be used for the local connection to the
' Distributor and all agent connections that use Windows Authentication.
publication.SnapshotGenerationAgentProcessSecurity.Login = winLogin
publication.SnapshotGenerationAgentProcessSecurity.Password = winPassword
' Explicitly set the security mode for the Publisher connection
' Windows Authentication (the default).
publication.SnapshotGenerationAgentPublisherSecurity.WindowsAuthentication = True
' Enable Subscribers to request snapshot generation and filtering.
publication.Attributes = publication.Attributes Or _
PublicationAttributes.AllowSubscriberInitiatedSnapshot
publication.Attributes = publication.Attributes Or _
PublicationAttributes.DynamicFilters
' Enable pull and push subscriptions
publication.Attributes = publication.Attributes Or _
PublicationAttributes.AllowPull
publication.Attributes = publication.Attributes Or _
PublicationAttributes.AllowPush
If Not publication.IsExistingObject Then
' Create the merge publication.
publication.Create()
' Create a Snapshot Agent job for the publication.
publication.CreateSnapshotAgent()
Else
Throw New ApplicationException(String.Format( _
"The {0} publication already exists.", publicationName))
End If
Catch ex As Exception
' Implement custom application error handling here.
Throw New ApplicationException(String.Format( _
"The publication {0} could not be created.", publicationName), ex)
Finally
conn.Disconnect()
End Try
次の例では、手動でサブスクライバーのパーティションを作成し、さらに、パラメーター化された行フィルターを使って、マージ パブリケーションのフィルター選択されたスナップショットを作成します。
// Define the server, database, and publication names
string publisherName = publisherInstance;
string publicationName = "AdvWorksSalesOrdersMerge";
string publicationDbName = "AdventureWorks2022";
string distributorName = publisherInstance;
MergePublication publication;
MergePartition partition;
MergeDynamicSnapshotJob snapshotAgentJob;
ReplicationAgentSchedule schedule;
// Create a connection to the Publisher.
ServerConnection publisherConn = new ServerConnection(publisherName);
// Create a connection to the Distributor to start the Snapshot Agent.
ServerConnection distributorConn = new ServerConnection(distributorName);
try
{
// Connect to the Publisher.
publisherConn.Connect();
// Set the required properties for the publication.
publication = new MergePublication();
publication.ConnectionContext = publisherConn;
publication.Name = publicationName;
publication.DatabaseName = publicationDbName;
// If we can't get the properties for this merge publication,
// then throw an application exception.
if (publication.LoadProperties() || publication.SnapshotAvailable)
{
// Set a weekly schedule for the filtered data snapshot.
schedule = new ReplicationAgentSchedule();
schedule.FrequencyType = ScheduleFrequencyType.Weekly;
schedule.FrequencyRecurrenceFactor = 1;
schedule.FrequencyInterval = Convert.ToInt32(0x001);
// Set the value of Hostname that defines the data partition.
partition = new MergePartition();
partition.DynamicFilterHostName = hostname;
snapshotAgentJob = new MergeDynamicSnapshotJob();
snapshotAgentJob.DynamicFilterHostName = hostname;
// Create the partition for the publication with the defined schedule.
publication.AddMergePartition(partition);
publication.AddMergeDynamicSnapshotJob(snapshotAgentJob, schedule);
}
else
{
throw new ApplicationException(String.Format(
"Settings could not be retrieved for the publication, " +
" or the initial snapshot has not been generated. " +
"Ensure that the publication {0} exists on {1} and " +
"that the Snapshot Agent has run successfully.",
publicationName, publisherName));
}
}
catch (Exception ex)
{
// Do error handling here.
throw new ApplicationException(string.Format(
"The partition for '{0}' in the {1} publication could not be created.",
hostname, publicationName), ex);
}
finally
{
publisherConn.Disconnect();
if (distributorConn.IsOpen) distributorConn.Disconnect();
}
' Define the server, database, and publication names
Dim publisherName As String = publisherInstance
Dim publicationName As String = "AdvWorksSalesOrdersMerge"
Dim publicationDbName As String = "AdventureWorks2022"
Dim distributorName As String = publisherInstance
Dim publication As MergePublication
Dim partition As MergePartition
Dim snapshotAgentJob As MergeDynamicSnapshotJob
Dim schedule As ReplicationAgentSchedule
' Create a connection to the Publisher.
Dim publisherConn As ServerConnection = New ServerConnection(publisherName)
' Create a connection to the Distributor to start the Snapshot Agent.
Dim distributorConn As ServerConnection = New ServerConnection(distributorName)
Try
' Connect to the Publisher.
publisherConn.Connect()
' Set the required properties for the publication.
publication = New MergePublication()
publication.ConnectionContext = publisherConn
publication.Name = publicationName
publication.DatabaseName = publicationDbName
' If we can't get the properties for this merge publication,
' then throw an application exception.
If (publication.LoadProperties() Or publication.SnapshotAvailable) Then
' Set a weekly schedule for the filtered data snapshot.
schedule = New ReplicationAgentSchedule()
schedule.FrequencyType = ScheduleFrequencyType.Weekly
schedule.FrequencyRecurrenceFactor = 1
schedule.FrequencyInterval = Convert.ToInt32("0x001", 16)
' Set the value of Hostname that defines the data partition.
partition = New MergePartition()
partition.DynamicFilterHostName = hostname
snapshotAgentJob = New MergeDynamicSnapshotJob()
snapshotAgentJob.DynamicFilterHostName = hostname
' Create the partition for the publication with the defined schedule.
publication.AddMergePartition(partition)
publication.AddMergeDynamicSnapshotJob(snapshotAgentJob, schedule)
Else
Throw New ApplicationException(String.Format( _
"Settings could not be retrieved for the publication, " + _
" or the initial snapshot has not been generated. " + _
"Ensure that the publication {0} exists on {1} and " + _
"that the Snapshot Agent has run successfully.", _
publicationName, publisherName))
End If
Catch ex As Exception
' Do error handling here.
Throw New ApplicationException(String.Format( _
"The partition for '{0}' in the {1} publication could not be created.", _
hostname, publicationName), ex)
Finally
publisherConn.Disconnect()
If distributorConn.IsOpen Then
distributorConn.Disconnect()
End If
End Try
次の例では、手動でスナップショット エージェントを起動し、パラメーター化された行フィルターを使って、マージ パブリケーションのサブスクライバー用にフィルター選択されたデータ スナップショットを生成します。
// Set the Publisher, publication database, and publication names.
string publicationName = "AdvWorksSalesOrdersMerge";
string publicationDbName = "AdventureWorks2022";
string publisherName = publisherInstance;
string distributorName = publisherInstance;
SnapshotGenerationAgent agent;
try
{
// Set the required properties for Snapshot Agent.
agent = new SnapshotGenerationAgent();
agent.Distributor = distributorName;
agent.DistributorSecurityMode = SecurityMode.Integrated;
agent.Publisher = publisherName;
agent.PublisherSecurityMode = SecurityMode.Integrated;
agent.Publication = publicationName;
agent.PublisherDatabase = publicationDbName;
agent.ReplicationType = ReplicationType.Merge;
// Specify the partition information to generate a
// filtered snapshot based on Hostname.
agent.DynamicFilterHostName = hostname;
// Start the agent synchronously.
agent.GenerateSnapshot();
}
catch (Exception ex)
{
// Implement custom application error handling here.
throw new ApplicationException(String.Format(
"A snapshot could not be generated for the {0} publication."
, publicationName), ex);
}
' Set the Publisher, publication database, and publication names.
Dim publicationName As String = "AdvWorksSalesOrdersMerge"
Dim publicationDbName As String = "AdventureWorks2022"
Dim publisherName As String = publisherInstance
Dim distributorName As String = publisherInstance
Dim agent As SnapshotGenerationAgent
Try
' Set the required properties for Snapshot Agent.
agent = New SnapshotGenerationAgent()
agent.Distributor = distributorName
agent.DistributorSecurityMode = SecurityMode.Integrated
agent.Publisher = publisherName
agent.PublisherSecurityMode = SecurityMode.Integrated
agent.Publication = publicationName
agent.PublisherDatabase = publicationDbName
agent.ReplicationType = ReplicationType.Merge
' Specify the partition information to generate a
' filtered snapshot based on Hostname.
agent.DynamicFilterHostName = hostname
' Start the agent synchronously.
agent.GenerateSnapshot()
Catch ex As Exception
' Implement custom application error handling here.
Throw New ApplicationException(String.Format( _
"A snapshot could not be generated for the {0} publication." _
, publicationName), ex)
End Try
参照
パラメーター化された行フィルター
Replication System Stored Procedures Concepts
レプリケーション セキュリティの推奨事項
フィードバック
以下は間もなく提供いたします。2024 年を通じて、コンテンツのフィードバック メカニズムとして GitHub の issue を段階的に廃止し、新しいフィードバック システムに置き換えます。 詳細については、「https://aka.ms/ContentUserFeedback」を参照してください。
フィードバックの送信と表示