Create a Publication
本主题介绍如何在 SQL Server 2014 中使用 SQL Server Management Studio、Transact-SQL 或复制管理对象 (RMO) 创建发布。
本主题内容
开始之前:
创建发布和定义项目,使用:
开始之前
限制和局限
- 发布和项目名称不能包括下列任何字符:%、*、[、]、|、:、"、? , ' , \ , / , < , >. 如果数据库中的对象包含这些字符中的任何一个,并且你想要复制它们,则必须指定一个项目名称,该名称不同于“ 项目属性 - <项目> ”对话框中的对象名称,该名称可从向导的“ 项目 ”页获取。
安全性
如果可能,请在运行时提示用户输入安全凭据。 如果必须存储凭据,请使用 Windows .NET Framework 提供的 Cryptographic Services Microsoft (加密服务)。
使用 SQL Server Management Studio
可以使用新建发布向导创建发布和定义项目。 创建发布后,在“发布属性 - <发布”对话框中查看和修改发布>属性。 有关从 Oracle 数据库创建发布的信息,请参阅从 Oracle 数据库创建发布。
创建发布和定义项目
在 Microsoft SQL Server Management Studio 中连接到发布服务器,然后展开服务器节点。
展开 “复制” 文件夹,再右键单击 “本地发布” 文件夹。
单击 “新建发布” 。
按照新建发布向导中的页完成以下任务:
如果尚未在服务器上配置分发,请指定分发服务器。 有关如何配置分发的详细信息,请参阅配置发布和分发。
如果在 “分发服务器” 页上指定将发布服务器用作其自己的分发服务器(本地分发服务器),而未将服务器配置为分发服务器,则新建发布向导将配置该服务器。 在 “快照文件夹” 页中指定分发服务器的快照文件夹。 快照文件夹只是指定共享的目录。向此文件夹中执行读写操作的代理必须对其具有足够的访问权限。 有关正确保护文件夹的详细信息,请参阅保护快照文件夹。
如果指定另一台服务器作为分发服务器,则必须在 “管理密码” 页上输入密码来连接发布服务器和分发服务器。 此密码必须与在远程分发服务器上启用发布服务器时所指定的密码相匹配。
有关详细信息,请参阅 Configure Distribution。
选择发布数据库。
选择发布类型。 有关详细信息,请参阅复制类型。
指定要发布的数据和数据库对象;(可选)筛选来自表项目的列,并设置项目属性。
可选择筛选来自表项目的行。 有关详细信息,请参阅筛选已发布数据。
设置快照代理调度。
指定运行下列复制代理和进行连接的凭证:
- 用于所有发布的快照代理。
- 用于所有事务发布的日志读取器代理。
- 用于允许更新订阅的事务发布的队列读取器代理。
有关详细信息,请参阅 Replication Agent Security Model 和 Replication Security Best Practices。
(可选)编写发布脚本。 有关详细信息,请参阅 Scripting Replication。
指定发布的名称。
“使用 Transact-SQL”
可以使用复制存储过程以编程方式创建发布。 使用的存储过程将取决于要创建的发布的类型。
创建快照发布或事务发布
在发布服务器上,对发布数据库执行 sp_replicationdboption (Transact-SQL) ,以使用快照或事务复制来发布当前数据库。
对于事务发布,确定发布数据库中是否存在日志读取器代理作业。 (对于快照发布,不需要此步骤)。
如果发布数据库中存在日志读取器代理作业,则继续执行步骤 3。
如果不确定已发布数据库是否存在日志读取器代理作业,请在发布服务器上对发布数据库执行 sp_helplogreader_agent (Transact-SQL) 。
如果结果集为空,则创建日志读取器代理作业。 在发布服务器上, sp_addlogreader_agent (执行 Transact-SQL) 。 为 @job_name 和 @password指定运行代理时所依据的 Microsoft Windows 凭据。 如果代理在连接到发布服务器时将使用 SQL Server 身份验证,则还必须将 @publisher_security_mode 的值指定为 0,并为@publisher_login和@publisher_password指定 Microsoft SQL Server登录信息。 继续执行步骤 3。
在发布服务器上, sp_addpublication (执行 Transact-SQL) 。 为@publication指定发布名称,对于@repl_freq参数,为快照发布指定 值,为事务发布指定
snapshot
值continuous
。 指定任何其他发布选项。 这便定义了发布。注意
发布名称不能包括下列字符:
% * [ ] | : " ? \ / <>
在发布服务器上,执行sp_addpublication_snapshot (Transact-SQL)。 指定步骤 3 中用于@publication的发布名称,并为@snapshot_job_name和@password指定运行快照代理所使用的 Windows 凭据。 如果代理在连接到发布服务器时将使用SQL Server身份验证,则还必须将 @publisher_security_mode 的值指定为 0,并为@publisher_login和@publisher_password指定SQL Server登录信息。 此操作将为发布创建一个快照代理作业。
重要
使用远程分发服务器配置发布服务器时,为所有参数提供的值(包括 job_login 和 job_password)都会以纯文本方式发送到该分发服务器。 在执行此存储过程之前,应该对发布服务器及其远程分发服务器之间的连接进行加密。 有关详细信息,请参阅启用数据库引擎的加密连接(SQL Server 配置管理器)。
向发布添加项目。 有关详细信息,请参阅 定义项目。
启动快照代理作业以为此发布生成初始快照。 有关详细信息,请参阅 创建并应用初始快照。
创建合并发布
在发布服务器上,执行 sp_replicationdboption (Transact-SQL) ,以便使用合并复制发布当前数据库。
在发布服务器上,对发布数据库执行 sp_addmergepublication (Transact-SQL) 。 为 @publication 和任何其他发布选项指定发布的名称。 这便定义了发布。
注意
发布名称不能包括下列字符:
% * [ ] | : " ? \ / <>
在发布服务器上,执行sp_addpublication_snapshot (Transact-SQL)。 指定步骤 2 中用于@publication的发布名称,并为@snapshot_job_name和@password指定运行快照代理所使用的 Windows 凭据。 如果代理在连接到发布服务器时将使用SQL Server身份验证,则还必须将 @publisher_security_mode 的值指定为 0,并为@publisher_login和@publisher_password指定SQL Server登录信息。 此操作将为发布创建一个快照代理作业。
重要
使用远程分发服务器配置发布服务器时,为所有参数提供的值(包括 job_login 和 job_password)都会以纯文本方式发送到该分发服务器。 在执行此存储过程之前,应该对发布服务器及其远程分发服务器之间的连接进行加密。 有关详细信息,请参阅启用数据库引擎的加密连接(SQL Server 配置管理器)。
向发布添加项目。 有关详细信息,请参阅 定义项目。
启动快照代理作业以为此发布生成初始快照。 有关详细信息,请参阅 创建并应用初始快照。
示例 (Transact-SQL)
此示例创建事务发布。 脚本变量用于传递创建快照代理和日志读取器代理作业时所需的 Windows 凭据。
-- 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".
DECLARE @publicationDB AS sysname;
DECLARE @publication AS sysname;
DECLARE @login AS sysname;
DECLARE @password AS sysname;
SET @publicationDB = N'AdventureWorks';
SET @publication = N'AdvWorksProductTran';
-- Windows account used to run the Log Reader and Snapshot Agents.
SET @login = $(Login);
-- This should be passed at runtime.
SET @password = $(Password);
-- Enable transactional or snapshot 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 new transactional publication with the required properties.
EXEC sp_addpublication
@publication = @publication,
@status = N'active',
@allow_push = N'true',
@allow_pull = N'true',
@independent_agent = N'true';
-- 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
此示例创建合并发布。 脚本变量用于传递创建快照代理作业时所需的 Windows 凭据。
-- 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".
--Declarations for adding a merge publication
DECLARE @publicationDB AS sysname;
DECLARE @publication AS sysname;
DECLARE @login AS sysname;
DECLARE @password AS sysname;
SET @publicationDB = N'AdventureWorks2012';
SET @publication = N'AdvWorksSalesOrdersMerge';
SET @login = $(Login);
SET @password = $(Password);
-- Enable merge replication on the publication database, using defaults.
USE master
EXEC sp_replicationdboption
@dbname=@publicationDB,
@optname=N'merge publish',
@value = N'true'
-- Create a new merge publication, explicitly setting the defaults.
USE [AdventureWorks2012]
EXEC sp_addmergepublication
-- These parameters are optional.
@publication = @publication,
-- optional parameters
@description = N'Merge publication of AdventureWorks2012.',
@publication_compatibility_level = N'120RTM';
-- Create a new snapshot job for the publication.
EXEC sp_addpublication_snapshot
@publication = @publication,
@job_login = @login,
@job_password = @password;
GO
使用复制管理对象 (RMO)
可以使用复制管理对象 (RMO) 以编程方式创建发布。 用于创建发布的 RMO 类取决于所创建发布的类型。
创建快照发布或事务发布
使用 ServerConnection 类创建与发布服务器的连接。
为发布数据库创建 ReplicationDatabase 类的实例,将 ConnectionContext 属性设置为步骤 1 中的 ServerConnection 的实例,然后调用 LoadProperties 方法。 如果 LoadProperties 返回
false
,请验证该数据库是否存在。如果 EnabledTransPublishing 属性为
false
,请将其设置为true
。对于事务发布,请检查 LogReaderAgentExists 属性的值。 如果该属性为
true
,说明已经存在一个针对此数据库的日志读取器代理作业。 如果该属性为false
,请执行如下操作:Login设置 的 LogReaderAgentProcessSecurity 和 Password 或 SecurePassword* 字段,为运行日志读取器代理的 Microsoft Windows 帐户提供凭据。
注意
如果发布是由
sysadmin
固定服务器角色的成员创建的,则不需要设置 LogReaderAgentProcessSecurity。 在这种情况下,代理会模拟 SQL Server Agent 帐户。 有关详细信息,请参阅 复制代理安全模式。(可选)在使用 SQL Server 身份验证连接到发布服务器时设置 SqlStandardLogin 的 SqlStandardPassword 和 SecureSqlStandardPassword 或 LogReaderAgentPublisherSecurity 字段。
调用 CreateLogReaderAgent 方法,为该数据库创建日志读取器代理作业。
创建 TransPublication 类的实例,并设置此对象的以下属性:
将 ServerConnection 设置为步骤 1 中的 ConnectionContext。
将 DatabaseName设置为已发布的数据库的名称。
将 Name属性设置为发布的名称。
将 PublicationType 设置为 Transactional 或 Snapshot。
设置 Login 的 Password 和 SnapshotGenerationAgentProcessSecurity 字段,为运行快照代理所用的 Windows 帐户提供凭据。 如果使用 Windows 身份验证,在快照代理连接到本地分发服务器或建立远程连接时,也会使用此帐户。
注意
如果发布是由
sysadmin
固定服务器角色的成员创建的,则不需要设置 SnapshotGenerationAgentProcessSecurity。 在这种情况下,代理会模拟 SQL Server Agent 帐户。 有关详细信息,请参阅 复制代理安全模式。(可选)如果使用 SQL Server 身份验证连接到发布服务器,设置 SqlStandardLogin 的 SqlStandardPassword 和 SecureSqlStandardPassword 或 SnapshotGenerationAgentPublisherSecurity 字段。
(可选)使用“或”逻辑 OR 运算符(在 Visual C# 中为
|
,在 Visual Basic 中为Or
)和“异或”逻辑 OR 运算符(在 Visual C# 中为^
,在 Visual Basic 中为Xor
),将 PublicationAttributes 属性的值设置为 Attributes。(可选)将 PublisherName 设置为发布服务器的名称(如果发布服务器不是 SQL Server 发布服务器)。
调用 Create 方法来创建发布。
重要
在使用远程分发服务器配置发布服务器时,为所有属性提供的值(包括 SnapshotGenerationAgentProcessSecurity)都会以纯文本形式发送到该分发服务器。 调用 Create 方法之前,应先对发布服务器与其远程分发服务器之间的连接进行加密。 有关详细信息,请参阅启用数据库引擎的加密连接(SQL Server 配置管理器)。
调用 CreateSnapshotAgent 方法,为发布创建快照代理作业。
创建合并发布
使用 ServerConnection 类创建与发布服务器的连接。
为发布数据库创建 ReplicationDatabase 类的实例,将 ConnectionContext 属性设置为步骤 1 中的 ServerConnection 的实例,然后调用 LoadProperties 方法。 如果 LoadProperties 返回
false
,请验证该数据库是否存在。如果 EnabledMergePublishing 属性为
false
,请将其设置为true
,然后调用 CommitPropertyChanges。创建 MergePublication 类的实例,并设置此对象的以下属性:
将 ServerConnection 设置为步骤 1 中的 ConnectionContext。
将 DatabaseName设置为已发布的数据库的名称。
将 Name属性设置为发布的名称。
设置 Login 的 Password 和 SnapshotGenerationAgentProcessSecurity 字段,为运行快照代理所用的 Windows 帐户提供凭据。 如果使用 Windows 身份验证,在快照代理连接到本地分发服务器或建立远程连接时,也会使用此帐户。
注意
如果发布是由
sysadmin
固定服务器角色的成员创建的,则不需要设置 SnapshotGenerationAgentProcessSecurity。 有关详细信息,请参阅 复制代理安全模式。(可选)使用“或”逻辑 OR 运算符(在 Visual C# 中为
|
,在 Visual Basic 中为Or
)和“异或”逻辑 OR 运算符(在 Visual C# 中为^
,在 Visual Basic 中为Xor
),将 PublicationAttributes 属性的值设置为 Attributes。
调用 Create 方法来创建发布。
重要
在使用远程分发服务器配置发布服务器时,为所有属性提供的值(包括 SnapshotGenerationAgentProcessSecurity)都会以纯文本形式发送到该分发服务器。 调用 Create 方法之前,应先对发布服务器与其远程分发服务器之间的连接进行加密。 有关详细信息,请参阅启用数据库引擎的加密连接(SQL Server 配置管理器)。
调用 CreateSnapshotAgent 方法,为发布创建快照代理作业。
示例 (RMO)
本例将 AdventureWorks 数据库设置为支持事务发布,定义了一个日志读取器代理作业,并且创建了 AdvWorksProductTran 发布。 必须为此发布定义一个项目。 创建日志读取器代理作业和快照代理作业所需的 Windows 帐户凭据在运行时进行传递。 若要了解如何使用 RMO 定义快照项目和事务项目,请参阅 Define an Article。
// Set the Publisher, publication database, and publication names.
string publicationName = "AdvWorksProductTran";
string publicationDbName = "AdventureWorks2012";
string publisherName = publisherInstance;
ReplicationDatabase publicationDb;
TransPublication publication;
// Create a connection to the Publisher using Windows Authentication.
ServerConnection conn;
conn = new ServerConnection(publisherName);
try
{
// Connect to the Publisher.
conn.Connect();
// Enable the AdventureWorks2012 database for transactional publishing.
publicationDb = new ReplicationDatabase(publicationDbName, conn);
// If the database exists and is not already enabled,
// enable it for transactional publishing.
if (publicationDb.LoadProperties())
{
if (!publicationDb.EnabledTransPublishing)
{
publicationDb.EnabledTransPublishing = true;
}
// If the Log Reader Agent does not exist, create it.
if (!publicationDb.LogReaderAgentExists)
{
// Specify the Windows account under which the agent job runs.
// This account will be used for the local connection to the
// Distributor and all agent connections that use Windows Authentication.
publicationDb.LogReaderAgentProcessSecurity.Login = winLogin;
publicationDb.LogReaderAgentProcessSecurity.Password = winPassword;
// Explicitly set authentication mode for the Publisher connection
// to the default value of Windows Authentication.
publicationDb.LogReaderAgentPublisherSecurity.WindowsAuthentication = true;
// Create the Log Reader Agent job.
publicationDb.CreateLogReaderAgent();
}
}
else
{
throw new ApplicationException(String.Format(
"The {0} database does not exist at {1}.",
publicationDb, publisherName));
}
// Set the required properties for the transactional publication.
publication = new TransPublication();
publication.ConnectionContext = conn;
publication.Name = publicationName;
publication.DatabaseName = publicationDbName;
// Specify a transactional publication (the default).
publication.Type = PublicationType.Transactional;
// Activate the publication so that we can add subscriptions.
publication.Status = State.Active;
// Enable push and pull subscriptions and independent Distribition Agents.
publication.Attributes |= PublicationAttributes.AllowPull;
publication.Attributes |= PublicationAttributes.AllowPush;
publication.Attributes |= PublicationAttributes.IndependentAgent;
// 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;
if (!publication.IsExistingObject)
{
// Create the transactional 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 publicationName As String = "AdvWorksProductTran"
Dim publicationDbName As String = "AdventureWorks2012"
Dim publisherName As String = publisherInstance
Dim publicationDb As ReplicationDatabase
Dim publication As TransPublication
' Create a connection to the Publisher using Windows Authentication.
Dim conn As ServerConnection
conn = New ServerConnection(publisherName)
Try
' Connect to the Publisher.
conn.Connect()
' Enable the AdventureWorks2012 database for transactional publishing.
publicationDb = New ReplicationDatabase(publicationDbName, conn)
' If the database exists and is not already enabled,
' enable it for transactional publishing.
If publicationDb.LoadProperties() Then
If Not publicationDb.EnabledTransPublishing Then
publicationDb.EnabledTransPublishing = True
End If
' If the Log Reader Agent does not exist, create it.
If Not publicationDb.LogReaderAgentExists Then
' Specify the Windows account under which the agent job runs.
' This account will be used for the local connection to the
' Distributor and all agent connections that use Windows Authentication.
publicationDb.LogReaderAgentProcessSecurity.Login = winLogin
publicationDb.LogReaderAgentProcessSecurity.Password = winPassword
' Explicitly set authentication mode for the Publisher connection
' to the default value of Windows Authentication.
publicationDb.LogReaderAgentPublisherSecurity.WindowsAuthentication = True
' Create the Log Reader Agent job.
publicationDb.CreateLogReaderAgent()
End If
Else
Throw New ApplicationException(String.Format( _
"The {0} database does not exist at {1}.", _
publicationDb, publisherName))
End If
' Set the required properties for the transactional publication.
publication = New TransPublication()
publication.ConnectionContext = conn
publication.Name = publicationName
publication.DatabaseName = publicationDbName
' Specify a transactional publication (the default).
publication.Type = PublicationType.Transactional
'Enable push and pull subscriptions and independent Distribition Agents.
publication.Attributes = _
publication.Attributes Or PublicationAttributes.AllowPull
publication.Attributes = _
publication.Attributes Or PublicationAttributes.AllowPush
publication.Attributes = _
publication.Attributes Or PublicationAttributes.IndependentAgent
' Activate the publication so that we can add subscriptions.
publication.Status = State.Active
' 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
If Not publication.IsExistingObject Then
' Create the transactional 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
本例将 AdventureWorks 数据库设置为支持合并发布,并且创建了 AdvWorksSalesOrdersMerge 发布。 仍然必须为此发布定义项目。 创建快照代理作业所需的 Windows 帐户凭据在运行时进行传递。 若要了解如何使用 RMO 定义合并项目,请参阅 Define an Article。
// 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
另请参阅
将 sqlcmd 与脚本变量结合使用
发布数据和数据库对象
复制管理对象概念
定义项目
查看和修改发布属性
配置分发
保护分发服务器
保护发布服务器