SqlServer 使用脚本创建分发服务及事务复制的可更新订阅

Posted 2020-10-22 lonelyxmas

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了SqlServer 使用脚本创建分发服务及事务复制的可更新订阅相关的知识，希望对你有一定的参考价值。

【创建使用本地分发服务器】

/************************【使用本地分发服务器配置发布】***********************/  
--  SqlServer 2008 R2  
--  https://technet.microsoft.com/zh-cn/library/ms151860(v=sql.105).aspx  
use master  
go  
  
--  服务器上是否已安装分发服务器  
--  https://msdn.microsoft.com/zh-cn/library/ms190339(v=sql.105).aspx  
exec master.dbo.sp_get_distributor  
go  
  
--  配置分发服务器  
--  https://msdn.microsoft.com/zh-cn/library/ms176028(v=sql.105).aspx  
exec master.dbo.sp_adddistributor   
 @distributor = 'KK-PC'    --分发服务器名称  
,@heartbeat_interval = 10       --代理在不记录进度消息的情况下可以运行的最长分钟数  
,@password = N'123456'  --分发服务器密码  
go  
  
--  配置分发数据库  
--  https://msdn.microsoft.com/zh-cn/library/ms189755(v=sql.105).aspx  
exec master.dbo.sp_adddistributiondb   
 @database = N'distribution'    --要创建的分发数据库的名称  
,@data_folder = N'E:\TempFile\Distribution' --分发数据库数据文件的目录  
,@data_file = N'distribution'   --数据库文件的名称  
,@data_file_size = 5            --初始数据文件大小，以兆字节 (MB) 为单位  
,@log_folder = N'E:\TempFile\Distribution' ----分发数据库日志文件的目录  
,@log_file = N'distribution_log'   
,@log_file_size =  5            --初始日志文件大小，以兆字节 (MB) 为单位   
,@min_distretention = 0         --从分发数据库中删除事务前的最小保持期，以小时为单位  
,@max_distretention = 72        --删除事务前的最大保持期，以小时为单位   
,@history_retention = 48        --历史记录的保留时间，以小时为单位   
,@security_mode = 1             --同步时连接到分发服务器的安全模式。默认值为1:Windows验证,0: SQL验证   
,@login = N'KK-PC\SqlReplicator'   
,@password = N'123456'   
,@createmode = 1                --1:创建或使用现有数据库(instdist.sql)   
go  
  
--  配置发布服务器以使用指定的分发数据库  
--  https://msdn.microsoft.com/zh-cn/library/ms173807(v=sql.105).aspx  
exec master.dbo.sp_adddistpublisher   
 @publisher = N'KK-PC'         --发布服务器的名称  
,@distribution_db = N'distribution' --分发数据库的名称   
,@security_mode = 1                 --安全模式,默认1:Windows验证,0: SQL验证   
,@login = N'KK-PC\SqlReplicator'   
,@password = N'123456'   
,@working_directory = N'E:\TempFile\ReplData'--默认快照文件夹的UNC共享目录  
,@thirdparty_flag  = 0              --发布服务器是否是SQLServer,默认0:是,1:否  
,@publisher_type  = N'MSSQLSERVER'  --发布服务器类型:MSSQLSERVER(默认)/ORACLE/ORACLE GATEWAY  
go  
  
/*****配置完成!!*****/

/*****【查看分发属性】******/

--	检查分发数据库目录
exec master.dbo.xp_subdirs N'E:\TempFile\Distribution'

--	发布服务器的属性（在分发服务器任何数据库执行）
--	https://technet.microsoft.com/zh-cn/library/ms190323(v=sql.105).aspx
exec master.dbo.sp_helpdistpublisher N'KK-PC'

--	分发数据库的属性（在分发服务器的分发数据库上执行）
--	https://msdn.microsoft.com/zh-cn/library/vstudio/aa238917.aspx
exec master.dbo.sp_helpdistributiondb N'distribution'

--	列出有关分发服务器相关信息（在分发服务器任何数据库执行）
--	https://msdn.microsoft.com/zh-cn/library/ms177504(v=sql.105).aspx
exec master.dbo.sp_helpdistributor

/*****【删除分发】******/
--这里不必执行！


--	删除分发发布服务器（在分发服务器任何数据库执行）
--	https://technet.microsoft.com/zh-cn/library/ms188411(v=sql.105).aspx
exec master.dbo.sp_dropdistpublisher @publisher =  N'KK-PC',@no_checks = 0,@ignore_distributor = 0 --检查对象;连接分发;

