实现操作dblink同步

以下代码由PHP站长网 52php.cn网络自互联网

此刻PHP站长网小编把它分享给各人，仅供参考

操作dblink 做oracle到oracle的按时同步，以刚为卡中心做的一个同步为例

1、建设必要的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,t2.zymc,'' sfsf,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,t1.dzxx email
       from idc_u_rs.rs_zzryjbxx t1                                                --  在职职员
union all
select t1.zgh userid,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 [email?protected]; --删除数据
            insert into [email?protected](outid,college,departname,major,typeof,sfsf,cn,email,inetuserstatus)
                   select outid,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;

以上内容由PHP站长网【52php.cn】网络清算供各人参考研究

假如以上内容对您有辅佐，接待保藏、点赞、保举、分享。

（编辑：湖南网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!