使用參數化篩選建立合併式發行集的快照集

發行項
06/18/2013

本主題描述如何使用 SQL Server Management Studio、Transact-SQL 或 Replication Management Objects (RMO)，在 SQL Server 2012 中使用參數化篩選建立合併式發行集的快照集。

本主題內容

開始之前：

建議
若要使用參數化篩選建立合併式發行集的快照集，請使用：

SQL Server Management Studio

Transact-SQL

Replication Management Objects (RMO)

開始之前

建議

在使用參數化篩選產生合併式發行集的快照集時，您必須先產生一個標準 (結構描述) 快照集，其中包含所有發行的資料以及訂閱的訂閱者中繼資料。如需詳細資訊，請參閱＜建立和套用初始快照集＞。在您建立結構描述快照集之後，您可以產生包含發行資料之訂閱者特有資料分割的快照集。
如果發行集內的一個或多個發行項的篩選產生對每個訂閱而言是唯一的非重疊資料分割，則只要合併代理程式一執行，就會清除中繼資料。這表示分割快照集會更快過期。使用這個選項時，您應該考慮允許訂閱者初始化快照集的產生與傳遞。如需篩選選項的詳細資訊，請參閱＜含參數化篩選之合併式發行集的快照集＞的「設定資料分割選項」一節。

搭配回到頁首連結使用的箭頭圖示 [Top]

使用 SQL Server Management Studio

在 [發行集屬性 - <發行集>] 對話方塊的 [資料分割] 頁面上，產生資料分割的快照集。如需有關存取這個對話方塊的詳細資訊，請參閱＜檢視及修改發行集屬性＞。您可以讓訂閱者初始化快照集產生和傳遞，並且/或者產生快照集。

產生一個或多個資料分割的快照集之前，必須：

使用「新增發行集精靈」建立合併發行集，並在精靈的 [加入篩選] 頁面上，指定一個或多個參數化資料列篩選器。如需詳細資訊，請參閱＜針對合併發行項定義及修改參數化資料列篩選＞。
產生發行集的結構描述快照集。依預設，當您完成「新增發行集精靈」時，便會產生結構描述快照集；您也可以從 SQL Server Management Studio 產生結構描述快照集。

若要產生結構描述快照集

連接到 Management Studio 中的發行者，然後展開伺服器節點。
展開 [複寫] 資料夾，然後展開 [發行集] 資料夾。
以滑鼠右鍵按一下您要為其建立快照集的發行集，然後按一下 [檢視快照集代理程式的狀態]。
在 [檢視快照集代理程式的狀態 - <Publication>] 對話方塊中，按一下 [啟動]。

快照集代理程式產生完快照集後，就會顯示一個訊息，例如「[100%] 已產生 17 個發行項的快照集」。

若要允許訂閱者初始化快照集的產生與傳遞

在 [發行集屬性 - <發行集>] 對話方塊的 [資料分割] 頁面上，選取 [新的訂閱者嘗試進行同步處理時，自動定義資料分割並依需要產生快照]。
按一下 [確定]。

若要產生和重新整理快照集

在 [發行集屬性 - <Publication>] 對話方塊的 [資料分割] 頁面上，按一下 [加入]。
輸入與您要建立快照集的資料分割關聯之 HOST_NAME() 和 (或) SUSER_SNAME() 的值。
選擇性地指定重新整理快照集的排程：
1. 選取 [排程這個資料分割的快照集代理程式在下列時間執行]
2. 接受重新重理快照集的預設排程，或按一下 [變更] 以指定其他排程。
按一下 [確定]，回到 [發行集屬性 - <發行集>] 對話方塊。
在屬性方格中選取資料分割，然後按一下 [立即產生選取的快照集]。
按一下 [確定]。

搭配回到頁首連結使用的箭頭圖示 [Top]

使用 Transact-SQL

您可以使用預存程序和快照集代理程式進行以下作業：

允許訂閱者在首次執行同步處理時，要求快照集產生和應用程式。
為每個資料分割預先產生快照集。

以手動方式為每一個訂閱者產生快照集。

安全性注意事項
可能的話，在執行階段提示使用者輸入安全性認證。如果您必須將認證儲存在指令碼檔案中，則必須維護這個檔案的安全性，使他人無法在未獲授權的情況下擅自存取。

建立可讓訂閱者初始化快照集產生和傳遞的發行集

