栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 系统运维 > 数据库 > MySQL > MsSql

SQL Server 跨库同步数据

MsSql 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

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 跨库同步数据的实现方法,希望对大家的学习有所帮助。

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/169220.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号