最近有个需求是要跨库进行数据同步，两个数据库分布在两台物理计算机上，自动定期同步可以通过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
如果没有正确配置，经常会出现 消息 7391，级别 16，状态 2，过程 xxxxx，第 xx 行 。无法执行该操作，因为链接服务器 “xxxxx” 的 ole db 访问接口 “sqlncli” 无法启动分布式事务。
可以参照如下的配置：
以上就是sql server 跨库同步数据的实现方法，希望对大家的学习有所帮助。