1. 本实例已完全通过测试,单向,又向同步都可使用.
  2. --名词说明:源——被同步的数据库
  3.             目的——要同步到的数据库
  4. 前6步必须执行,第6以后是一些辅助信息.
  5. --1、在目的数据库上,创建dblink
  6. drop public database link dblink_orc92_182;
  7. Create public DATABASE LINK dblink_orc92_182 CONNECT TO bst114 IDENTIFIED BY password USING ''orc92_192.168.254.111'';
  8. --dblink_orc92_182 是dblink_name
  9. --bst114 是 username
  10. --password 是 password
  11. --''orc92_192.168.254.111'' 是远程数据库名
  12. --2、在源和目的数据库上创建要同步的表(最好有主键约束,快照才可以快速刷新)
  13. drop table test_user;
  14. create table test_user(id number(10) primary key,name varchar2(12),age number(3));
  15. --3、在目的数据库上,测试dblink
  16. select * from test_user@dblink_orc92_182;    //查询的是源数据库的表
  17. select * from test_user;
  18. --4、在源数据库上,创建要同步表的快照日志
  19. Create snapshot log on test_user;
  20. --5、创建快照,在目的数据库上创建快照
  21. Create snapshot sn_test_user as select * from test_user@dblink_orc92_182;
  22. --6、设置快照刷新时间(只能选择一种刷新方式,推荐使用快速刷新,这样才可以用触发器双向同步)
  23. 快速刷新
  24. Alter snapshot sn_test_user refresh fast Start with sysdate next sysdate with primary key;
  25. --oracle马上自动快速刷新,以后不停的刷新,只能在测试时使用.真实项目要正确权衡刷新时间.
  26. 完全刷新
  27. Alter snapshot sn_test_user refresh complete Start with sysdate+30/24*60*60 next sysdate+30/24*60*60;
  28. --oracle自动在30秒后进行第一次完全刷新,以后每隔30秒完全刷新一次
  29. --7、手动刷新快照,在没有自动刷新的情况下,可以手动刷新快照.
  30. 手动刷新方式1
  31. begin
  32. dbms_refresh.refresh(''sn_test_user'');
  33. end;
  34. 手动刷新方式2
  35. EXEC DBMS_SNAPSHOT.REFRESH(''sn_test_user'',''F'');  //第一个参数是快照名,第二个参数 F 是快速刷新 C 是完全刷新.
  36. --8.修改会话时间格式
  37. ALTER SESSION SET NLS_DATE_FORMAT = ''YYYY-MM-DD HH24:MI:SS'';
  38. --9.查看快照最后一次刷新时间
  39. SELECT NAME,LAST_REFRESH FROM ALL_SNAPSHOT_REFRESH_TIMES;
  40. --10.查看快照下次执行时间
  41. select last_date,next_date,what from user_jobs order by next_date;
  42. --11.打印调试信息
  43. dbms_output.put_line(''use ''||''plsql'');
  44. --12.如果你只想单向同步,那么在目的数据库创建以下触发器(当源数据库表改变时,目的数据库表跟着改变,但目的数据库表改变时,源数据库表不改变).
  45. create or replace trigger TRI_test_user_AFR
  46.   after  insert or update or delete on sn_test_user
  47.   for each row
  48. begin
  49.   if deleting then
  50.       delete from test_user where id=:old.id;
  51.   end if;
  52.   if inserting then
  53.       insert into test_user(id,name)
  54.       values(:new.id,:new.name);
  55.   end if;
  56.   if updating then
  57.      update test_user set name=:new.name where id=:old.id;
  58.   end if;
  59. end TRI_test_user_AFR;
  60. --13.如果你想双向同步,请在源数据库中执行前6步,并在双方都创建以下触发器(当源数据库表改变时,目的数据库表跟着改变,目的数据库表改变时,源数据库表也改变)
  61. CREATE OR REPLACE TRIGGER BST114.TRI_TEST_USER_AFR
  62. AFTER DELETE OR INSERT OR UPDATE
  63. ON BST114.SN_TEST_USER 
  64. REFERENCING NEW AS NEW OLD AS OLD
  65. FOR EACH ROW
  66. declare
  67.     tmp_id number(10):=-1;
  68. begin
  69.   dbms_output.put_line(''begin'');
  70.   if inserting then
  71.       --select id into tmp_id from test_user where id=:new.id;    
  72.       for p in(select id from test_user where id=:new.id)
  73.       loop
  74.         tmp_id:=p.id;
  75.       end loop;
  76.       
  77.       dbms_output.put_line(tmp_id||''===------------'');
  78.       if (tmp_id=-1) then
  79.           insert into test_user(id,name,age)
  80.           values(:new.id,:new.name,:new.age);
  81.       end if;
  82.   end if;
  83.   
  84.   if updating then
  85.      dbms_output.put_line(''updated'');
  86.      for p in(select name,age from test_user where id=:old.id)
  87.      loop
  88.          if (p.name!=:new.name) or (p.age!=:new.age) then
  89.               update test_user set name=:new.name,age=:new.age where id=:old.id;
  90.          end if;
  91.      end loop;
  92.   end if;
  93.   
  94.   if deleting then
  95.       dbms_output.put_line(''deleted'');
  96.       delete from test_user where id=:old.id;
  97.   end if;
  98.   dbms_output.put_line(''end'');
  99. end TRI_test_user_AFR;
  100.  --为防止双向同步触发器死循环,所以要在触发器中增加一些判断,阻止死循环.
  101. --以上同步原理
  102. 1.首先创建一个dblink,可以访问远程数据库
  103. 2.在本地创建一个快照,映射远程数据表,当远程数据表有变化时,会反应到快照中.
  104. 3.由于快照类似于视图表,所以在本地为快照创建一个触发器,当快照有变化时,会触发相应事件.
  105. 4.在触发器中写同步数据的代码.
  106. --附:快照刷新时间参数说明
  107. 一天的秒数=24小时*60分钟*60钞
  108. 所以要想在30秒后刷新,参数应该这样写 sysdate+30/(24*60*60)
  109. 1分钟==sysdate+60/(24*60*60)
  110. 一天的分钟数=24小时*60分钟
  111. 一分钟也可以这样写 sysdate+1/(24*60)
  112. 30分钟==sysdate+30/(24*60)
  113. 60分钟==sysdate+60/(24*60)
  114. 以此类推
  115. 1小时==sysdate+1/24==sysdate+60/(24*60)
  116. 1天==sysdate+1
  117. 一个月==sysdate+30
  118. 文章出处:http://www.diybl.com/course/7_databases/oracle/oraclejs/200855/113330.html

发表于 @ 2008年11月21日 13:07:00|评论(0 )|收藏

新一篇: DELPHI成批插入数据库 | 旧一篇: 巧用dblink结合oracle快照实现两台服务器的数据同步