--	删除分发数据库（在分发服务器任何数据库执行）
--	https://msdn.microsoft.com/zh-cn/library/ms188355(v=sql.105).aspx
exec master.dbo.sp_dropdistributiondb N'distribution';

--	卸载分发服务器（除分发数据库之外的任何数据库中执行）
--	https://technet.microsoft.com/zh-cn/library/ms173516(v=sql.105).aspx
exec master.dbo.sp_dropdistributor @no_checks = 0,@ignore_distributor = 0 --检查对象;连接分发;

【创建可更新订阅的事务发布】

/*************************************【创建发布】**************************************/
/*【实例:可更新订阅】

* A 为发布数据库,id为每个表的主键
* B,C 为订阅数据库
* A中符合条件 [id % 2 = 0] 的同步到B中
* A中符合条件 [id % 2 = 1] 的同步到C中
* 以下以 B 创建发布订阅
	
  当前发布数据库:[mytest]
  当前订阅数据库:[mytestA]
  
  
*/



--	作为发布的数据库
use [mytest]

--	设置指定数据库的复制数据库选项（发布服务器或订阅服务器执行）
--	http://msdn.microsoft.com/zh-cn/library/ms188769.aspx
exec sys.sp_replicationdboption @dbname = N'mytest', @optname = N'publish', @value = N'true'
go


--	为给定分发服务器添加队列读取器代理（在分发库或发布库执行）（每个实例默认只1个，已存在可不须再执行）
--	http://msdn.microsoft.com/ZH-CN/LIBRARY/ms189517
exec sys.sp_addqreader_agent @job_login = N'KK-PC\SqlReplicator', @job_password = N'123456', @job_name = null, @frompublisher = 1
go


--	为给定数据库添加日志读取器代理（在发布数据库执行）（每个数据库默认只1个，已存在可不须再执行）
--	http://technet.microsoft.com/zh-cn/library/ms189516.aspx
exec sys.sp_helplogreader_agent @publisher = null --查看当前数据库存在的日志代理
exec sys.sp_addlogreader_agent @job_login = N'KK-PC\SqlReplicator', @job_password = N'123456', @publisher_security_mode = 1, @job_name = null
go


/***************************【创建发布:以下用于1库多发布】******************************/

--	添加（可更新订阅）事务发布（在发布数据库执行）
--	http://msdn.microsoft.com/zh-cn/library/ms188738(v=sql.100).aspx
exec sys.sp_addpublication 
@publication = N'tran_repl',		--【指定发布名称】
@description = N'来自发布服务器“”的数据库“mytest”的具有可更新订阅的事务发布。', 
@sync_method = N'concurrent',			--同步模式:本机模式大容量复制程序输出
@retention = 0,							--订阅活动的保持期（小时）:默认值为336小时;0:订阅永不过期
@allow_push = N'true',					--推送订阅 
@allow_pull = N'true',					--允许创建请求订阅
@allow_anonymous = N'false',			--不可创建匿名订阅 
@enabled_for_internet = N'false',		--非Internet发布
@snapshot_in_defaultfolder = N'false',	--不指定快照默认文件夹,须设置@alt_snapshot_folder
@alt_snapshot_folder = N'E:\TempFile\ReplData',	--指定快照的备用文件夹的位置
@compress_snapshot = N'false',			--不压缩快照
@ftp_port = 21,							--默认分发服务器的FTP服务的端口号:21
@ftp_login = N'anonymous',				--默认用于连接到 FTP 服务的用户名:anonymous
@allow_subscription_copy = N'false',	--禁用复制订阅此发布的订阅数据库
@add_to_active_directory = N'false',	--（已不推荐使用）
@repl_freq = N'continuous',				--复制频率的类型:基于日志的事务的输出
@status = N'active',					--发布数据可立即用于订阅服务器
@independent_agent = N'true',			--【独立分发代理】
@immediate_sync = N'false',				--每次运行快照代理时不为发布创建同步文件
@allow_sync_tran = N'true',				--允许使用【立即更新订阅】
@autogen_sync_procs = N'true',			--在发布服务器上生成更新订阅的【同步存储过程】
@allow_queued_tran = N'true',			--在订阅服务器中启用更改的队列
@allow_dts = N'false',					--不允许数据转换
@conflict_policy = N'sub wins',			--排队更新订阅服务器选项时所遵从的冲突解决策略:【订阅入选】
@centralized_conflicts = N'true',		--在发布服务器上存储冲突记录
@conflict_retention = 14,				--冲突保持期（天）
@queue_type = N'sql',					--使用的队列类型:默认SQL Server存储事务
@replicate_ddl = 1,						--【支持架构复制】
@allow_initialize_from_backup = N'false', --不允许用备份初始化订阅
@enabled_for_p2p = N'false',			--非对等复制
@enabled_for_het_sub = N'false'			--只支持SQL Server订阅服务器
go


