图片 2

跨库同步数据

  近年来有个供给是要跨库举行多少同步,多少个数据库遍布在两台物理Computer上,自动准时联合能够通过SQL
Server代理作业来促成,可是前提是内需编制三个囤积进度来达成协同逻辑管理。这里的仓库储存进程用的不是opendatasource,而是用的链接服务器来得以完成的。存款和储蓄进程创制在IP1:192.168.0.3服务器上,供给将视图v_custom的客户消息同步到IP2:192.168.0.10服务器上的t_custom表中。逻辑是借使不设有则插入,存在则更新字段。

图片 1

    

 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

  若无精确配置,平时会见世 音讯 7391,等级 16,状态 2,进程 xxxxx,第 XX
行 。无法实施该操作,因为链接服务器 “xxxxx” 的 OLE
DB 访谈接口 “SQLNCLI” 不能够运营遍布式事务。

  能够参见如下的配置:

图片 2

 具体能够仿照效法: 

发表评论

电子邮件地址不会被公开。 必填项已用*标注