パラメーター化されたフィルターを使用したパブリケーションのスナップショットの作成

[アーティクル]
06/18/2013

このトピックでは、SQL Server 2012 で SQL Server Management Studio、Transact-SQL、またはレプリケーション管理オブジェクト (RMO) を使用して、パラメーター化されたフィルターでマージパブリケーションのスナップショットを作成する方法ついて説明します。

このトピックの内容

作業を開始する準備:

推奨事項
パラメーター化されたフィルターを使用してマージパブリケーションのスナップショットを作成するために使用するもの:

SQL Server Management Studio

Transact-SQL

レプリケーション管理オブジェクト (RMO)

作業を開始する準備

推奨事項

パラメーター化されたフィルターを使用してマージパブリケーションのスナップショットを生成する際には、最初にすべてのパブリッシュ済みデータとサブスクリプションのサブスクライバーメタデータを含む標準 (スキーマ) スナップショットを生成する必要があります。詳細については、「初期スナップショットの作成および適用」を参照してください。スキーマスナップショットを作成した後で、パブリッシュ済みデータのサブスクライバー固有のパーティションを含むスナップショットを作成できます。
パブリケーション内の 1 つ以上のアーティクルにフィルターを適用して、各サブスクリプション固有の重複しないパーティションが得られる場合、マージエージェントが実行されるたびにメタデータがクリーンアップされます。これは、パーティションスナップショットの有効期限が短いことを意味しています。このオプションを使用する場合は、サブスクライバーに対してスナップショットの生成と配信を許可することを検討する必要があります。フィルターオプションの詳細については、「パラメーター化されたフィルターを使用したマージパブリケーションのスナップショット」の「[パーティションのオプション] の設定」を参照してください。

[トップに戻る] リンクで使用される矢印アイコン [Top]

SQL Server Management Studio の使用

[パブリケーションのプロパティ - <Publication>] ダイアログボックスの [データパーティション] ページでパーティションのスナップショットを作成します。このダイアログボックスへのアクセスの詳細については、「パブリケーションプロパティの表示および変更」を参照してください。サブスクライバーには、スナップショットの生成と配信の開始や、スナップショットの生成を許可できます。

1 つ以上のパーティションに対してスナップショットを生成する前に、以下の作業を行う必要があります。

新規パブリーケーションウィザードを使用してマージパブリケーションを作成し、ウィザードの [フィルターの追加] ページで 1 つ以上のパラメーター化された行フィルターを指定します。詳細については、「マージアーティクルのパラメーター化された行フィルターの定義および変更」を参照してください。
パブリケーションのスキーマスナップショットを生成します。既定では、新規パブリケーションウィザードが完了すると、スキーマスナップショットが生成されます。また、SQL Server Management Studio からスキーマスナップショットを生成することもできます。

スキーマスナップショットを生成するには

Management Studio でパブリッシャーに接続し、サーバーノードを展開します。
[レプリケーション] フォルダーを展開し、[パブリケーション] フォルダーを展開します。
スナップショットを作成するパブリケーションを右クリックして、[スナップショットエージェントの状態の表示] をクリックします。
[スナップショットエージェントの状態の表示 - <Publication>] ダイアログボックスで [開始] をクリックします。

スナップショットエージェントによるスナップショットの生成が完了すると、"[100%] 17 個のアーティクルのスナップショットが生成されました。" などのメッセージが表示されます。

サブスクライバーにスナップショットの生成と配信を許可するには

[パブリケーションのプロパティ - <Publication>] ダイアログボックスの [データパーティション] ページで、[新規サブスクライバーで同期を行うとき、パーティションを自動的に定義し、必要に応じてスナップショットを生成する] を選択します。
[OK] をクリックします。

スナップショットの生成と更新を行うには

[パブリケーションのプロパティ - <Publication>] ダイアログボックスの [データパーティション] ページで [追加] をクリックします。
スナップショットを作成するパーティションに関連付けられた HOST_NAME() と SUSER_SNAME() に値を入力します。
オプションでスナップショットの更新スケジュールを指定します。
1. [以下のスケジュールでこのパーティションのスナップショットエージェントを実行する] を選択します。
2. スナップショットの既定の更新スケジュールをそのまま使用するか、または [変更] をクリックして別のスケジュールを指定します。
[OK] をクリックして、[パブリケーションのプロパティ - <Publication>] ダイアログボックスに戻ります。
プロパティグリッドでパーティションを選択し、[今すぐ選択したスナップショットを生成する] をクリックします。
[OK] をクリックします。

