SQL Server 跨库同步数据

前端之家收集整理的这篇文章主要介绍了SQL Server 跨库同步数据前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。

最近有个需求是要跨库进行数据同步,两个数据库分布在两台物理计算机上,自动定期同步可以通过sql Server代理作业来实现,但是前提是需要编写一个存储过程来实现同步逻辑处理。这里的存储过程用的不是opendatasource,而是用的链接服务器来实现的。存储过程创建在IP1:192.168.0.3服务器上,需要将视图v_custom的客户信息同步到IP2:192.168.0.10服务器上的t_custom表中。逻辑是如果不存在则插入,存在则更新字段。

sql;"> 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,'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.客户<a href="https://www.jb51.cc/tag/mingcheng/" target="_blank" class="keywords">名称</a>=B.客户<a href="https://www.jb51.cc/tag/mingcheng/" target="_blank" class="keywords">名称</a>,A.客户简称=B.客户简称,A.输入码=dbo.fn_pm_GetPy(B.客户<a href="https://www.jb51.cc/tag/mingcheng/" target="_blank" class="keywords">名称</a>),A.<a href="https://www.jb51.cc/tag/chaxun/" target="_blank" class="keywords">查询</a>码=B.客户编号+','+B.客户<a href="https://www.jb51.cc/tag/mingcheng/" target="_blank" class="keywords">名称</a>+','+dbo.fn_pm_GetPy(B.客户<a href="https://www.jb51.cc/tag/mingcheng/" target="_blank" class="keywords">名称</a>)+','+B.客户简称+','+dbo.fn_pm_GetPy(B.客户简称),A.地址=B.地址,A.<a href="https://www.jb51.cc/tag/xiugai/" target="_blank" class="keywords">修改</a><a href="https://www.jb51.cc/tag/denglu/" target="_blank" class="keywords">登录</a>名='admin',A.<a href="https://www.jb51.cc/tag/xiugai/" target="_blank" class="keywords">修改</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 跨库同步数据的实现方法,希望对大家的学习有所帮助。

原文链接:https://www.f2er.com/mssql/62897.html

猜你在找的MsSQL相关文章