マージ アーティクルのパラメーター化された行フィルターの定義および変更

適用対象:SQL Server

このトピックでは、SQL Server で SQL Server Management Studio または Transact-SQL を使用して、パラメーター化された行フィルターを定義して修正する方法について説明します。

テーブル アーティクルを作成する際には、パラメーター化された行フィルターを使用できます。 このフィルターでは WHERE 句を使用して、パブリッシュする適切なデータを選択します。 静的行フィルターのようにこの句でリテラル値を指定するのではなく、システム関数 SUSER_SNAME および HOST_NAMEのいずれかまたは両方を指定します。 詳しくは、「 Parameterized Row Filters」をご覧ください。

このトピックの内容

• 作業を開始する準備:

  制限事項と制約事項

• パラメーター化された行フィルターを定義または変更するために使用するもの:

  SQL Server Management Studio

  Transact-SQL

はじめに

制限事項と制約事項

• パブリケーションに対するサブスクリプションが初期化された後に、パラメーター化された行フィルターを追加、変更、または削除した場合は、変更を行った後で、新しいスナップショットを生成し、すべてのサブスクリプションを再初期化する必要があります。 プロパティ変更の要件の詳細については、「Change Publication and Article Properties」(パブリケーションとアーティクルのプロパティの変更) をご覧ください。

推奨事項

• パラメーター化された行フィルター句では列名に関数を適用しないことをお勧めします。これは、 LEFT([MyColumn]) = SUSER_SNAME()のように指定すると、パフォーマンスに問題が生じるためです。 フィルター句で HOST_NAME を使用していて、HOST_NAME 値をオーバーライドする場合は、CONVERT を使用するデータ型の変換が必要になる可能性があります。 このようなケースの推奨事項の詳細については、「Parameterized Row Filters」の「HOST_NAME() 値のオーバーライド」をご覧ください。

SQL Server Management Studio を使用する

パブリケーションの新規作成ウィザードの [テーブル行のフィルター選択] ページ、または [パブリケーションのプロパティ - <パブリケーション]> ダイアログ ボックスの [行のフィルター選択] ページで、パラメーター化された行フィルターを定義、変更、または削除します。 ウィザードの使用およびダイアログ ボックスへのアクセスの詳細については、「パブリケーションの作成」および「View and Modify Publication Properties」 (パブリケーション プロパティの表示および変更) を参照してください。

パラメーター化された行フィルターを定義するには

1. パブリケーションの新規作成ウィザードの [テーブル行のフィルター選択] ページ、または [パブリケーションのプロパティ - <パブリケーション]> ダイアログ ボックスの [行のフィルター選択] ページで、[追加] をクリックし、次に [フィルターの追加] をクリックします。

2. [フィルターの追加] ダイアログ ボックスで、ドロップダウン リスト ボックスからフィルター選択するテーブルを選択します。

3. [フィルター ステートメント] テキスト ボックスで、フィルター ステートメントを作成します。 テキスト領域に直接入力することも、 [列] ボックスから列をドラッグ アンド ドロップすることもできます。

   • [フィルター ステートメント] テキスト領域には、次の形式の既定のテキストが表示されます。

     SELECT <published_columns> FROM [tableowner].[tablename] WHERE  
     

   • 既定のテキストは変更できません。標準の SQL 構文を使用して WHERE キーワードの後にフィルター句を入力してください。 パラメーター化されたフィルターには、システム関数 HOST_NAME() および SUSER_SNAME()の呼び出し、あるいは、これらの関数のいずれかまたは両方を参照するユーザー定義関数の呼び出しが含まれています。 パラメーター化された行フィルターの完全なフィルター句の例を次に示します。

     SELECT <published_columns> FROM [HumanResources].[Employee] WHERE LoginID = SUSER_SNAME()  
     

     WHERE 句には、2 つの部分で構成されている名前を使用する必要があります。3 つまたは 4 つの部分で構成されている名前の使用はサポートされていません。

4. 複数のサブスクライバー間でのデータの共有方法に一致するオプションを選択します。

   • [このテーブルの 1 行を複数のサブスクリプションに移動する]

   • [このテーブルの 1 行を 1 つのサブスクリプションのみに移動する]

   [このテーブルの 1 行を 1 つのサブスクリプションのみに移動する]を選択すると、マージ レプリケーションは、格納および処理するメタデータを減らすことにより、パフォーマンスを最適化できます。 ただし、データのパーティション分割によって、1 つの行が複数のサブスクライバーにレプリケートされないことを確認する必要があります。 詳細については、「 パラメーター化された行フィルター」トピックの「[パーティションのオプション] の設定」をご覧ください。