--	为指定的发布创建快照代理（在发布数据库执行）
--	http://msdn.microsoft.com/zh-cn/library/ms174958(v=sql.100)
exec sys.sp_addpublication_snapshot 
@publication = N'tran_repl',
@frequency_type = 1,
@frequency_interval = 0,
@frequency_relative_interval = 0,
@frequency_recurrence_factor = 0,
@frequency_subday = 0, 
@frequency_subday_interval = 0, 
@active_start_time_of_day = 0, 
@active_end_time_of_day = 235959, 
@active_start_date = 0, 
@active_end_date = 0, 
@job_login = N'KK-PC\SqlReplicator', 
@job_password = N'123456', 
@publisher_security_mode = 1
go


--	更改发布属性
--	https://msdn.microsoft.com/zh-cn/library/ms188413(v=sql.105).aspx
--	exec sys.sp_changepublication ……

技术分享图片

--	创建项目并将其添加到发布中（在发布数据库执行）
--	http://msdn.microsoft.com/zh-cn/library/ms173857

/*1. 添加可筛选的表(默认架构dbo)*/
declare @tableName			nvarchar(100)
declare @publName			nvarchar(100)
declare @mark				bit			-- 区分是否有sid的列，有则进行筛选
declare @filterNum			nvarchar(10)-- 一个数据库多个发布加编号区别
declare @filterClause		nvarchar(100)
declare @SQLaddarticle		nvarchar(max)
declare @SQLarticlefilter	nvarchar(max)
declare @SQLarticleview		nvarchar(max)
set @publName = N'tran_repl' --	【指定发布名称】
set @filterClause = N'dbo.f_SIDTOInt(SID) % 2 = 0' --	【指定行筛选】
select @filterNum = CONVERT(NVARCHAR(10),count(*)) from distribution.dbo.MSpublications
declare cur_addTable cursor local fast_forward
for 
	/*有主键 并且 有SID列(用于筛选)*/
	select name,1 mark from sys.tables t1(nolock) where is_ms_shipped = 0
	and exists(select 1 from sys.columns t2(nolock) where t1.object_id=t2.object_id and t2.name='SID')
	and name in(select table_name from information_schema.key_column_usage(nolock) 
		where objectproperty(object_id(constraint_name),'isprimarykey')=1 )
	union all
	/*有主键 并且 无SID列(不可筛选)*/
	select name,0 mark from sys.tables t1(nolock) where is_ms_shipped = 0
	and not exists(select 1 from sys.columns t2(nolock) where t1.object_id=t2.object_id and t2.name='SID')
	and name in(select table_name from information_schema.key_column_usage (nolock)
		where objectproperty(object_id(constraint_name),'isprimarykey')=1 )
