• 企业400电话
  • 微网小程序
  • AI电话机器人
  • 电商代运营
  • 全 部 栏 目

    企业400电话 网络优化推广 AI电话机器人 呼叫中心 网站建设 商标✡知产 微网小程序 电商运营 彩铃•短信 增值拓展业务
    SQL Server 跨库同步数据

    最近有个需求是要跨库进行数据同步,两个数据库分布在两台物理计算机上,自动定期同步可以通过SQL Server代理作业来实现,但是前提是需要编写一个存储过程来实现同步逻辑处理。这里的存储过程用的不是opendatasource,而是用的链接服务器来实现的。存储过程创建在IP1:192.168.0.3服务器上,需要将视图v_custom的客户信息同步到IP2:192.168.0.10服务器上的t_custom表中。逻辑是如果不存在则插入,存在则更新字段。

    create PROCEDURE [dbo].[p_pm_项目平台客户批量同步到报销平台](
      @destserver nvarchar(50),
      @sourceserver nvarchar(50)
    )
    AS
    BEGIN
    
      SET NOCOUNT ON;
      --不存在则添加链接服务器,外部查询必须指明IP地址,例如 select * from [IP].[database].[dbo].[table]
      if not exists (select * from sys.servers where server_id!=0 and data_source=@destserver)
      begin
        exec sp_addlinkedserver  @server=@destserver
      end
      if not exists (select * from sys.servers where server_id!=0 and data_source=@sourceserver)
      begin
        exec sp_addlinkedserver  @server=@sourceserver
      end
        begin try 
        set xact_abort on
        begin transaction 
                  INSERT INTO [192.168.0.10].[dbCRM].[dbo].[t_custom] (客户ID,
                    
                    客户名称,
                    客户简称,
                    输入码,
                    查询码,
                    地址,
                    录入登录名,
                    录入时间,
                    修改登录名,
                    修改时间,
                    审批状态ID,
                    审批状态名称,
                    是否审批结束,
                    审批操作时间,
                    项目管理客商编码,
                    序号)
            SELECT A.客户ID,A.客户名称,
                    A.客户简称,
                    dbo.fn_pm_GetPy(A.客户名称),
                    A.客户编号+','+A.客户名称+','+dbo.fn_pm_GetPy(A.客户名称)+','+A.客户简称+','+dbo.fn_pm_GetPy(A.客户简称),
                    A.地址,
                    'admin',
                    getdate(),
                    null,
                    null,
                    'D65F87A8-79C8-4D1C-812D-AE4591E056A8',
                    '已审批',
                    1,
                    A.审批操作时间,
                    A.项目管理客商编码,
                    0
            FROM  [dbPM].[dbo].[v_custom] A
            WHERE A.客户ID NOT IN ( SELECT 客户ID FROM  [192.168.0.10].[dbCRM].[dbo].[t_custom]);
          
                              
                                              
            ----------------------------------存在更新-----------------------------------                                
            update  A set 
                  A.客户名称=B.客户名称,
                  A.客户简称=B.客户简称,
                  A.输入码=dbo.fn_pm_GetPy(B.客户名称),
                  A.查询码=B.客户编号+','+B.客户名称+','+dbo.fn_pm_GetPy(B.客户名称)+','+B.客户简称+','+dbo.fn_pm_GetPy(B.客户简称),
                  A.地址=B.地址,
                  A.修改登录名='admin',
                  A.修改时间=getdate(),
                  A.项目管理客商编码 =B.项目管理客商编码
              from [192.168.0.10].[dbCRM].[dbo].[t_custom] A,[dbPM].[dbo].[v_custom] B 
              where A.客户ID=B.客户ID;
          
          
          
          commit transaction 
        end try 
        begin catch 
          select ERROR_NUMBER() as errornumber,ERROR_MESSAGE() as errormsg,ERROR_LINE() as errorline
          rollback transaction 
        end catch
    END
    

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

      可以参照如下的配置:

    以上就是SQL Server 跨库同步数据的实现方法,希望对大家的学习有所帮助。

    您可能感兴趣的文章:
    • SQLServer 跨库查询实现方法
    • MSSQLSERVER跨服务器连接(远程登录)的示例代码
    • SQL Server实现跨库跨服务器访问的方法
    上一篇:实例理解SQL中truncate和delete的区别
    下一篇:sql存储过程几个简单例子
  • 相关文章
  • 

    © 2016-2020 巨人网络通讯 版权所有

    《增值电信业务经营许可证》 苏ICP备15040257号-8

    SQL Server 跨库同步数据 SQL,Server,跨库,同步,数据,