两个Oracle数据库安装在不同的服务器中:
举个例子:数据库a(orcl-a)中的表table_a同步数据库b(orcl-b)中的表table_b,
Oracle数据同步是思路是:1.在数据库a中创建dblink,2.创建存储过程,3.创建job定时执行该存储过程
1.创建dblink
create database link TestDblink
connect to username identified by password
using '(DESCRIPTION =(ADDRESS_LIST =(ADDRESS =(PROTOCOL = TCP)(HOST = 127.0.0.1)(PORT = 1521)))(CONNECT_DATA =(SERVICE_NAME = orcl-b)))';
注:这里的连接信息(ip, port, username, password)都是数据库b的连接信息
简单测试dblink是否创建成功:
select * from orcl-b.table_b@TestDblink;
2.创建存储过程
CREATE OR REPLACE
procedure user_synchronization as
begin
insert into table_a (user_id, name) select user_id, name from orcl-b.b@TestDblink b where not exists (select user_id from table_a a where a.user_id = b.user_id);
commit;
end;
exists 与 not exists的解释可参考:https://www.cnblogs.com/cjm123/p/8177017.html
3.创建job定时执行该存储过程
declare
job1 number;
begin
<!-- dbms_job.submit(job1, '存储过程名称;', '开始时间', '执行周期');-->
dbms_job.submit(job1, 'user_synchronization;', '2019-08-17 17:17', 'sysdate+10/86400');--每10s插入一条记录
end;
查看定时任务是否启动:
select * from dba_jobs;
移除定时任务:
begin
dbms_job.remove(任务号);
end;
相关的执行周期
每天午夜12点 ''TRUNC(SYSDATE + 1)''
每天早上8点30分 ''TRUNC(SYSDATE + 1) + (860+30)/(2460)''
每星期二中午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)''
每3秒钟执行一次 'sysdate+3/(246060)'
每2分钟执行一次 'sysdate+2/(24*60)'
1:每分钟执行
Interval => TRUNC(sysdate,'mi') + 1/ (2460) --每分钟执行
interval => 'sysdate+1/(2460)' --每分钟执行
interval => 'sysdate+1' --每天
interval => 'sysdate+1/24' --每小时
interval => 'sysdate+2/2460' --每2分钟
interval => 'sysdate+30/2460*60' --每30秒
如果日期格式不对,可以用to_date函数。如:to_date('2005-01-01 13:14:20','yyyy-MM-dd HH24:mm:ss')