SQL Server 跨库同步数据

这篇文章主要为大家详细介绍了SQL Server 跨库同步数据的实现方法,具有一定的参考价值,感兴趣的小伙伴们可以参考一下

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

SQL Server 跨库同步数据

?

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

77

78

79

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,

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 catch

END

  如果没有正确配置,经常会出现 消息 7391,级别 16,状态 2,过程 xxxxx,第 XX 行 。无法执行该操作,因为链接服务器 "xxxxx" 的 OLE DB 访问接口 "SQLNCLI" 无法启动分布式事务。

  可以参照如下的配置:

SQL Server 跨库同步数据

以上就是SQL Server 跨库同步数据的实现方法,希望对大家的学习有所帮助。

版权声明:本文(即:原文链接:https://www.qin1qin.com/catagory/26730/)内容由互联网用户自发投稿贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 630367839@qq.com 举报,一经查实,本站将立刻删除。

(0)
上一篇 2022-09-28 8:20:20
下一篇 2022-09-28 8:20:27

软件定制开发公司

相关阅读

发表回复

登录后才能评论
通知:禁止投稿所有关于虚拟货币,币圈类相关文章,发现立即永久封锁账户ID!