45fan.com - 路饭网

搜索: 您的位置主页 > 网络频道 > 阅读资讯:SQL Server跨库进行同步数据的具体方法

SQL Server跨库进行同步数据的具体方法

2016-02-26 18:11:01 来源:www.45fan.com 【

SQL Server跨库进行同步数据的具体方法

最近有个需求是要跨库进行数据同步,两个数据库分布在两台物理计算机上,自动定期同步可以通过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 跨库同步数据的实现方法,希望对大家的学习有所帮助。


本文地址:http://www.45fan.com/a/question/40622.html
Tags: sql Server 跨库
编辑:路饭网
关于我们 | 联系我们 | 友情链接 | 网站地图 | Sitemap | App | 返回顶部