1. 程式人生 > >SQL Server 跨庫同步資料

SQL Server 跨庫同步資料

下載網站:www.SyncNavigator.CN 

 ----------------------------------------------------------

HKROnline SyncNavigator 8.4.1 非破解版 註冊機 授權啟用教程

最近有個需求是要跨庫進行資料同步,兩個資料庫分佈在兩臺物理計算機上,自動定期同步可以通過SQL Server代理作業來實現,但是前提是需要編寫一個儲存過程來實現同步邏輯處理。這裡的儲存過程用的不是opendatasource,而是用的連結伺服器來實現的。儲存過程建立在IP1:192.168.0.3伺服器上,需要將檢視v_custom的客戶資訊同步到IP2:192.168.0.10伺服器上的t_custom表中。邏輯是如果不存在則插入,存在則更新欄位。

 

複製程式碼

 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 
[email protected]
) 11 begin 12 exec sp_addlinkedserver @[email protected] 13 end 14 if not exists (select * from sys.servers where server_id!=0 and dat[email protected]) 15 begin 16 exec sp_addlinkedserver @[email protected] 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

複製程式碼

如果沒有正確配置,經常會出現 訊息 7391,級別 16,狀態 2,過程 xxxxx,第 XX 行 。無法執行該操作,因為連結伺服器 "xxxxx" 的 OLE DB 訪問介面 "SQLNCLI" 無法啟動分散式事務。

  可以參照如下的配置: