Welcome 微信登录

首页 / 数据库 / MySQL / 利用dblink实现Oracle对Oracle数据库的同步

利用dblink 做Oracle到oracle的定时同步,以刚为卡中心做的一个同步为例推荐阅读:利用Oracle DBLink进行表同步 http://www.linuxidc.com/Linux/2012-01/52479.htmOracle DBLink使用 http://www.linuxidc.com/Linux/2013-05/84961.htmOracle通过DBLink访问GreenPlum  http://www.linuxidc.com/Linux/2013-05/84284.htmORA-01017/ORA-02063 DBLink建立错误问题分析及解决 http://www.linuxidc.com/Linux/2013-01/78778.htmOracle 创建DBLink 报错:ORA-01017、ORA-02063 http://www.linuxidc.com/Linux/2013-01/78319.htm1、创建需要的dblink连接的数据库(若已经有,则不需要)
 
例:
查看 dblink :  select * from dba_db_links;
 
创建 dblink :
 
create database link ECARDRYXX
  connect to WPENG
  using "(DESCRIPTION =
    (ADDRESS_LIST =
      (ADDRESS = (PROTOCOL = TCP)(HOST = 202.120.85.118)(PORT = 1521))
    )
    (CONNECT_DATA =
      (SID = ORA92)
    )
  )";
 
 
2. 创建需要同步到对方数据的视图:
 
例:
create or replace view ryxx as
select ryjbxx.userid outid, xyzzjg.bmmc college, xszzjg.bmmc departname, ryjbxx.major,
     ryjbxx.typeof, ryjbxx.sfsf, ryjbxx.cn, ryjbxx.email, decode(sys_user.STATUS, "2", "Yes", "4", "No", "No") inetUserStatus
     from

select t1.xh userid, t1.xym , t1.xsm , t2.zymc major,
     "student" typeof, t1.sfsf sfsf, t1.xm cn, t1.dzxx email
     from idc_u_xs.xs_xsjbxx t1, idc_u_jwmis.jw_zyxx t2
     where  t1.zyh = t2.zydh(+)                                               -- 本科生
union all
select t1.xh userid, t1.xym, t1.xsm, t2.zymc, "student" typeof, "" sfsf, t1.xm cn, t1.email email
     from idc_u_yjs.yjs_yjsjbxx t1, idc_u_yjs.yjs_dict_bsxkzydm t2
     where t1.zydm = t2.zydm(+)                                                  -- 研究生
union all
select t1.zgh userid, "" xym, "" xsm, "" major, "teacher" typeof, "" sfsf,  t1.xm cn, t1.dzxx email
     from idc_u_rs.rs_zzryjbxx t1                                                --  在职人员
union all
select t1.zgh userid, "" xym, "" xsm, "" major, "teacher" typeof, "" sfsf,  t1.xm cn, t1.dzxx email
     from idc_u_rs.rs_xjrylsb t1                                               -- 新增人员
) ryjbxx, idc_u_pub.sys_user, idc_u_rs.rs_zzjg xyzzjg, idc_u_rs.rs_zzjg xszzjg
where
      ryjbxx.userid = sys_user.userid
      and ryjbxx.xym = xyzzjg.bmbh(+)    --  学院组织机构
      and ryjbxx.xym = xszzjg.bmbh(+)    -- 院系组织机构3. 创建需要执行同步的pl/sql :
 
例如:
 为了使用更模块化,更集中,建议同面向同一个库的pl/sql,写在同一个包下。
 
CREATE OR REPLACE PACKAGE ECARD IS
     PROCEDURE RYXXSYNC;
END;
 
CREATE OR REPLACE PACKAGE BODY ECARD IS
     PROCEDURE RYXXSYNC IS
     BEGIN
            delete from wpeng.ryxx@ecardryxx; --删除数据
            insert into wpeng.ryxx@ecardryxx(outid, college, departname, major, typeof, sfsf, cn, email, inetuserstatus)
                 select outid, college, departname, major, typeof, sfsf, cn, email, inetuserstatus from ryxx;  --插入最新数据
     END;
END;
 4. 创建job,定时执行同步:
 
例:
打开 sql命令窗口:
 
variable ryxxsyncjob number;
 
 
begin
   dbms_job.submit(:ryxxsyncjob, "ECARD.RYXXSYNC;",
                                 SYSDATE, "TRUNC(SYSDATE) + 1 + 2/24");  --每天凌晨两点执行。
   commit;
end;更多Oracle相关信息见Oracle 专题页面 http://www.linuxidc.com/topicnews.aspx?tid=12从远程Oracle服务器上同步复制数据到本地备份库Oracle中dblink创建的两种方式相关资讯      DBLINK  Oracle dblink 
  • Oracle dblink配置  (今 07:31)
  • Oracle DATABASE LINK(DBLINK)创建  (01月21日)
  • Oracle DBLink创建和维护以及ORA-  (07/08/2015 08:38:09)
  • 过度使用DBLINK做系统集成会带来的  (07月27日)
  • Oracle同义词+dblink的实际应用  (07/21/2015 14:55:05)
  • Oracle dblink造成远程数据库  (06/09/2015 19:33:54)
本文评论 查看全部评论 (0)
表情: 姓名: 字数