SQL Server 跨库同步数据

 1 create PROCEDURE [dbo].[p_pm_项目平台客户批量同步到报销平台](
 2     @destserver nvarchar(50),
 3     @sourceserver nvarchar(50)
 4 )
 5 AS
 6 BEGIN
 7 
 8     SET NOCOUNT ON;
 9     --不存在则添加链接服务器,外部查询必须指明IP地址,例如 select * from [IP].[database].[dbo].[table]
10     if not exists (select * from sys.servers where server_id!=0  and data_source=@destserver)
11     begin
12         exec sp_addlinkedserver    @server=@destserver
13     end
14     if not exists (select * from sys.servers where server_id!=0  and data_source=@sourceserver)
15     begin
16         exec sp_addlinkedserver    @server=@sourceserver
17     end
18         begin try  
19         set xact_abort on
20         begin transaction 
21             --http://www.cnblogs.com/chnking/archive/2007/04/04/699891.html 
22                 INSERT INTO [192.168.0.10].[dbCRM].[dbo].[t_custom] (客户ID,
23                                 
24                                 客户名称,
25                                 客户简称,
26                                 输入码,
27                                 查询码,
28                                 地址,
29                                 录入登录名,
30                                 录入时间,
31                                 修改登录名,
32                                 修改时间,
33                                 审批状态ID,
34                                 审批状态名称,
35                                 是否审批结束,
36                                 审批操作时间,
37                                 项目管理客商编码,
38                                 序号)
39                 SELECT A.客户ID,A.客户名称,
40                                 A.客户简称,
41                                 dbo.fn_pm_GetPy(A.客户名称),
42                                 A.客户编号+','+A.客户名称+','+dbo.fn_pm_GetPy(A.客户名称)+','+A.客户简称+','+dbo.fn_pm_GetPy(A.客户简称),
43                                 A.地址,
44                                 'admin',
45                                 getdate(),
46                                 null,
47                                 null,
48                                 'D65F87A8-79C8-4D1C-812D-AE4591E056A8',
49                                 '已审批',
50                                 1,
51                                 A.审批操作时间,
52                                 A.项目管理客商编码,
53                                 0
54                 FROM   [dbPM].[dbo].[v_custom] A
55                 WHERE  A.客户ID NOT IN ( SELECT 客户ID FROM   [192.168.0.10].[dbCRM].[dbo].[t_custom]);
56             
57                                                     
58                                                                                     
59                 ----------------------------------存在更新-----------------------------------                                                                
60                 update   A  set  
61                             A.客户名称=B.客户名称,
62                             A.客户简称=B.客户简称,
63                             A.输入码=dbo.fn_pm_GetPy(B.客户名称),
64                             A.查询码=B.客户编号+','+B.客户名称+','+dbo.fn_pm_GetPy(B.客户名称)+','+B.客户简称+','+dbo.fn_pm_GetPy(B.客户简称),
65                             A.地址=B.地址,
66                             A.修改登录名='admin',
67                             A.修改时间=getdate(),
68                             A.项目管理客商编码 =B.项目管理客商编码
69                     from  [192.168.0.10].[dbCRM].[dbo].[t_custom] A,[dbPM].[dbo].[v_custom]  B 
70                     where A.客户ID=B.客户ID;
71             
72             
73             
74             commit transaction 
75         end try 
76         begin catch 
77             select ERROR_NUMBER() as errornumber,ERROR_MESSAGE() as errormsg,ERROR_LINE() as errorline
78             rollback transaction 
79         end catch
80 END