• SQL Server如何实现跨库同步数据
  • 苦丁茶 发表于 2016/2/18 11:38:00 | 分类标签: SQLServer 跨库 同步数据
  • 最近有个需求是要跨库进行数据同步,两个数据库分布在两台物理计算机上,自动定期同步可以通过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     begin
    12         exec sp_addlinkedserver    @server=@destserver
    13     end
    14     if not exists (select * from sys.servers where server_id!=0  and data_source=@sourceserver)
    15     begin
    16         exec sp_addlinkedserver    @server=@sourceserver
    17     end
    18         begin try  
    19         set xact_abort on
    20         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                                 0
    54                 FROM   [dbPM].[dbo].[v_custom] A
    55                 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 errorline
    78             rollback transaction 
    79         end catch
    80 END


    如果没有正确配置,经常会出现 消息 7391,级别 16,状态 2,过程 xxxxx,第 XX 行 。无法执行该操作,因为链接服务器 "xxxxx" 的 OLE DB 访问接口 "SQLNCLI" 无法启动分布式事务。

    可以参照如下的配置:

  • 请您注意

    ·自觉遵守:爱国、守法、自律、真实、文明的原则

    ·尊重网上道德,遵守《全国人大常委会关于维护互联网安全的决定》及中华人民共和国其他各项有关法律法规

    ·严禁发表危害国家安全,破坏民族团结、国家宗教政策和社会稳定,含侮辱、诽谤、教唆、淫秽等内容的作品

    ·承担一切因您的行为而直接或间接导致的民事或刑事法律责任

    ·您在编程中国社区新闻评论发表的作品,本网站有权在网站内保留、转载、引用或者删除

    ·参与本评论即表明您已经阅读并接受上述条款

  • 感谢本文作者
  • 作者头像
  • 昵称:苦丁茶
  • 加入时间:2013/6/19 0:00:00
  • TA的签名
  • 这家伙很懒,虾米都没写
  • +进入TA的空间
  • 以下内容也很赞哦
分享按钮