首页 > 资讯列表 > 编程/数据库 >> 数据库操作教程

SQLServer跨库同步数据

数据库操作教程 2022-09-23 17:45:55 转载来源: 网络整理/侵权必删

最近有个需求是要跨库进行数据同步,两个数据库分布在两台物理计算机上,自动定期同步可以通过SQLServer代理作业来实现,但是前提是需要编写一个存储过程来实现同步逻辑处理。这里的存储过程用的不是opendatasource,而是用的链接服务器来实现的

最近有个需求是要跨库进行数据同步,两个数据库分布在两台物理计算机上,自动定期同步可以通过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))ASBEGIN  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 catchEND

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

  可以参照如下的配置:

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

标签: SQLServer 跨库 同步 数据


声明:本文内容来源自网络,文字、图片等素材版权属于原作者,平台转载素材出于传递更多信息,文章内容仅供参考与学习,切勿作为商业目的使用。如果侵害了您的合法权益,请您及时与我们联系,我们会在第一时间进行处理!我们尊重版权,也致力于保护版权,站搜网感谢您的分享!

站长搜索

http://www.adminso.com

Copyright @ 2007~2024 All Rights Reserved.

Powered By 站长搜索

打开手机扫描上面的二维码打开手机版


使用手机软件扫描微信二维码

关注我们可获取更多热点资讯

站长搜索目录系统技术支持