• 项目

如何为事务发布启用更新订阅（复制 Transact-SQL 编程）

注意注意

后续版本的 Microsoft SQL Server 将删除该功能。 请避免在新的开发工作中使用该功能，并着手修改当前还在使用该功能的应用程序。

在使用复制存储过程以编程的方式创建事务发布时，您可以启用立即或排队更新订阅。

安全说明安全说明

如果可能，请在运行时提示用户输入安全凭据。如果必须在脚本文件中存储凭据，则必须保护文件以防止未经授权的访问。

创建支持立即更新订阅的发布

  1. 如有必要，可为发布数据库创建一个日志读取器代理作业。

    • 如果发布数据库已经拥有一个日志读取器代理作业，请继续执行步骤 2。

    • 如果您无法确定发布数据库是否已经拥有一个日志读取器代理作业，请在发布服务器上对发布数据库执行sp_helplogreader_agent (Transact-SQL)。如果结果集为空，则必须创建日志读取器代理作业。

    • 在发布服务器上，执行 sp_addlogreader_agent (Transact-SQL)。将运行该代理时所使用的 Microsoft Windows 凭据指定给 @job_name 和 @password。如果代理在连接到发布服务器时使用 SQL Server 身份验证，则您还必须将 @publisher_security_mode 的值指定为 0 并将 MicrosoftSQL Server 登录信息指定给 @publisher_login 和 @publisher_password。

  2. 执行 sp_addpublication (Transact-SQL)，将参数 @allow_sync_tran 的值指定为 true。

  3. 在发布服务器中，执行 sp_addpublication_snapshot (Transact-SQL)。将步骤 2 中使用的发布名称指定给 @publication 并将运行该快照代理时所使用的 Windows 凭据指定给 @job_name 和 @password。如果代理在连接到发布服务器时使用 SQL Server 身份验证，则您还必须将 @publisher_security_mode 的值指定为 0 并将 SQL Server 登录信息指定给 @publisher_login 和 @publisher_password。此操作将为发布创建一个快照代理作业。

  4. 向发布添加项目。有关详细信息，请参阅如何定义项目（复制 Transact-SQL 编程）。

  5. 在订阅服务器上，创建此发布的更新订阅。有关详细信息，请参阅如何创建对事务发布的可更新订阅（复制 Transact-SQL 编程）。

创建支持排队更新订阅的发布

  1. 如有必要，可为发布数据库创建一个日志读取器代理作业。

    • 如果发布数据库已经拥有一个日志读取器代理作业，请继续执行步骤 2。

    • 如果您无法确定发布数据库是否已经拥有一个日志读取器代理作业，请在发布服务器上对发布数据库执行 sp_helplogreader_agent (Transact-SQL)。如果结果集为空，则必须创建一个日志读取器代理作业。

    • 在发布服务器上，执行 sp_addlogreader_agent (Transact-SQL)。将运行该代理时所使用的 Windows 凭据指定给 @job_name 和 @password。如果代理在连接到发布服务器时使用 SQL Server 身份验证，则您还必须将 @publisher_security_mode 的值指定为 0 并将 SQL Server 登录信息指定给 @publisher_login 和 @publisher_password。

  2. 如有必要，可为分发服务器创建一个队列读取器代理作业。

    • 如果分发数据库已经拥有一个队列读取器代理作业，请继续执行步骤 3。

    • 如果您无法确定分发数据库是否已经拥有一个队列读取器代理作业，请在分发服务器上对分发数据库执行 sp_helpqreader_agent (Transact-SQL)。如果结果集为空，则必须创建一个队列读取器代理作业。

    • 在分发服务器上，执行 sp_addqreader_agent (Transact-SQL)。将运行该代理时所使用的 Windows 凭据指定给 @job_name 和 @password。这些凭据将在队列读取器代理连接到发布服务器和订阅服务器时使用。有关详细信息，请参阅复制代理安全性模式。

  3. 执行 sp_addpublication (Transact-SQL)，将参数 @allow_queued_tran 的值指定为 true 并将 @conflict_policy 的值指定为 pub wins、sub reinit 或 sub wins。

  4. 在发布服务器中，执行 sp_addpublication_snapshot (Transact-SQL)。将步骤 3 中使用的发布名称指定给 @publication 并将运行该快照代理时所使用的 Windows 凭据指定给 @snapshot_job_name 和 @password。如果代理在连接到发布服务器时使用 SQL Server 身份验证，则您还必须将 @publisher_security_mode 的值指定为 0 并将 SQL Server 登录信息指定给 @publisher_login 和 @publisher_password。此操作将为发布创建一个快照代理作业。

  5. 向发布添加项目。有关详细信息，请参阅如何定义项目（复制 Transact-SQL 编程）。

  6. 在订阅服务器上，创建此发布的更新订阅。有关详细信息，请参阅如何创建对事务发布的可更新订阅（复制 Transact-SQL 编程）。

为允许排队更新订阅的发布更改冲突策略

  • 在发布服务器上，对发布数据库执行 sp_changepublication (Transact-SQL)。将值 conflict_policy 指定给 @property，并为 @value 指定所需的冲突策略模式 pub wins、sub reinit 或 sub wins。

示例

此示例创建一个支持立即和排队更新请求订阅的发布。

-- To avoid storing the login and password in the script file, the values 
-- are passed into SQLCMD as scripting variables. 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".

--Declarations for adding a transactional publication
DECLARE @publicationDB AS sysname;
DECLARE @publication AS sysname;
DECLARE @login AS sysname;
DECLARE @password AS sysname;
SET @publicationDB = N'AdventureWorks'; 
SET @publication = N'AdvWorksProductTran'; 
SET @login = $(Login); 
SET @password = $(Password); 

USE [AdventureWorks]
-- Enable transactional replication on the publication database.
EXEC sp_replicationdboption 
    @dbname=@publicationDB, 
    @optname=N'publish',
    @value = N'true';

-- Execute sp_addlogreader_agent to create the agent job. 
EXEC sp_addlogreader_agent 
    @job_login = @login, 
    @job_password = @password,
    -- Explicitly specify the use of Windows Integrated Authentication (default) 
    -- when connecting to the Publisher.
    @publisher_security_mode = 1;

-- Create a transactional publication that supports immediate updating, 
-- queued updating, and pull subscriptions. 
EXEC sp_addpublication 
    @publication = @publication, 
    @status = N'active',
    @allow_sync_tran = N'true', 
    @allow_queued_tran = N'true',
    @allow_pull = N'true',
    @independent_agent = N'true',
  -- Explicitly declare the related default properties 
    @conflict_policy = N'pub wins';

-- Create a new snapshot job for the publication, using a default schedule.
EXEC sp_addpublication_snapshot 
    @publication = @publication, 
    @job_login = @login, 
    @job_password = @password,
    -- Explicitly specify the use of Windows Integrated Authentication (default) 
    -- when connecting to the Publisher.
    @publisher_security_mode = 1;
GO

--Declarations for adding an article.
DECLARE @publication AS sysname;
DECLARE @article AS sysname;
DECLARE @owner AS sysname;
SET @publication = N'AdvWorksProductTran';
SET @article = N'Product'; 
SET @owner = N'Production'; 

-- Add a horizontally and vertically filtered article for the Product table.
USE [AdventureWorks]
EXEC sp_addarticle 
    @publication = @publication, 
    @article = @article, 
    @source_table = @article, 
    @vertical_partition = N'false', 
    @type = N'logbased',
    @source_owner = @owner, 
    @destination_owner = @owner;
GO