sqlserver表结构不同实现数据同步

周杰伦本人

发布于 2022-10-25 16:17:52

7290

发布于 2022-10-25 16:17:52

文章被收录于专栏：同步文章

这周在搞数据同步的功能说是什么数据c库到a库 a库到b库现在要改成c库直接到b库由于各种各样的原因吧这两天才搞明白实现方案是：b库创建一个到c库的链接然后写个存储过程让sqlserver的作业定时执行这个存储过程实现定时同步

上sql

1. 创建链接

-------------------链接C库------------------
EXEC  sp_addlinkedserver
@server='MJZFPT',   --链接服务器别名
@srvproduct='',
@provider='SQLOLEDB',
@datasrc='172.16.111.111'  --要访问的的数据库所在的服务器的ip
GO
EXEC sp_addlinkedsrvlogin
'MJZFPT',                  --链接服务器别名
'false', 
 NULL,
'sa',                     --要访问的数据库的用户              
'111'                    --要访问的数据库，用户的密码
GO
exec sp_serveroption 'MJZFPT','rpc out','true'
GO
exec sp_serveroption 'MJZFPT','rpc','true'
GO

2. 同步数据的存储过程

--从C库获取基本信息 
use DB_JY

go

create PROCEDURE [dbo].[spGetJzsJBXXFromMJZFPT]
AS
BEGIN
	-- routine body goes here, e.g.
	-- SELECT 'Navicat for SQL Server'
	
	MERGE DB_JY.dbo.T_ZF_JBXX AS T
		USING (SELECT  DBO.FN_INNEREX_GETZFXH(C_ZFBH) N_ZFXH
      ,[C_ZFBH] 
      ,[C_XM]  
      ,[C_XB]
      ,[D_CSRQ]
      ,[C_MZ]
      ,[C_JG]
      ,[C_FYLB]
      ,[D_RJRQ]
      ,[C_SZJY]
      ,[C_SZJQ] C_SZFJQ
      ,[C_ZYBS] N_ZYBS
  FROM MJZFPT.[DB_ZF].[dbo].[T_ZF]
	WHERE C_SZJY in ('73878031185de329fa6876725c100013','73878031185de329fa6876725c100014','73878031185de329fa6876725c100015')
	--and C_ZFBH='1101016609'
		) AS S
		ON (T.N_ZFXH = S.N_ZFXH)
		WHEN MATCHED THEN
		UPDATE SET N_ZFXH = S.N_ZFXH, C_ZFBH = S.C_ZFBH, C_XM = S.C_XM, C_XB = S.C_XB, 
		D_CSRQ = S.D_CSRQ, C_MZ = S.C_MZ, C_JG = S.C_JG, C_FYLB = S.C_FYLB, D_RJRQ = S.D_RJRQ, C_SZJY = S.C_SZJY, 
		C_SZFJQ = S.C_SZFJQ,N_ZYBS=S.N_ZYBS
		WHEN NOT MATCHED BY TARGET THEN
		INSERT (N_ZFXH, C_ZFBH, C_XM, C_XB, D_CSRQ, C_MZ, C_JG, C_FYLB, D_RJRQ, C_SZJY, C_SZFJQ,N_ZYBS) 
		VALUES (S.N_ZFXH, S.C_ZFBH, S.C_XM, S.C_XB, S.D_CSRQ, S.C_MZ, S.C_JG, S.C_FYLB, S.D_RJRQ, S.C_SZJY, S.C_SZFJQ,N_ZYBS);
		
END

思路就是两个表根据N_ZFXH字段进行对比如果匹配说明T表数据存在做更新操作如果不存在做插入操作