[トップに戻る] リンクで使用される矢印アイコン [Top]

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 ログイン情報を指定する必要があります。これにより、パブリケーション用のスナップショットエージェントジョブが作成されます。初期スナップショットの作成と、スナップショットエージェントのカスタムスケジュールの定義については、「初期スナップショットの作成および適用」を参照してください。

セキュリティに関する注意
リモートディストリビューターを使用するパブリッシャーを構成する場合は、job_login および job_password を含むすべてのパラメーターに指定された値がディストリビューターにプレーンテキストとして送信されます。このストアドプロシージャを実行する前に、パブリッシャーとそのリモートディストリビューター間の接続を暗号化する必要があります。詳細については、「データベースエンジンへの暗号化接続の有効化 (SQL Server 構成マネージャー)」を参照してください。

リモートディストリビューターを使用するパブリッシャーを構成する場合は、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 ログイン情報を指定する必要があります。これにより、パブリケーション用のスナップショットエージェントジョブが作成されます。初期スナップショットの作成と、スナップショットエージェントのカスタムスケジュールの定義については、「初期スナップショットの作成および適用」を参照してください。

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 を指定します。

セキュリティに関する注意
リモートディストリビューターを使用するパブリッシャーを構成する場合は、job_login および job_password を含むすべてのパラメーターに指定された値がディストリビューターにプレーンテキストとして送信されます。このストアドプロシージャを実行する前に、パブリッシャーとそのリモートディストリビューター間の接続を暗号化する必要があります。詳細については、「データベースエンジンへの暗号化接続の有効化 (SQL Server 構成マネージャー)」を参照してください。

パブリッシャー側のパブリケーションデータベースに対して、sp_adddynamicsnapshot_job (Transact-SQL) を実行します。手順 1. のパブリケーション名を @publication に指定します。手順 8. で使用した @suser_sname または @host_name の値を指定し、ジョブのスケジュールを指定します。これにより、指定されたパーティションにパラメーター化スナップショットを生成するジョブが作成されます。詳細については、「同期スケジュールの指定」を参照してください。

注
このジョブは、手順 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_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 - このパーティションの動的スナップショットの場所。

セキュリティに関する注意
リモートディストリビューターを使用するパブリッシャーを構成する場合は、job_login および job_password を含むすべてのパラメーターに指定された値がディストリビューターにプレーンテキストとして送信されます。このストアドプロシージャを実行する前に、パブリッシャーとそのリモートディストリビューター間の接続を暗号化する必要があります。詳細については、「データベースエンジンへの暗号化接続の有効化 (SQL Server 構成マネージャー)」を参照してください。

注
レプリケーションエージェントのプログラミングの詳細については、「レプリケーションエージェント実行可能ファイルの概念」を参照してください。

