美文网首页
DBLink增量更新

DBLink增量更新

作者: 树熊晓乐 | 来源:发表于2019-11-20 09:58 被阅读0次

    第一步:建立DBLink

    两个数据库,源数据库test中的表数据同步到目标数据库scott的同一个表(表不相同也可以,不影响的),在PL/SQL工具里输入:

    create database link link名称

    connect to 对方数据库用户名 identified by 对方数据库用户密码

    using '对方数据库ip:端口/实例名';

    例如:本例子的

    -- Create database link

    create public database link SCOTT_LINK

      connect to SCOTT identified by 密码

     using 'gwssi';

    可用 select * from dual@SCOTT_LINK; 来测试是否连接成功

    第二步:数据同步的存储过程

    CREATE OR REPLACE PROCEDURE TEST_JOB_SCOTT

    AS SCOTT_ID  NUMBER;

    BEGIN

      SELECT  NVL (MAX (ID), 0) INTO SCOTT_ID FROM T_OPD_CQZXXB@SCOTT_LINK;

        INSERT INTO T_OPD_CQZXXB@SCOTT_LINK

          SELECT  *

              FROM  T_OPD_CQZXXB

            WHERE  T_OPD_CQZXXB.ID > SCOTT_ID;

        COMMIT;

    EXCEPTION

        WHEN OTHERS

        THEN

          DBMS_OUTPUT.PUT_LINE ('Exception happened,data was rollback');

          ROLLBACK;

    END;

    这是我的例子,T_OPD_CQZXXB是表名,具体需要怎么同步看各自的需求,明白怎么一个流程就行

    第三步:建立JOB任务,定时同步数据

    在PL/SQL的command window输入以下语句:

    var job_num number; 

    begin 

        dbms_job.submit(:job_num,'TEST_JOB_SCOTT;',SYSDATE,'sysdate+1/24/60'); 

    end; 

    /

    查询你的job语句:SELECT*FROMUSER_JOBS;

    ps:下面来讲讲定时任务的时间间隔怎么算的。

    第一种调度任务需求的日期算法比较简单,即'SYSDATE+n',这里n是一个以天为单位的时间间隔。

    描述 Interval参数值

    每天运行一次    'SYSDATE + 1'

    每小时运行一次    'SYSDATE + 1/24'

    每10分钟运行一次    'SYSDATE + 10/(60*24)'

    每30秒运行一次    'SYSDATE + 30/(60*24*60)'

    每隔一星期运行一次    'SYSDATE + 7'

    不再运行该任务并删除它 NULL

    第二种调度任务需求相对于第一种就需要更复杂的时间间隔(interval)表达式

    描述 INTERVAL参数值

    每天午夜12点   'TRUNC(SYSDATE + 1)'

    每天早上8点30分   'TRUNC(SYSDATE + 1) + (8*60+30)/(24*60)'

    每星期二中午12点      'NEXT_DAY(TRUNC(SYSDATE ), ''TUESDAY'' ) + 12/24'

    每个月第一天的午夜12点    'TRUNC(LAST_DAY(SYSDATE ) + 1)'

    每个季度最后一天的晚上11点    'TRUNC(ADD_MONTHS(SYSDATE + 2/24, 3 ), 'Q' ) -1/24'

    每星期六和日早上6点10分    'TRUNC(LEAST(NEXT_DAY(SYSDATE, ''SATURDAY"), NEXT_DAY(SYSDATE, "SUNDAY"))) + (6×60+10)/(24×60)'

    相关文章

      网友评论

          本文标题:DBLink增量更新

          本文链接:https://www.haomeiwen.com/subject/sqgnictx.html