富贵资源网 Design By www.hznty.com

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

SQL Server 跨库同步数据

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 跨库同步数据

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

富贵资源网 Design By www.hznty.com
广告合作:本站广告合作请联系QQ:858582 申请时备注:广告合作(否则不回)
免责声明:本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除!
富贵资源网 Design By www.hznty.com

《魔兽世界》大逃杀!60人新游玩模式《强袭风暴》3月21日上线

暴雪近日发布了《魔兽世界》10.2.6 更新内容,新游玩模式《强袭风暴》即将于3月21 日在亚服上线,届时玩家将前往阿拉希高地展开一场 60 人大逃杀对战。

艾泽拉斯的冒险者已经征服了艾泽拉斯的大地及遥远的彼岸。他们在对抗世界上最致命的敌人时展现出过人的手腕,并且成功阻止终结宇宙等级的威胁。当他们在为即将于《魔兽世界》资料片《地心之战》中来袭的萨拉塔斯势力做战斗准备时,他们还需要在熟悉的阿拉希高地面对一个全新的敌人──那就是彼此。在《巨龙崛起》10.2.6 更新的《强袭风暴》中,玩家将会进入一个全新的海盗主题大逃杀式限时活动,其中包含极高的风险和史诗级的奖励。

《强袭风暴》不是普通的战场,作为一个独立于主游戏之外的活动,玩家可以用大逃杀的风格来体验《魔兽世界》,不分职业、不分装备(除了你在赛局中捡到的),光是技巧和战略的强弱之分就能决定出谁才是能坚持到最后的赢家。本次活动将会开放单人和双人模式,玩家在加入海盗主题的预赛大厅区域前,可以从强袭风暴角色画面新增好友。游玩游戏将可以累计名望轨迹,《巨龙崛起》和《魔兽世界:巫妖王之怒 经典版》的玩家都可以获得奖励。