5. [OK] を選択します。

6. [パブリケーションのプロパティ - <パブリケーション]> ダイアログ ボックスが表示されている場合は、[OK] をクリックして保存し、ダイアログ ボックスを閉じます。

パラメーター化された行フィルターを変更するには

1. パブリケーションの新規作成ウィザードの [テーブル行のフィルター選択] ページ、または [パブリケーションのプロパティ - <パブリケーション]> の [行のフィルター選択] ページで、[フィルター選択されたテーブル] ペイン内のフィルターを選択し、[編集] をクリックします。

2. [フィルターの編集] ダイアログ ボックスで、フィルターを変更します。

3. [OK] を選択します。

パラメーター化された行フィルターを削除するには

1. パブリケーションの新規作成ウィザードの [テーブル行のフィルター選択] ページ、または [パブリケーションのプロパティ - <パブリケーション]> の [行のフィルター選択] ページで、[フィルター選択されたテーブル] ペイン内のフィルターを選択し、[削除] をクリックします。

Transact-SQL の使用

パラメーター化された行フィルターは、レプリケーション ストアド プロシージャを使用してプログラムから作成し、変更できます。

マージ パブリケーション内のアーティクルにパラメーター化された行フィルターを定義するには

1. パブリッシャー側のパブリケーション データベースに対して、sp_addmergearticle (Transact-SQL) を実行します。 @publicationを指定し、アーティクルの名前を @articleに、パブリッシュするテーブルを @source_objectに、パラメーター化されたフィルターを定義する WHERE 句 ( は含めません) を @subset_filterclause WHEREに指定します。 @partition_optionsに次のいずれかの値を指定します。これにより、パラメーター化された行フィルターによって行われるパーティション分割の種類が指定されます。

   • 0 - アーティクルのフィルター選択が静的であるか、各パーティションに対して一意なデータのサブセットは生成されません ("重複する" パーティション)。

   • 1 - 生成されるパーティションは重複しており、サブスクライバーでの更新によって行が属しているパーティションを変更することはできません。

   • 2 - アーティクルのフィルター選択によって重複しないパーティションが生成されますが、複数のサブスクライバーが同じパーティションを受け取ることができます。

   • 3 - アーティクルのフィルター選択によって、各サブスクリプションで一意な重複しないパーティションが生成されます。

マージ パブリケーション内のアーティクルに適用するパラメーター化された行フィルターを変更するには

1. パブリッシャー側のパブリケーション データベースに対して、 sp_changemergearticleを実行します。 @publication と @article を指定し、subset_filterclause を @property に、パラメーター化されたフィルターを定義する式 (WHERE は含めません) を @value に指定し、@force_invalidate_snapshot と @force_reinit_subscription に 1 を指定します。

2. この変更によって別のパーティション分割が発生した場合、 sp_changemergearticle を再び実行します。 @publicationと @articleを指定し、 partition_options を @propertyに指定します。次の中から最も適切なパーティション分割オプションを @valueに指定します。

   • 0 - アーティクルのフィルター選択が静的であるか、各パーティションに対して一意なデータのサブセットは生成されません ("重複する" パーティション)。

   • 1 - 生成されるパーティションは重複しており、サブスクライバーでの更新によって行が属しているパーティションを変更することはできません。

   • 2 - アーティクルのフィルター選択によって重複しないパーティションが生成されますが、複数のサブスクライバーが同じパーティションを受け取ることができます。

   • 3 - アーティクルのフィルター選択によって、各サブスクリプションで一意な重複しないパーティションが生成されます。

例 (Transact-SQL)

次の例では、 Employee テーブルに対して一連の結合フィルターを使用してアーティクルがフィルター選択されるマージ パブリケーションで、アーティクルのグループを定義します。このテーブル自体はパラメーター化された行フィルターを LoginID 列に使用してフィルター選択されています。 同期の間、HOST_NAME 関数により返される値はオーバーライドされます。 詳細については、「 Parameterized Row Filters」の「HOST_NAME() 値のオーバーライド」をご覧ください。

-- 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

参照

マージ アーティクル間の結合フィルターの定義および変更
パブリケーションおよびアーティクルのプロパティの変更
結合フィルター
パラメーター化された行フィルター