1. 本實例已完全通過測試,單向,又向同步都可使用.
  3. --名詞說明：源——被同步的數據庫
  4.             目的——要同步到的數據庫
  6. 前6步必須執行,第6以后是一些輔助信息.
  8. --1、在目的數據庫上，創建dblink
  9. drop public database link dblink_orc92_182;
  10. Create public DATABASE LINK dblink_orc92_182 CONNECT TO bst114 IDENTIFIED BY password USING ''orc92_192.168.254.111'';
  11. --dblink_orc92_182 是dblink_name
  12. --bst114 是 username
  13. --password 是 password
  14. --''orc92_192.168.254.111'' 是遠程數據庫名
  17. --2、在源和目的數據庫上創建要同步的表(最好有主鍵約束,快照才可以快速刷新)
  18. drop table test_user;
  19. create table test_user(id number(10) primary key,name varchar2(12),age number(3));
  21. --3、在目的數據庫上，測試dblink
  22. select * from test_user@dblink_orc92_182;    //查詢的是源數據庫的表
  23. select * from test_user;
  25. --4、在源數據庫上，創建要同步表的快照日志
  26. Create snapshot log on test_user;
  28. --5、創建快照，在目的數據庫上創建快照
  29. Create snapshot sn_test_user as select * from test_user@dblink_orc92_182;
  31. --6、設置快照刷新時間(只能選擇一種刷新方式,推薦使用快速刷新,這樣才可以用觸發器雙向同步)
  32. 快速刷新
  33. Alter snapshot sn_test_user refresh fast Start with sysdate next sysdate with primary key;
  34. --oracle馬上自動快速刷新，以后不停的刷新,只能在測試時使用.真實項目要正確權衡刷新時間.
  36. 完全刷新
  37. Alter snapshot sn_test_user refresh complete Start with sysdate+30/24*60*60 next sysdate+30/24*60*60;
  38. --oracle自動在30秒后進行第一次完全刷新，以后每隔30秒完全刷新一次
  40. --7、手動刷新快照,在沒有自動刷新的情況下,可以手動刷新快照.
  41. 手動刷新方式1
  42. begin
  43. dbms_refresh.refresh(''sn_test_user'');
  44. end;
  46. 手動刷新方式2
  47. EXEC DBMS_SNAPSHOT.REFRESH(''sn_test_user'',''F'');  //第一個參數是快照名,第二個參數 F 是快速刷新 C 是完全刷新.
  49. --8.修改會話時間格式
  50. ALTER SESSION SET NLS_DATE_FORMAT = ''YYYY-MM-DD HH24:MI:SS'';
  52. --9.查看快照最后一次刷新時間
  53. SELECT NAME,LAST_REFRESH FROM ALL_SNAPSHOT_REFRESH_TIMES;
  55. --10.查看快照下次執行時間
  56. select last_date,next_date,what from user_jobs order by next_date;
  58. --11.打印調試信息
  59. dbms_output.put_line(''use ''||''plsql'');
  61. --12.如果你只想單向同步,那么在目的數據庫創建以下觸發器(當源數據庫表改變時,目的數據庫表跟著改變,但目的數據庫表改變時,源數據庫表不改變).
  62. create or replace trigger TRI_test_user_AFR
  63.   after  insert or update or delete on sn_test_user
  64.   for each row
  65. begin
  66.   if deleting then
  67.       delete from test_user where id=:old.id;
  68.   end if;
  69.   if inserting then
  70.       insert into test_user(id,name)
  71.       values(:new.id,:new.name);
  72.   end if;
  73.   if updating then
  74.      update test_user set name=:new.name where id=:old.id;
  75.   end if;
  76. end TRI_test_user_AFR;
  78. --13.如果你想雙向同步,請在源數據庫中執行前6步,并在雙方都創建以下觸發器(當源數據庫表改變時,目的數據庫表跟著改變,目的數據庫表改變時,源數據庫表也改變)
  79. CREATE OR REPLACE TRIGGER BST114.TRI_TEST_USER_AFR
  80. AFTER DELETE OR INSERT OR UPDATE
  81. ON BST114.SN_TEST_USER 
  82. REFERENCING NEW AS NEW OLD AS OLD
  83. FOR EACH ROW
  84. declare
  85.     tmp_id number(10):=-1;
  86. begin
  88.   dbms_output.put_line(''begin'');
  89.   if inserting then
  90.       --select id into tmp_id from test_user where id=:new.id;    
  91.       for p in(select id from test_user where id=:new.id)
  92.       loop
  93.         tmp_id:=p.id;
  94.       end loop;
  95.       
  96.       dbms_output.put_line(tmp_id||''===------------'');
  97.       if (tmp_id=-1) then
  98.           insert into test_user(id,name,age)
  99.           values(:new.id,:new.name,:new.age);
  100.       end if;
  101.   end if;
  102.   
  103.   if updating then
  104.      dbms_output.put_line(''updated'');
  105.      for p in(select name,age from test_user where id=:old.id)
  106.      loop
  107.          if (p.name!=:new.name) or (p.age!=:new.age) then
  108.               update test_user set name=:new.name,age=:new.age where id=:old.id;
  109.          end if;
  110.      end loop;
  111.   end if;
  112.   
  113.   if deleting then
  114.       dbms_output.put_line(''deleted'');
  115.       delete from test_user where id=:old.id;
  116.   end if;
  117.   dbms_output.put_line(''end'');
  118. end TRI_test_user_AFR;
  119.  --為防止雙向同步觸發器死循環,所以要在觸發器中增加一些判斷,阻止死循環.
  121. --以上同步原理
  122. 1.首先創建一個dblink,可以訪問遠程數據庫
  123. 2.在本地創建一個快照,映射遠程數據表,當遠程數據表有變化時,會反應到快照中.
  124. 3.由于快照類似于視圖表,所以在本地為快照創建一個觸發器,當快照有變化時,會觸發相應事件.
  125. 4.在觸發器中寫同步數據的代碼.
  127. --附:快照刷新時間參數說明
  128. 一天的秒數=24小時*60分鐘*60鈔
  129. 所以要想在30秒后刷新,參數應該這樣寫 sysdate+30/(24*60*60)
  130. 1分鐘==sysdate+60/(24*60*60)
  132. 一天的分鐘數=24小時*60分鐘
  133. 一分鐘也可以這樣寫 sysdate+1/(24*60)
  134. 30分鐘==sysdate+30/(24*60)
  135. 60分鐘==sysdate+60/(24*60)
  137. 以此類推
  138. 1小時==sysdate+1/24==sysdate+60/(24*60)
  139. 1天==sysdate+1
  140. 一個月==sysdate+30
  142. 文章出處：http://www.diybl.com/course/7_databases/oracle/oraclejs/200855/113330.html

發表于 @ 2008年11月21日 13:07:00|評論(0 )|收藏

新一篇: DELPHI成批插入數據庫 | 舊一篇: 巧用dblink結合oracle快照實現兩臺服務器的數據同步