这周在搞数据同步的功能 说是什么数据c库到a库 a库到b库 现在要改成c库直接到b库 由于各种各样的原因吧 这两天才搞明白实现方案是:b库创建一个到c库的链接 然后写个存储过程 让sqlserver的作业定时执行这个存储过程 实现定时同步
上sql
1. 创建链接
代码语言:javascript复制-------------------链接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. 同步数据的存储过程
代码语言:javascript复制--从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表数据存在 做更新操作 如果不存在做插入操作
3. 作业
在这里搞个作业 步骤里添加EXEC spGetJzsJBXXFromMJZFPT
定时执行作业