例 (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'AdventureWorks2012';
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 [AdventureWorks2012];

-- Enable AdventureWorks2012 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 AdventureWorks2012.', 
  @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'AdventureWorks2012';
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 [AdventureWorks2012];

-- Enable AdventureWorks2012 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 AdventureWorks2012.', 
  @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'AdventureWorks2012';
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 [AdventureWorks2012];

-- Enable AdventureWorks2012 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 AdventureWorks2012.', 
  @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=AdventureWorks2012 
SET PubName=AdvWorksSalesPersonMerge

"C:\Program Files\Microsoft SQL Server\110\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=AdventureWorks2012 
SET PubName=AdvWorksSalesPersonMerge
SET SnapshotDir=\\%DistPub%\repldata\unc\fernando

MD %SnapshotDir%

"C:\Program Files\Microsoft SQL Server\110\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 = AdventureWorks2012 
SET SubDB = AdventureWorks2012Replica 
SET PubName = AdvWorksSalesPersonMerge 
SET SnapshotDir=\\%DistPub%\repldata\unc\fernando

"C:\Program Files\Microsoft SQL Server\110\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

[トップに戻る] リンクで使用される矢印アイコン [Top]

レプリケーション管理オブジェクト (RMO) の使用

パーティションスナップショットは、プログラムからレプリケーション管理オブジェクト (RMO) を使用して生成できます。その方法を次に示します。

サブスクライバーが最初に同期するときに、スナップショットの生成と適用を要求できます。
各パーティションのスナップショットを事前に生成できます。
スナップショットエージェントを実行してサブスクライバーごとにスナップショットを手動で生成できます。

注
アーティクルをフィルター選択して、サブスクリプションごとに一意の重複しないパーティションを取得する場合 (マージアーティクルの作成時、PartitionOption の値に NonOverlappingSingleSubscription を指定した場合)、マージエージェントの実行時に常にメタデータがクリーンアップされます。これは、パーティションスナップショットの有効期間が短時間で切れてしまうことを意味します。このオプションを使用する場合は、サブスクライバーからスナップショットの生成を要求できるようにする必要があります。詳細については、「パラメーター化された行フィルター」の「適切なフィルター選択オプションの使用」を参照してください。

アーティクルをフィルター選択して、サブスクリプションごとに一意の重複しないパーティションを取得する場合 (マージアーティクルの作成時、PartitionOption の値に NonOverlappingSingleSubscription を指定した場合)、マージエージェントの実行時に常にメタデータがクリーンアップされます。これは、パーティションスナップショットの有効期間が短時間で切れてしまうことを意味します。このオプションを使用する場合は、サブスクライバーからスナップショットの生成を要求できるようにする必要があります。詳細については、「パラメーター化された行フィルター」の「適切なフィルター選択オプションの使用」を参照してください。

セキュリティに関する注意
可能であれば、実行時に、ユーザーに対してセキュリティ資格情報の入力を求めるメッセージを表示します。資格情報を保存する必要がある場合は、Microsoft Windows .NET Framework に用意されている暗号化サービスを使用します。

サブスクライバーでスナップショットの生成と配信を開始するためのパブリケーションを作成するには

ServerConnection クラスを使用して、パブリッシャーへの接続を作成します。
パブリケーションデータベースに ReplicationDatabase クラスのインスタンスを作成するには、ConnectionContext プロパティに手順 1. の ServerConnection インスタンスを設定し、LoadProperties メソッドを呼び出します。 LoadProperties から false が返された場合は、データベースが存在していることを確認してください。
EnabledMergePublishing プロパティが false の場合は、このプロパティに true を設定して、CommitPropertyChanges を呼び出します。

MergePublication クラスのインスタンスを作成し、このオブジェクトに次のプロパティを設定します。

手順 1. の ServerConnection を ConnectionContext に指定します。
パブリッシュするデータベースの名前を DatabaseName に指定します。
Name にパブリケーションの名前を指定します。
MaxConcurrentDynamicSnapshots に、実行する動的スナップショットジョブの最大数を指定します。サブスクライバーがスナップショットを要求するタイミングは不定です。そのため、同時に複数のサブスクライバーがパーティションスナップショットを要求した場合に、このプロパティを使って、同時に実行できるスナップショットエージェントジョブの数を制限します。実行中のジョブが最大数に達した場合は、パーティションスナップショットに対するそれ以降の要求は、実行されているいずれかのジョブが完了するまでキューに格納されます。
ビットごとの論理 OR (| (Visual C#) および Or (Visual Basic)) 演算子を使用して、値 AllowSubscriberInitiatedSnapshot を Attributes に追加します。

SnapshotGenerationAgentProcessSecurity の Login フィールドおよび Password フィールドに、スナップショットエージェントジョブの実行に使用する Microsoft Windows アカウントの資格情報を指定します。

注
パブリケーションが固定サーバーロール sysadmin のメンバーによって作成された場合、SnapshotGenerationAgentProcessSecurity を設定することをお勧めします。詳細については、「レプリケーションエージェントのセキュリティモデル」を参照してください。

Create メソッドを呼び出して、パブリケーションを作成します。

セキュリティに関する注意
リモートディストリビューターを使用するパブリッシャーを構成する場合は、SnapshotGenerationAgentProcessSecurity を含むすべてのプロパティに指定された値がディストリビューターにプレーンテキストとして送信されます。 Create メソッドを呼び出す前に、パブリッシャーとそのリモートディストリビューター間の接続を暗号化する必要があります。詳細については、「データベースエンジンへの暗号化接続の有効化 (SQL Server 構成マネージャー)」を参照してください。

リモートディストリビューターを使用するパブリッシャーを構成する場合は、SnapshotGenerationAgentProcessSecurity を含むすべてのプロパティに指定された値がディストリビューターにプレーンテキストとして送信されます。 Create メソッドを呼び出す前に、パブリッシャーとそのリモートディストリビューター間の接続を暗号化する必要があります。詳細については、「データベースエンジンへの暗号化接続の有効化 (SQL Server 構成マネージャー)」を参照してください。

MergeArticle プロパティを使用して、アーティクルをパブリケーションに追加します。パラメーター化されたフィルターを定義する FilterClause プロパティを少なくとも 1 つのアーティクルについて指定します。 (省略可) アーティクル間の結合フィルターを定義する MergeJoinFilter オブジェクトを作成します。詳細については、「アーティクルの定義」を参照してください。
SnapshotAgentExists の値が false の場合は、CreateSnapshotAgent を呼び出して、このパブリケーション用の初期スナップショットエージェントジョブを作成します。
手順 4. で作成した MergePublication オブジェクトの StartSnapshotGenerationAgentJob メソッドを呼び出します。これにより、初期スナップショットを生成するエージェントジョブが開始されます。初期スナップショットの作成と、スナップショットエージェントのカスタムスケジュールの定義については、「初期スナップショットの作成および適用」を参照してください。
(省略可) 初期スナップショットが使用できる状態にあるかを調べるには、SnapshotAvailable プロパティの値が true であることを確認します。
サブスクライバーのマージエージェントの初回接続時に、パーティションスナップショットが自動的に生成されます。

パブリケーションを作成し、スナップショットを事前に生成したり、自動的に更新するには

MergePublication クラスのインスタンスを使用して、マージパブリケーションを定義します。詳細については、「パブリケーションの作成」を参照してください。
MergeArticle プロパティを使用して、アーティクルをパブリケーションに追加します。パラメーター化されたフィルターを定義する FilterClause プロパティを少なくとも 1 つのアーティクルについて指定し、さらに、必要に応じて、アーティクル間の結合フィルターを定義する MergeJoinFilter オブジェクトを作成します。詳細については、「アーティクルの定義」を参照してください。
SnapshotAgentExists の値が false の場合は、CreateSnapshotAgent を呼び出して、このパブリケーション用のスナップショットエージェントジョブを作成します。
手順 1. で作成した MergePublication オブジェクトの StartSnapshotGenerationAgentJob メソッドを呼び出します。このメソッドにより、初期スナップショットを生成するエージェントジョブが開始されます。初期スナップショットを生成する方法、およびスナップショットエージェントのカスタムスケジュールを定義する方法については、「初期スナップショットの作成および適用」を参照してください。
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. の Server オブジェクトの JobServer プロパティと、手順 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 認証を使用する場合)
ReplicationType に Merge を設定します。
次に示したプロパティを少なくとも 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 = "AdventureWorks2012";

            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 = "AdventureWorks2012"

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 = "AdventureWorks2012";
            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 = "AdventureWorks2012"
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 = "AdventureWorks2012";
            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 = "AdventureWorks2012"
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

[トップに戻る] リンクで使用される矢印アイコン [Top]

Share via

パラメーター化されたフィルターを使用したパブリケーションのスナップショットの作成

作業を開始する準備

推奨事項

SQL Server Management Studio の使用

スキーマスナップショットを生成するには

サブスクライバーにスナップショットの生成と配信を許可するには

スナップショットの生成と更新を行うには

Transact-SQL の使用

サブスクライバーでスナップショットの生成と配信を開始するためのパブリケーションを作成するには

パブリケーションを作成し、スナップショットを事前に生成、または自動更新するには

パブリケーションを作成し、各パーティションのスナップショットを手動で作成するには

例 (Transact-SQL)

レプリケーション管理オブジェクト (RMO) の使用

サブスクライバーでスナップショットの生成と配信を開始するためのパブリケーションを作成するには

パブリケーションを作成し、スナップショットを事前に生成したり、自動的に更新するには

パブリケーションを作成し、各パーティションのスナップショットを手動で作成するには

例 (RMO)

関連項目

概念

その他のリソース

Share via

パラメーター化されたフィルターを使用したパブリケーションのスナップショットの作成

作業を開始する準備

推奨事項

SQL Server Management Studio の使用

スキーマ スナップショットを生成するには

サブスクライバーにスナップショットの生成と配信を許可するには

スナップショットの生成と更新を行うには

Transact-SQL の使用

サブスクライバーでスナップショットの生成と配信を開始するためのパブリケーションを作成するには

パブリケーションを作成し、スナップショットを事前に生成、または自動更新するには

パブリケーションを作成し、各パーティションのスナップショットを手動で作成するには

例 (Transact-SQL)

レプリケーション管理オブジェクト (RMO) の使用

サブスクライバーでスナップショットの生成と配信を開始するためのパブリケーションを作成するには

パブリケーションを作成し、スナップショットを事前に生成したり、自動的に更新するには

パブリケーションを作成し、各パーティションのスナップショットを手動で作成するには

例 (RMO)

関連項目

概念

その他のリソース

スキーマスナップショットを生成するには