在發行集資料庫的發行者上，執行 sp_addmergepublication (Transact-SQL)。指定下列參數：
- 將 @publication 設定為發行集的名稱。
- 將 @allow_subscriber_initiated_snapshot 設定為 true 的值，這樣可讓訂閱者起始快照集處理。
- (選擇性) 將 @max_concurrent_dynamic_snapshots 設定為可以並行執行的動態快照集處理序數目。如果正在執行最大的處理序數目，而且訂閱者嘗試產生快照集，則會將此處理序置於佇列中。根據預設，並行處理序的數目沒有任何限制。

在發行者上，執行 sp_addpublication_snapshot (Transact-SQL)。針對 @publication 指定步驟 1 中所用的發行集名稱，並針對 @job_login 和 @password 指定執行複寫快照集代理程式所用的 Microsoft Windows 認證。如果代理程式會在與「發行者」時連接時使用「SQL Server 驗證」，則也必須指定 @publisher_security_mode 的值 0，以及 @publisher_login 和 @publisher_password 的 Microsoft SQL Server 登入資訊。這麼做會為發行集建立快照集代理程式作業。如需有關產生初始快照集以及為快照集代理程式定義自訂排程的詳細資訊，請參閱＜建立和套用初始快照集＞。

安全性注意事項
當利用遠端散發者來設定發行者時，提供給所有參數的值 (包括 job_login 和 job_password) 都會以純文字的方式傳給散發者。您應該先加密「發行者」及其遠端「散發者」之間的連接，再執行這個預存程序。如需詳細資訊，請參閱＜啟用 Database Engine 的加密連接 (SQL Server 組態管理員)＞。

執行 sp_addmergearticle (Transact-SQL) 將發行項加入發行集中。必須針對發行集中的每一個發行項執行一次此預存程序。在使用參數化篩選時，您必須使用 @subset_filterclause 參數來指定一個或多個發行項的參數化資料列篩選器。如需詳細資訊，請參閱＜針對合併發行項定義及修改參數化資料列篩選＞。
如果將根據參數化資料列篩選器來篩選其他發行項，請執行 sp_addmergefilter (Transact-SQL) 來定義兩個發行項之間的聯結或邏輯記錄關聯性。必須針對每一個定義的關聯性執行一次此預存程序。如需詳細資訊，請參閱＜定義和修改合併發行項之間的聯結篩選＞。
當合併代理程式要求此快照集初始化訂閱者時，會自動產生要求之訂閱資料分割的快照集。

建立發行集及預先產生或自動重新整理快照集

執行 sp_addmergepublication (Transact-SQL) 來建立發行集。如需詳細資訊，請參閱＜建立發行集＞。

在發行者上，執行 sp_addpublication_snapshot (Transact-SQL)。針對 @publication 指定步驟 1 中所使用的發行集名稱，以及針對 @job_login 和 @password 指定快照集代理程式執行時所使用的 Windows 認證。如果代理程式會在與「發行者」時連接時使用「SQL Server 驗證」，則也必須指定 @publisher_security_mode 的值 0，以及 @publisher_login 和 @publisher_password 的 SQL Server 登入資訊。這麼做會為發行集建立快照集代理程式作業。如需有關產生初始快照集以及為快照集代理程式定義自訂排程的詳細資訊，請參閱＜建立和套用初始快照集＞。

安全性注意事項
當利用遠端散發者來設定發行者時，提供給所有參數的值 (包括 job_login 和 job_password) 都會以純文字的方式傳給散發者。您應該先加密「發行者」及其遠端「散發者」之間的連接，再執行這個預存程序。如需詳細資訊，請參閱＜啟用 Database Engine 的加密連接 (SQL Server 組態管理員)＞。

執行 sp_addmergearticle (Transact-SQL) 將發行項加入發行集中。必須針對發行集中的每一個發行項執行一次此預存程序。在使用參數化篩選時，您必須使用 @subset_filterclause 參數來指定一個發行項的參數化資料列篩選器。如需詳細資訊，請參閱＜針對合併發行項定義及修改參數化資料列篩選＞。
如果將根據參數化資料列篩選器來篩選其他發行項，請執行 sp_addmergefilter (Transact-SQL) 來定義兩個發行項之間的聯結或邏輯記錄關聯性。必須針對每一個定義的關聯性執行一次此預存程序。如需詳細資訊，請參閱＜定義和修改合併發行項之間的聯結篩選＞。
在發行集資料庫的發行者上執行 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)。針對 @publication 指定步驟 1 中的發行集名稱，並針對 @suser_sname (如果 SUSER_SNAME (Transact-SQL) 用於篩選子句) 或是針對 @host_name (如果 HOST_NAME (Transact-SQL) 用於篩選子句) 指定用於定義資料分割的值。
在發行集資料庫的發行者上，執行 sp_adddynamicsnapshot_job (Transact-SQL)。針對 @publication 指定步驟 1 中的發行集名稱、步驟 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) 來建立發行集。如需詳細資訊，請參閱＜建立發行集＞。