open cur_addTable
fetch next from cur_addTable into @tableName,@mark
while @@fetch_status = 0
begin
	if ( @mark = 1 ) /*可筛选的表对象*/
	begin
		set @SQLaddarticle = N'
		exec sp_addarticle 
		@publication = N'''[email protected]+''', 
		@article = N'''[email protected]+''', 
		@source_owner = N''dbo'', 
		@source_object = N'''[email protected]me+''', 
		@type = N''logbased'', 
		@description = null, 
		@creation_script = null, 
		@pre_creation_cmd = N''drop'', 
		@schema_option = 0x0000000008035CDF, 
		@identityrangemanagementoption = N''none'', 
		@destination_table = N'''[email protected]+''', 
		@destination_owner = N''dbo'', 
		@status = 24,
		@vertical_partition = N''false'''
		exec(@SQLaddarticle)
		/*添加项目筛选器*/
		set @SQLarticlefilter = N' 
		exec sp_articlefilter 
		@publication = N'''[email protected]+''', 
		@article = N'''[email protected]+''', 
		@filter_name = N''FLTR_'[email protected]+'_'[email protected]+'__'+rtrim(ltrim(str(@@spid)))+''', 
		@filter_clause = N'''[email protected]+''', 
		@force_invalidate_snapshot = 1, 
		@force_reinit_subscription = 1'
		exec(@SQLarticlefilter)
		/*添加项目同步对象*/
		set @SQLarticleview = N'
		exec sp_articleview 
		@publication = N'''[email protected]+''', 
		@article = N'''[email protected]+''', 
		@view_name = N''SYNC_'[email protected]+'_'[email protected]+'__'+rtrim(ltrim(str(@@spid)))+''', 
		@filter_clause = N'''[email protected]+''', 
		@force_invalidate_snapshot = 1, 
		@force_reinit_subscription = 1'
		exec(@SQLarticleview)
		print '已筛选:'[email protected]
	end
	else if ( @mark = 0 )
	begin
		set @SQLaddarticle = N'
		exec sp_addarticle 
		@publication = N'''[email protected]+''', 
		@article = N'''[email protected]+''', 
		@source_owner = N''dbo'', 
		@source_object = N'''[email protected]+''', 
		@type = N''logbased'', 
		@description = null, 
		@creation_script = null, 
		@pre_creation_cmd = N''drop'', 
		@schema_option = 0x0000000008035CDF, 
		@identityrangemanagementoption = N''none'', 
		@destination_table = N'''[email protected]+''', 
		@destination_owner = N''dbo'', 
		@status = 24,
		@vertical_partition = N''false'''
		exec(@SQLaddarticle)
		print '无筛选:'[email protected]
	end
	fetch next from cur_addTable into @tableName,@mark
end
close cur_addTable
deallocate cur_addTable

/*2. 添加视图/存储过程/函数对象(默认架构dbo)*/
declare @publName		nvarchar(100)
declare @ObjectName		nvarchar(100)
declare @Type			nvarchar(30)
declare @ObjectType		nvarchar(30)
declare @SQLaddObject	nvarchar(max)
set @publName = N'tran_repl' --	【指定发布名称】
declare cur_addObject cursor local fast_forward
for select name,type from mytest.sys.objects where type in(N'P') and is_ms_shipped = 0
	union all
	select name,type from mytest.sys.objects a where type in(N'V') and is_ms_shipped = 0
	and exists(select 1 from mytest.sys.sql_modules b where a.object_id=b.object_id and is_schema_bound = 0)
	union all
	select name,N'B' as type from mytest.sys.objects a where type in(N'V') and is_ms_shipped = 0 
	and exists(select 1 from sys.sql_modules b where a.object_id=b.object_id and is_schema_bound = 1)/*架构绑定的索引视图*/
	union all
	select name,type from mytest.sys.objects where type in(N'TF',N'FN') and is_ms_shipped = 0
	order by type,name
open cur_addObject
fetch next from cur_addObject into @ObjectName,@ObjectType
while @@fetch_status = 0
begin
	SET @Type = 
	(
		CASE 
		WHEN @ObjectType = N'V' THEN N'view schema only'
		WHEN @ObjectType = N'B' THEN N'indexed view schema only'
		WHEN @ObjectType = N'P' THEN N'proc schema only'
		WHEN @ObjectType in(N'TF',N'FN') THEN N'func schema only'
		END
	)
	set @SQLaddObject = N'
	exec sp_addarticle 
	@publication = N'''[email protected]+''', 
	@article = N'''[email protected]+''', 
	@source_owner = N''dbo'', 
	@source_object = N'''[email protected]+''', 
	@type =  N'''[email protected]+''', 
	@description = null, 
	@creation_script = null, 
	@pre_creation_cmd = N''drop'', 
	@schema_option = 0x0000000008000001, 
	@status = 16,
	@destination_owner = N''dbo'', 
	@destination_table = N'''[email protected]+''''
	exec(@SQLaddObject)
	print @ObjectType+ '：' + @ObjectName
	fetch next from cur_addObject into @ObjectName,@ObjectType
end
close cur_addObject
deallocate cur_addObject

【创建订阅】

		
/***********************************【创建订阅】***************************************/
/*【要在发布服务器上运行的脚本】*/

use [mytest]

--	将订阅添加到发布并设置订阅服务器的状态
--	(警告: distribution 代理作业隐式创建，并将在 SQL Server 代理服务帐户下运行)
--	http://technet.microsoft.com/zh-cn/library/ms181702(v=sql.100).aspx
exec sys.sp_addsubscription 
@publication = N'tran_repl',	--指定发布名称
@subscriber = N'KK-PC',		--订阅服务器
@destination_db = N'mytestA',--订阅数据库
@subscription_type = N'Push',		--推送订阅
@sync_type = N'automatic',			--默认,已发布表的架构和初始数据将首先传输到订阅服务器
@article = N'all',					--发布所订阅的项目
@update_mode = N'queued failover',	--将订阅启用为排队更新订阅，并允许更改为立即更新模式
@subscriber_type = 0				--订阅服务器的类型：SQL Server订阅服务器
go

--	添加新的预定分发代理作业，以使推送订阅与事务发布同步
--	http://msdn.microsoft.com/zh-cn/library/ms175006(v=SQL.100)
exec sys.sp_addpushsubscription_agent 
@publication = N'tran_repl',	--指定发布名称
@subscriber = N'KK-PC',			--订阅服务器
@subscriber_db = N'mytestA',	--订阅数据库
@job_login = N'KK-PC\SqlReplicator', 
@job_password = N'123456', 
@subscriber_security_mode = 1,			--Windows 身份验证
@frequency_type = 64,					--分发代理计划的频率：自动启动(默认)
@frequency_interval = 1, 
@frequency_relative_interval = 1, 
@frequency_recurrence_factor = 0, 
@frequency_subday = 4, 
@frequency_subday_interval = 5, 
@active_start_time_of_day = 0, 
@active_end_time_of_day = 235959, 
@active_start_date = 0, 
@active_end_date = 0, 
@dts_package_location = N'Distributor'
go

/*【要在订阅服务器上运行的脚本】*/

use mytestA

--	设置在连接到发布服务器时立即更新订阅的同步触发器所使用的配置和安全信息
--	http://msdn.microsoft.com/zh-cn/library/ms174991(v=sql.100).aspx
exec sys.sp_link_publication 
@publisher = N'KK-PC', 
@publisher_db = N'mytest', 
@publication = N'tran_repl', 
@distributor = N'KK-PC', 
@security_mode = 1,		--SQL Server 身份验证或 Windows 身份验证
@login = N'KK-PC\SqlReplicator', 
@password = N'123456'
go

【启动快照并初始化】

/**********************************【启动快照并初始化】**************************************/
--	发布服务器发布数据
use [mytest]

--	对其请求订阅中的新项目的订阅添加到发布中（在发布服务器的发布数据库中执行）
--	https://technet.microsoft.com/zh-cn/library/ms181680(v=sql.100).aspx
--	exec sys.sp_refreshsubscriptions @publication = N'tran_repl'


--	将订阅标记为要重新初始化
--	https://msdn.microsoft.com/zh-cn/library/ms189469(v=sql.100).aspx
exec sys.sp_reinitsubscription 
@publication = N'tran_repl', 
@subscriber = N'KK-PC', 
@destination_db = N'mytestA', 
@article = N'all'
go

--	启动可为发布生成初始快照的快照代理作业（在发布服务器的发布数据库中执行）
--	http://msdn.microsoft.com/zh-cn/library/ms176026(v=sql.105).aspx
exec sys.sp_startpublication_snapshot @publication = N'tran_repl'
go

--	为所有表项目编写自定义 sp_MSins、sp_MSupd 和 sp_MSdel 过程的脚本
--	https://msdn.microsoft.com/zh-cn/library/ms187946(SQL.100).aspx
--exec sys.sp_scriptpublicationcustomprocs 'tran_repl'
--go


--	至此,完成发布订阅!!!~ 初始化完成!!~

技术分享图片

之前测试了N遍！！！~~今晚有空终于成功处理了！~

以上是关于SqlServer 使用脚本创建分发服务及事务复制的可更新订阅的主要内容，如果未能解决你的问题，请参考以下文章

SQLServer 发布订阅（Replication）造成的Memroy压力（cmemthread等待）

SQLServer 使用sp_repldone标识所有未分发的事务为已分发

使用远程分发器进行事务复制对 SQL Server 2008 的性能影响

如何处理SQL Server事务复制中的大事务操作

SQLServer 事务复制中使用脚本添加某个对象的发布

SQL Server 事务复制分发到订阅同步慢