Как определить и изменить параметризованный фильтр строк для статьи публикации слиянием (программирование репликации на языке Transact-SQL)
При создании статей таблицы можно применять параметризованные фильтры строк. Эти фильтры используют предложение WHERE, чтобы выбрать необходимые данные для публикации. Вместо того чтобы задавать буквенное значение в предложении (так, как в случае статического фильтра строк), вы указываете одну или обе следующие системные функции: SUSER_SNAME или HOST_NAME. Дополнительные сведения см. в разделе Параметризованные фильтры строк. Параметризованные фильтры строк можно создавать и изменять программно с помощью хранимых процедур репликации.
Определение параметризованного фильтра строк для статьи в публикации слиянием
В базе данных публикации на издателе выполните процедуру изменения задержки и проверки соединений для репликации транзакций (sp_addmergearticle (Transact-SQL)). Укажите параметр @publication, имя статьи в параметре @article, публикуемую таблицу в параметре @source_object, предложение WHERE, определяющее параметризованный фильтр в параметре @subset_filterclause (исключая WHERE), и одно из следующих значений в параметре @partition_options, описывающее тип секционирования, которое будет получено в результате применения параметризованного фильтра строк.
0 — фильтрация для данной статьи либо является статической, либо не возвращает уникального подмножества данных для каждой из секций (то есть имеются перекрывающиеся секции).
1 — результирующие секции перекрываются, и произведенные на подписчике изменения не могут быть внесены в секцию, которой принадлежит строка.
2 — фильтрация для статьи дает неперекрывающиеся секции, но несколько подписчиков могут получить одну и ту же секцию.
3 — фильтрация для статьи дает неперекрывающиеся секции, уникальные для каждой из подписок.
Изменение параметризованного фильтра строк для статьи в публикации слиянием
В базе данных публикации на издателе выполните процедуру sp_changemergearticle. Укажите параметры @publication, @article, значение subset_filterclause в параметре @property, выражение, определяющее параметризованный фильтр в параметре @value (исключая WHERE), и значение 1 как в параметре @force_invalidate_snapshot, так и в параметре @force_reinit_subscription.
Если это изменение приведет к разному поведению секционирования, еще раз выполните хранимую процедуру sp_changemergearticle. Укажите параметры @publication, @article, значение partition_options в параметре @property и наиболее оптимальный параметр секционирования в параметре @value, например один из следующих.
0 — фильтрация для данной статьи либо является статической, либо не возвращает уникального подмножества данных для каждой из секций (то есть имеются перекрывающиеся секции).
1 — результирующие секции перекрываются, и произведенные на подписчике изменения не могут быть внесены в секцию, которой принадлежит строка.
2 — фильтрация для статьи дает неперекрывающиеся секции, но несколько подписчиков могут получить одну и ту же секцию.
3 — фильтрация для статьи дает неперекрывающиеся секции, уникальные для каждой из подписок.
Пример
В этом примере определяется группа статей в публикации слиянием. К статьям применяется последовательность фильтров соединения для таблицы Employee Table, которая сама фильтруется по столбцу LoginID с помощью параметризованного фильтра строк. Во время синхронизации переопределяется значение, возвращаемое функцией HOST_NAME. Дополнительные сведения см. в подразделе «Переопределение значения функции 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'AdventureWorks';
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 [AdventureWorks];
-- Enable AdventureWorks 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 AdventureWorks.',
@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].[EmployeeID] = [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