--------------------------------------------------------------------------------------------------------------------------------
DECLARE
jobno number;
--间隔 5分钟
INTERVAL_M5 CONSTANT VARCHAR2(100) := '/*5:Mins*/trunc(sysdate,''mi'')-MOD(to_number(to_char(sysdate,''mi'')),5)/1440+5/60/24';
--间隔1小时
INTERVAL_H1 CONSTANT VARCHAR2(100) := '/*1:Hrs*/trunc(sysdate,'HH24')+1/24';
--间隔一天
INTERVAL_D1 CONSTANT VARCHAR2(100) := '/*1
ays*/trunc(sysdate)+1+10/60/24';
NEXT_DATE_01DATE:= trunc(sysdate,'MI')+5/60/24;
NEXT_DATE_02DATE:= trunc(sysdate,'HH24')+1/24;
NEXT_DATE_03DATE:= trunc(sysdate)+1+1/24;
NEXT_DATE_04DATE:= trunc(sysdate)+1+20/60/24;
NEXT_DATE_05DATE:= trunc(sysdate)+1+10/60/24;
BEGIN
--添加实时数据同步作业(间隔5分钟)
DBMS_JOB.SUBMIT(job => jobno, what => 'DATA_SYNC.Sync_AllRealTimeData;', next_date => NEXT_DATE_01, interval => INTERVAL_M5);
--添加历史数据同步作业(间隔1小时)
DBMS_JOB.SUBMIT(job => jobno, what => 'DATA_SYNC.Sync_AllHistoryData;', next_date => NEXT_DATE_02, interval => INTERVAL_H1);
--添加数据保护作业(间隔1天)
DBMS_JOB.SUBMIT(job => jobno, what => 'DATA_SYNC.Protect_AllDataSync;', next_date => NEXT_DATE_03, interval => INTERVAL_D1);
--添加日负荷极值计算作业(间隔1天)
DBMS_JOB.SUBMIT(job => jobno, what => 'DATA_SYNC.DayDataStatistics;', next_date => NEXT_DATE_04, interval => INTERVAL_D1);
--添加数据清除作业(间隔1天)
DBMS_JOB.SUBMIT(job => jobno, what => 'DATA_SYNC.DataClear;', next_date => NEXT_DATE_05, interval => INTERVAL_D1);
COMMIT;
END;
--------------------------------------------------------------------------------------------------------------------------------
|