SQL Server 跨库同步数据
16lz
2022-01-08
最近有个需求是要跨库进行数据同步,两个数据库分布在两台物理计算机上,自动定期同步可以通过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
可以参照如下的配置:
更多相关文章
- SQL Server之JSON 函数详解
- MySQL 5.7.9 服务无法启动-“NET HELPMSG 3534”的解决方法
- MySQL系列多表连接查询92及99语法示例详解教程
- Linux下MYSQL 5.7 找回root密码的问题(亲测可用)
- MySQL 什么时候使用INNER JOIN 或 LEFT JOIN
- mybatisplus的坑 insert标签insert into select无参数问题的解决
- python起点网月票榜字体反爬案例
- 《Android开发从零开始》——25.数据存储(4)
- Android系统配置数据库注释(settings.db)