SQL Server 跨库同步数据

 更新时间:2016年02月21日 09:58:34   投稿:lijiao  
这篇文章主要为大家详细介绍了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 查询时日期格式化语句

    SqlServer 查询时日期格式化语句

    这篇文章主要介绍了SqlServer 查询时日期格式化语句,在文中给大家补充介绍了Sql Server关于日期查询时,如果表中日期到具体某个时间,具体内容大家参考下本文
    2018-03-03
  • SqlServer表死锁的解决方法分享

    SqlServer表死锁的解决方法分享

    前些天写一个存储过程,存储过程中使用了事务,后来我把一些代码注释掉来进行调试找错,突然发现一张表被锁住了,原来是创建事务的代码忘记注释掉。本文表锁住了的解决方法。
    2011-08-08
  • SQL语句实现查询Index使用状况

    SQL语句实现查询Index使用状况

    这篇文章主要介绍了SQL语句实现查询Index使用状况,本文直接给出SQL脚本代码,需要的朋友可以参考下
    2015-07-07
  • SQL Server 2012 身份验证(Authentication)

    SQL Server 2012 身份验证(Authentication)

    这篇SQL Server安全文章,我们学习了SQL Server里的多个验证选项。Windows集成身份验证是最安全的,但并不是都是可行的,微软多年来已经让SQL Server验证更加安全。
    2016-04-04
  • SQL SERVER迁移之更换磁盘文件夹的完整步骤

    SQL SERVER迁移之更换磁盘文件夹的完整步骤

    这篇文章主要给大家介绍了关于SQL SERVER迁移之更换磁盘文件夹的完整步骤,文中通过图文介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-10-10
  • SQL SERVER 2012新增函数之字符串函数FORMAT详解

    SQL SERVER 2012新增函数之字符串函数FORMAT详解

    这篇文章主要给大家介绍了关于SQL SERVER 2012新增函数之字符串函数FORMAT的相关资料,文中通过实例介绍的非常详细,对大家具有一定的参考价值,需要的朋友们下面来一起看看吧。
    2017-03-03
  • SQL Server 公用表表达式(CTE)实现递归的方法

    SQL Server 公用表表达式(CTE)实现递归的方法

    这篇文章主要介绍了SQL Server 公用表表达式(CTE)实现递归的方法,需要的朋友可以参考下
    2017-05-05
  • 数据库日常练习题,每天进步一点点(1)

    数据库日常练习题,每天进步一点点(1)

    下面小编就为大家带来一篇数据库基础的几道练习题(分享)。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧,希望可以帮到你
    2021-07-07
  • sql server字符串非空判断实现方法

    sql server字符串非空判断实现方法

    在使用sql server过程中会遇到非空判断,本文将详细介绍sql server字符串非空判断实现方法,需要了解的朋友可以参考下
    2012-12-12
  • win11安装sqlserver失败的详细解决方案

    win11安装sqlserver失败的详细解决方案

    这篇文章主要给大家介绍了关于win11安装sqlserver失败的详细解决方案,文中通过图文介绍的非常详细,对大家学习或者SqlServer具有一定的参考学习价值,需要的朋友可以参考下
    2023-04-04

最新评论