通过

定义和修改合并项目的参数化行筛选器

  • 项目

适用于：SQL Server

本主题介绍如何使用 SQL Server Management Studio 或 Transact-SQL 在 SQL Server 中定义和修改参数化行筛选器。

在创建表项目时，可以使用参数化行筛选器。 这些筛选器使用 WHERE 子句来选择要发布的相应数据。 不要在该子句中指定文字值（像在静态行筛选器中那样），而是指定以下一个或两个系统函数： SUSER_SNAME 和 HOST_NAME。 有关详细信息，请参阅 参数化行筛选器。

本主题内容

开始之前

限制和局限

  • 如果在初始化对发布的订阅后添加、修改或删除参数化行筛选器，必须在更改后生成新的快照并重新初始化所有订阅。 有关属性更改要求的详细信息，请参阅更改发布和项目属性。

建议

  • 出于性能方面的考虑，我们建议您不要将这些函数应用于参数化行筛选器子句（如 LEFT([MyColumn]) = SUSER_SNAME()）中的列名。 如果在筛选子句中使用 HOST_NAME 并覆盖 HOST_NAME 值，则可能需要使用 CONVERT 转换数据类型。 有关此情况的最佳实践的详细信息，请参阅主题 Parameterized Row Filters中的“覆盖 HOST_NAME() 值”一节。

使用 SQL Server Management Studio

可在新建发布向导的“筛选表行”页或“发布属性 - <发布>”对话框的“筛选行”页上定义、修改和删除参数化行筛选器。 有关如何使用该向导和如何访问该对话框的详细信息，请参阅创建发布和查看和修改发布属性。

定义参数化行筛选器

  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 子句应使用由两部分构成的命名方式，不支持由三部分和四部分构成的命名方式。

  4. 选择指示订阅服务器之间如何共享数据的选项：

    • 此表中的行将转到多个订阅

    • 此表中的行将仅转到一个订阅

    如果选择 “此表中的行将仅转到一个订阅”，则合并复制可以通过存储和处理较少的元数据来优化性能。 但是，必须确保在对数据分区时不能将行复制到多个订阅服务器。 有关详细信息，请参阅主题 参数化行筛选器中的“设置‘分区选项’”部分。

  5. 选择“确定”。

  6. 如果处于“发布属性 - <发布>”对话框中，请单击“确定”以保存并关闭该对话框。

修改参数化行筛选器

  1. 在新建发布向导的“筛选表行”页或“发布属性 - <发布>”的“筛选行”页上，在“筛选的表”窗格中选择筛选器，然后单击“编辑”。

  2. 在 “编辑筛选器” 对话框中，修改筛选器。

  3. 选择“确定”。

删除参数化行筛选器

  1. 在新建发布向导的“筛选表行”页或“发布属性 - <发布>”的“筛选行”页上，在“筛选的表”窗格中选择筛选器，然后单击“删除”。

“使用 Transact-SQL”

可以使用复制存储过程以编程方式创建和修改参数化行筛选器。

为合并发布中的项目定义参数化行筛选器

  1. 在发布数据库中的发布服务器上，执行 sp_addmergearticle (Transact-SQL)。 指定 @publication，为 @article指定项目名称，为 @source_object指定要发布的表，为 @subset_filterclause 指定定义参数化筛选器的 WHERE 子句（不包括 WHERE），并为 @partition_options（说明从参数化行筛选器得出的分区类型）指定下列值之一：

    • 0 - 对项目的筛选是静态的，或者不为每个分区生成唯一的数据子集（“重叠”分区）。

    • 1 - 导致分区重叠，并且在订阅服务器上所做的更新不能更改行所属的分区。

    • 2 - 对项目的筛选将生成不重叠分区，但多个订阅服务器可以接收相同的分区。

    • 3 - 对项目的筛选将为每个订阅生成唯一的不重叠分区。

更改合并发布中的项目的参数化行筛选器

  1. 在发布服务器上，对发布数据库执行 sp_changemergearticle。 指定 @publication、@article，为 @property 指定 subset_filterclause 值，为 @value 指定定义参数化筛选器的表达式（不包括 WHERE），并将 @force_invalidate_snapshot 和 @force_reinit_subscription 的值指定为“1”。

  2. 如果此更改导致不同的分区行为，则再次执行 sp_changemergearticle 。 指定 @publication和 @article，为 @property 指定 partition_options值，并为 @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

相关内容