最近有个需求是要跨库进行数据同步,两个数据库分布在两台物理计算机上,自动定期同步可以通过SQL Server代理作业来实现,但是前提是需要编写一个存储过程来实现同步逻辑处理。这里的存储过程用的不是opendatasource,而是用的链接服务器来实现的。存储过程创建在IP1:19 ...
最近有个需求是要跨库进行数据同步,两个数据库分布在两台物理计算机上,自动定期同步可以通过SQL Server代理作业来实现,但是前提是需要编写一个存储过程来实现同步逻辑处理。这里的存储过程用的不是opendatasource,而是用的链接服务器来实现的。存储过程创建在IP1:192.168.0.3服务器上,需要将视图v_custom的客户信息同步到IP2:192.168.0.10服务器上的t_custom表中。逻辑是如果不存在则插入,存在则更新字段。
1 create PROCEDURE [dbo].[p_pm_项目平台客户批量同步到报销平台]( 2 @destserver nvarchar(50), 3 @sourceserver nvarchar(50) 4 ) 5 AS 6 BEGIN 7 8 SET NOCOUNT ON; 9 --不存在则添加链接服务器,外部查询必须指明IP地址,例如 select * from [IP].[database].[dbo].[table]10 if not exists (select * from sys.servers where server_id!=0 and data_source=@destserver)11 begin12 exec sp_addlinkedserver @server=@destserver13 end14 if not exists (select * from sys.servers where server_id!=0 and data_source=@sourceserver)15 begin16 exec sp_addlinkedserver @server=@sourceserver17 end18 begin try 19 set xact_abort on20 begin transaction 21 --http://www.cnblogs.com/chnking/archive/2007/04/04/699891.html 22 INSERT INTO [192.168.0.10].[dbCRM].[dbo].[t_custom] (客户ID,23 24 客户名称,25 客户简称,26 输入码,27 查询码,28 地址,29 录入登录名,30 录入时间,31 修改登录名,32 修改时间,33 审批状态ID,34 审批状态名称,35 是否审批结束,36 审批操作时间,37 项目管理客商编码,38 序号)39 SELECT A.客户ID,A.客户名称,40 A.客户简称,41 dbo.fn_pm_GetPy(A.客户名称),42 A.客户编号+','+A.客户名称+','+dbo.fn_pm_GetPy(A.客户名称)+','+A.客户简称+','+dbo.fn_pm_GetPy(A.客户简称),43 A.地址,44 'admin',45 getdate(),46 null,47 null,48 'D65F87A8-79C8-4D1C-812D-AE4591E056A8',49 '已审批',50 1,51 A.审批操作时间,52 A.项目管理客商编码,53 054 FROM [dbPM].[dbo].[v_custom] A55 WHERE A.客户ID NOT IN ( SELECT 客户ID FROM [192.168.0.10].[dbCRM].[dbo].[t_custom]);56 57 58 59 ----------------------------------存在更新----------------------------------- 60 update A set 61 A.客户名称=B.客户名称,62 A.客户简称=B.客户简称,63 A.输入码=dbo.fn_pm_GetPy(B.客户名称),64 A.查询码=B.客户编号+','+B.客户名称+','+dbo.fn_pm_GetPy(B.客户名称)+','+B.客户简称+','+dbo.fn_pm_GetPy(B.客户简称),65 A.地址=B.地址,66 A.修改登录名='admin',67 A.修改时间=getdate(),68 A.项目管理客商编码 =B.项目管理客商编码69 from [192.168.0.10].[dbCRM].[dbo].[t_custom] A,[dbPM].[dbo].[v_custom] B 70 where A.客户ID=B.客户ID;71 72 73 74 commit transaction 75 end try 76 begin catch 77 select ERROR_NUMBER() as errornumber,ERROR_MESSAGE() as errormsg,ERROR_LINE() as errorline78 rollback transaction 79 end catch80 END
原标题:SQL Server 跨库同步数据
关键词:sql
*特别声明:以上内容来自于网络收集,著作权属原作者所有,如有侵权,请联系我们:
admin#shaoqun.com
(#换成@)。