安全性注意事項
當利用遠端散發者來設定發行者時，提供給所有參數的值 (包括 job_login 和 job_password) 都會以純文字的方式傳給散發者。您應該先加密「發行者」及其遠端「散發者」之間的連接，再執行這個預存程序。如需詳細資訊，請參閱＜啟用 Database Engine 的加密連接 (SQL Server 組態管理員)＞。

執行 sp_addmergearticle (Transact-SQL) 將發行項加入發行集中。必須針對發行集中的每一個發行項執行一次此預存程序。在使用參數化篩選時，您必須使用 @subset_filterclause 參數，至少針對一個發行項指定參數化資料列篩選器。如需詳細資訊，請參閱＜針對合併發行項定義及修改參數化資料列篩選＞。
如果將根據參數化資料列篩選器來篩選其他發行項，請執行 sp_addmergefilter (Transact-SQL) 來定義兩個發行項之間的聯結或邏輯記錄關聯性。必須針對每一個定義的關聯性執行一次此預存程序。如需詳細資訊，請參閱＜定義和修改合併發行項之間的聯結篩選＞。
從命令提示字元啟動快照集作業或是執行複寫快照集代理程式，以產生標準快照集結構描述和其他檔案。如需詳細資訊，請參閱＜建立和套用初始快照集＞。
再次從命令提示字元執行複寫快照集代理程式，以產生大量複製 (.bcp) 檔案，為 -DynamicSnapshotLocation 指定分割快照集的位置，以及指定可定義此資料分割的下列其中一個或兩個屬性：
- -DynamicFilterHostName - 如果使用 HOST_NAME (Transact-SQL) 時的值。
- -DynamicFilterLogin - 如果使用 SUSER_SNAME (Transact-SQL) 時的值。
針對每一個訂閱重複步驟 6 來產生分割快照集。
針對每一個訂閱執行合併代理程式，以便在訂閱者上套用初始分割快照集，並指定下列屬性：
- -Hostname - 如果正在覆寫 HOST_NAME 的實際值，則表示用於定義資料分割的值。
- -DynamicSnapshotLocation - 此資料分割的動態快照集位置。

[!附註]

如需有關複寫代理程式之程式設計的詳細資訊，請參閱＜複寫代理程式可執行檔概念＞。

範例 (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]

使用 Replication Management Objects (RMO)

您可以透過以下方式，以程式設計的方式使用 Replication Management Objects (RMO) 來產生分割快照集。

允許訂閱者在首次執行同步處理時，要求快照集產生和應用程式。
為每個資料分割預先產生快照集。
執行「快照集代理程式」為每個訂閱者手動產生快照集。

[!附註]

當篩選發行項產生了對每個訂閱而言是唯一的非重疊資料分割時 (在建立合併發行項時，針對 PartitionOption 指定 NonOverlappingSingleSubscription 的值)，則只要合併代理程式一執行，就會清除中繼資料。這表示分割快照集會更快過期。當使用這個選項時，您應該考慮允許訂閱者要求產生快照集。如需詳細資訊，請參閱＜參數化資料列篩選器＞主題中的「使用適當的篩選選項」一節。

安全性注意事項
可能的話，系統會在執行階段提示使用者輸入安全性認證。如果您必須儲存認證，請使用 Microsoft Windows .NET Framework 提供的密碼編譯服務。

建立可讓訂閱者初始化快照集產生和傳遞的發行集

