SQL Server 跨库同步数据

 1createPROCEDURE[dbo].[p_pm_项目平台客户批量同步到报销平台](
 2@destservernvarchar(50),
 3@sourceservernvarchar(50)
 4)
 5AS 6BEGIN 7 8SET NOCOUNT ON;
 9--不存在则添加链接服务器,外部查询必须指明IP地址,例如 select * from [IP].[database].[dbo].[table]10ifnotexists (select*from sys.servers where server_id!=0and data_source=@destserver)
11begin12exec sp_addlinkedserver    @server=@destserver13end14ifnotexists (select*from sys.servers where server_id!=0and data_source=@sourceserver)
15begin16exec sp_addlinkedserver    @server=@sourceserver17end18begin try  
19set xact_abort on20begintransaction21--http://www.cnblogs.com/chnking/archive/2007/04/04/699891.html 22INSERTINTO[192.168.0.10].[dbCRM].[dbo].[t_custom] (客户ID,
2324                                客户名称,
25                                客户简称,
26                                输入码,
27                                查询码,
28                                地址,
29                                录入登录名,
30                                录入时间,
31                                修改登录名,
32                                修改时间,
33                                审批状态ID,
34                                审批状态名称,
35                                是否审批结束,
36                                审批操作时间,
37                                项目管理客商编码,
38                                序号)
39SELECT 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‘,
45getdate(),
46null,
47null,
48‘D65F87A8-79C8-4D1C-812D-AE4591E056A8‘,
49‘已审批‘,
501,
51                                A.审批操作时间,
52                                A.项目管理客商编码,
53054FROM[dbPM].[dbo].[v_custom] A
55WHERE  A.客户ID NOTIN ( SELECT 客户ID FROM[192.168.0.10].[dbCRM].[dbo].[t_custom]);
56575859----------------------------------存在更新-----------------------------------                                                                60update   A  set61                             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.项目管理客商编码
69from[192.168.0.10].[dbCRM].[dbo].[t_custom] A,[dbPM].[dbo].[v_custom]  B 
70where A.客户ID=B.客户ID;
71727374committransaction75end try 
76begin catch 
77select ERROR_NUMBER() as errornumber,ERROR_MESSAGE() as errormsg,ERROR_LINE() as errorline
78rollbacktransaction79end catch
80END