利用DBLink+JOB实现两个Oracle数据库之间的数据同步
针对上一篇文章的部分内容这里通过DBLink+JOB实现两个Oracle数据库之间的数据同步,我自己测试了两个数据库之间的一个表同步没有问题,下面写个详细例子供大家参考;网络爬虫太多,加个地址:http://blog.csdn.net/qq_22260641
第一步:建立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任务,定时同步数据
var job_num number;
begin
dbms_job.submit(:job_num,\'TEST_JOB_SCOTT;\',SYSDATE,\'sysdate+1/24/60\');
end;
/
查询你的job语句:SELECT * FROM USER_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）\’