使用 ServerConnection 類別建立與發行者的連接。
為發行集資料庫建立 ReplicationDatabase 類別的執行個體、將 ConnectionContext 屬性設定為步驟 1 中的 ServerConnection 執行個體，並呼叫 LoadProperties 方法。如果 LoadProperties 傳回 false，請確認此資料庫確實存在。
如果 EnabledMergePublishing 屬性為 false，請將它設定為 true 然後呼叫 CommitPropertyChanges。
建立 MergePublication 類別的執行個體，並為此物件設定下列屬性：
- 將 ConnectionContext 設定為步驟 1 中的 ServerConnection。
- 將 DatabaseName 設為發行的資料庫名稱。
- 將 Name 設定為發行集名稱。
- 將 MaxConcurrentDynamicSnapshots 設定為動態快照集作業的最大數目。由於訂閱者起始的快照集要求可在任何時間發生，所以當多個訂閱者同時要求其分割快照集時，這個屬性會限制可以同時執行的快照集代理程式作業數目。當正在執行最大的作業數目時，其他分割快照集要求會排入佇列中，直到其中一個執行中的作業完成為止。
- 在 Visual C# 中使用位元邏輯 OR (| (Visual Basic 中為 Or) 運算子，將 AllowSubscriberInitiatedSnapshot 值加入至 Attributes。
- SnapshotGenerationAgentProcessSecurity 的 Login 和 Password 欄位，可提供執行快照集代理程式作業所使用之 Microsoft Windows 帳戶的認證。
  
  [!附註]
  
  當發行集是由 sysadmin 固定伺服器角色的成員所建立時，建議您設定 SnapshotGenerationAgentProcessSecurity。如需詳細資訊，請參閱＜複寫代理程式安全性模型＞。

呼叫 Create 方法來建立發行集。

安全性注意事項
當利用遠端散發者來設定發行者時，提供給所有屬性的值 (包括 SnapshotGenerationAgentProcessSecurity) 都會以純文字的方式傳給散發者。您應該先加密發行者及其遠端散發者之間的連接，再呼叫 Create 方法。如需詳細資訊，請參閱＜啟用 Database Engine 的加密連接 (SQL Server 組態管理員)＞。

使用 MergeArticle 屬性將發行項加入發行集中。至少針對定義參數化篩選的一個發行項指定 FilterClause 屬性。 (選擇性) 建立可在發行項之間定義聯結篩選的 MergeJoinFilter 物件。如需詳細資訊，請參閱＜定義發行項＞。
如果 SnapshotAgentExists 的值是 false，請呼叫 CreateSnapshotAgent 來針對這個發行集建立初始快照集代理程式作業。
呼叫步驟 4 中建立之 MergePublication 物件的 StartSnapshotGenerationAgentJob 方法。這樣會啟動可產生初始快照集的代理程式作業。如需有關產生初始快照集以及為快照集代理程式定義自訂排程的詳細資訊，請參閱＜建立和套用初始快照集＞。
(選擇性) 檢查是否有為 SnapshotAvailable 屬性設定 true 的值，以判斷初始快照集何時可準備好供人使用。
當訂閱者的合併代理程式第一次連接時，會自動產生分割快照集。

建立發行集及預先產生或自動重新整理快照集

使用 MergePublication 類別的執行個體來定義合併式發行集。如需詳細資訊，請參閱＜建立發行集＞。
使用 MergeArticle 屬性將發行項加入發行集中。至少針對定義參數化篩選的一個發行項指定 FilterClause 屬性，並建立可在兩個發行項之間定義聯結篩選的任何 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 屬性，並建立可在兩個發行項之間定義聯結篩選的任何 MergeJoinFilter 物件。如需詳細資訊，請參閱＜定義發行項＞。
產生初始快照集。如需詳細資訊，請參閱＜建立和套用初始快照集＞。
建立 SnapshotGenerationAgent 類別的執行個體，並設定下列必要的屬性：
- Publisher - 發行者的名稱
- PublisherDatabase - 發行集資料庫的名稱
- Publication - 發行集的名稱
- Distributor - 散發者的名稱
- PublisherSecurityMode - 代表使用「Windows 整合式驗證」的 Integrated 值，或使用「SQL Server 驗證」的 Standard 值。
- DistributorSecurityMode - 代表使用「Windows 整合式驗證」的 Integrated 值，或使用「SQL Server 驗證」的 Standard 值。
為 ReplicationType 設定 Merge 的值。
設定以下其中一個或多個屬性來定義資料分割參數：
- 如果訂閱者的資料分割是由 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]

請參閱

概念

共用方式為

使用參數化篩選建立合併式發行集的快照集

開始之前

建議

使用 SQL Server Management Studio

若要產生結構描述快照集

若要允許訂閱者初始化快照集的產生與傳遞

若要產生和重新整理快照集

使用 Transact-SQL

建立可讓訂閱者初始化快照集產生和傳遞的發行集

建立發行集及預先產生或自動重新整理快照集

針對每一個資料分割建立發行集及手動建立快照集

範例 (Transact-SQL)

使用 Replication Management Objects (RMO)

建立可讓訂閱者初始化快照集產生和傳遞的發行集

建立發行集及預先產生或自動重新整理快照集

針對每一個資料分割建立發行集及手動建立快照集

範例 (RMO)

請參閱

概念

其他資源