加入收藏 | 设为首页 | 会员中心 | 我要投稿 银川站长网 (https://www.0951zz.com/)- 云通信、基础存储、云上网络、机器学习、视觉智能!
当前位置: 首页 > 站长学院 > MsSql教程 > 正文

sql实现跨数据库数据同步的办法是什么

发布时间:2023-06-16 13:15:23 所属栏目:MsSql教程 来源:
导读: 本文给大家分享的是关于sql跨数据库数据同步的内容,下本有具体的实例,有一定的学习借鉴价值,需要的朋友可以了解一下。下面我们一起来看看sql是怎么实现跨数据库数据同步的吧。 最近有个需求是要跨库进行数

    本文给大家分享的是关于sql跨数据库数据同步的内容,下本有具体的实例,有一定的学习借鉴价值,需要的朋友可以了解一下。下面我们一起来看看sql是怎么实现跨数据库数据同步的吧。

     最近有个需求是要跨库进行数据同步,两个数据库分布在两台物理计算机上,自动定期同步可以通过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实现跨数据库数据同步的方法介绍了,有需要的朋友可以参考学习,希望大家阅读完这篇文章能有所收获,想要了解更多sql跨数据库数据同步的内容,可以继续关注其他文章。

(编辑:银川站长网)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

    推荐文章