Oracle定時任務(1)-DBMS_SCHEDULER

來自：http://blog.csdn.net/fw0124/article/details/6753715

 

Oracle 10g之前，可以使用dbms_job來管理定時任務。
10g之后，Oracle引入dbms_scheduler來替代先前的dbms_job,
在功能方面,它比dbms_job提供了更強大的功能和更靈活的機制/管理。

使用dbms_scheduler創建一個定時任務有兩種形式
1）創建1個SCHEDULER來定義計划，1個PROGRAM來定義任務內容，
再創建1個JOB，為這個JOB指定上面的SCHEDULER和PROGRAM。
2）直接創建JOB，在參數里面直接指定計划和任務內容。

要執行DBMS_SCHEDULER需要有CREATE JOB權限。
如果要創建外部操作系統命令的job, 還必須有CREATE EXTERNAL JOB權限。
如果要對於某個對象進行操作，必須是它的owner，或者對它具有alter權限，或者有create any job權限。
如果要創建/操作job_class，還需要有MANAGE SCHEDULER權限。job_class都是創建在sys schema中的。

 

名稱	類型	描述
CREATE_SCHEDULE	過程	DBMS_SCHEDULER.CREATE_SCHEDULE (    schedule_name          IN VARCHAR2,    start_date             IN TIMESTAMP WITH TIMEZONE DEFAULT NULL,    repeat_interval        IN VARCHAR2,    end_date               IN TIMESTAMP WITH TIMEZONE DEFAULT NULL,    comments               IN VARCHAR2 DEFAULT NULL);
CREATE_PROGRAM	過程	DBMS_SCHEDULER.CREATE_PROGRAM (    program_name             IN VARCHAR2,    program_type             IN VARCHAR2,    program_action           IN VARCHAR2,    number_of_arguments      IN PLS_INTEGER DEFAULT 0,    enabled                  IN BOOLEAN DEFAULT FALSE,    comments                 IN VARCHAR2 DEFAULT NULL);
CREATE_JOB	過程	通過事先創建的schedule object 和 program object來創建job： （另外還有2個過程只指定shcedule和program中的1個） DBMS_SCHEDULER.CREATE_JOB (    job_name                IN VARCHAR2,    program_name            IN VARCHAR2,    schedule_name           IN VARCHAR2,    job_class               IN VARCHAR2              DEFAULT 'DEFAULT_JOB_CLASS',    enabled                 IN BOOLEAN               DEFAULT FALSE,    auto_drop               IN BOOLEAN               DEFAULT TRUE,    comments                IN VARCHAR2              DEFAULT NULL,    job_style               IN VARCHAR2              DEFAULT 'REGULAR',    credential_name         IN VARCHAR2              DEFAULT NULL,    destination_name        IN VARCHAR2              DEFAULT NULL); DBMS_SCHEDULER.CREATE_JOB (    job_name             IN VARCHAR2,    job_type             IN VARCHAR2,    job_action           IN VARCHAR2,    number_of_arguments  IN PLS_INTEGER              DEFAULT 0,    start_date           IN TIMESTAMP WITH TIME ZONE DEFAULT NULL,    repeat_interval      IN VARCHAR2                 DEFAULT NULL,    end_date             IN TIMESTAMP WITH TIME ZONE DEFAULT NULL,    job_class            IN VARCHAR2                 DEFAULT 'DEFAULT_JOB_CLASS',    enabled              IN BOOLEAN                  DEFAULT FALSE,    auto_drop            IN BOOLEAN                  DEFAULT TRUE,    comments             IN VARCHAR2                 DEFAULT NULL,    credential_name      IN VARCHAR2                 DEFAULT NULL,    destination_name     IN VARCHAR2                 DEFAULT NULL);
SET_JOB_ARGUMENT_VALUE	過程	DBMS_SCHEDULER.SET_JOB_ARGUMENT_VALUE (    job_name                IN VARCHAR2,    argument_position       IN PLS_INTEGER,    argument_value          IN VARCHAR2); DBMS_SCHEDULER.SET_JOB_ARGUMENT_VALUE (    job_name                IN VARCHAR2,    argument_name           IN VARCHAR2,    argument_value          IN VARCHAR2);
ENABLE DISABLE	過程	DBMS_SCHEDULER.ENABLE (    name              IN VARCHAR2,    commit_semantics  IN VARCHAR2 DEFAULT 'STOP_ON_FIRST_ERROR'); DBMS_SCHEDULER.DISABLE (    name              IN VARCHAR2,    force             IN BOOLEAN DEFAULT FALSE,    commit_semantics  IN VARCHAR2 DEFAULT 'STOP_ON_FIRST_ERROR'); *name可以用逗號分隔來指定多個對象，commit_semantics用於這種情況：STOP_ON_FIRST_ERROR，TRANSACTIONAL，ABSORB_ERRORS *force參數用於dependencies，如果TRUE，即使其他對象依賴於它，操作也能成功。 另外，如果job正在運行，當force為TRUE, job被置為diabled並且允許運行中的job結束； 當force為false,返回錯誤。
RUN_JOB STOP_JOB	過程	DBMS_SCHEDULER.RUN_JOB (    job_name                IN VARCHAR2,    use_current_session     IN BOOLEAN DEFAULT TRUE); *use_current_session如果為TRUE: 1) The job runs as the user who called RUN_JOB 2) You can test a job and see any possible errors on the command line. 3) run_count,last_start_date, ast_run_duration,failure_count are not updated. 4) RUN_JOB can be run in parallel with a regularly scheduled job run. *use_current_session如果為FALSE: 1) The job runs as the user who is the job owner. 2) You need to check the job log to find error information. 3) run_count,last_start_date,last_run_duration,failure_count are updated. 4) RUN_JOB fails if a regularly scheduled job is running. DBMS_SCHEDULER.STOP_JOB (    job_name         IN VARCHAR2    force            IN BOOLEAN DEFAULT FALSE    commit_semantics IN VARCHAR2 DEFAULT 'STOP_ON_FIRST_ERROR'); *force如果為FALSE, oracle嘗試gracefully停止job,  使用中斷機制(interrupt mechanism)，將控制權交還給slave process,  來更新job queue中的job狀態。如果失敗了，返回錯誤。 force如果為TRUE, oracle立即中止job slave process. Oracle建議只有force=FALSE停止job失敗的情況下才嘗試force=true. 並且如果使用force選項，比如有MANAGE SCHEDULER權限。
DROP_JOB DROP_PROGRAM DROP_SCHEDULE	過程	DBMS_SCHEDULER.DROP_JOB (    job_name                IN VARCHAR2,    force                   IN BOOLEAN DEFAULT FALSE,    defer                   IN BOOLEAN DEFAULT FALSE,    commit_semantics        IN VARCHAR2 DEFAULT 'STOP_ON_FIRST_ERROR'); *如果force為TRUE,試圖停止正在運行的job（調用STOP_JOB(force=>false))，之后再drop。 *如果defer為TRUE,等待正在運行的job結束再drop。 *同時指定force和defer為TRUE，返回錯誤。 *如果同時指定force和defer為FALSE，對於一個正在運行的job，調用失敗。 DBMS_SCHEDULER.DROP_PROGRAM (    program_name            IN VARCHAR2,    force                   IN BOOLEAN DEFAULT FALSE); DBMS_SCHEDULER.DROP_SCHEDULE (    schedule_name    IN VARCHAR2,    force            IN BOOLEAN DEFAULT FALSE); *force如果為false,這個program/schedule必須不被任何job引用，否則報錯。 *force如果為true,引用此program/schedule的job都會被disable，正在運行的job會繼續進行。
GET_ATTRIBUTE SET_ATTRIBUTE SET_ATTRIBUTE_NULL	過程	DBMS_SCHEDULER.GET_ATTRIBUTE (    name           IN VARCHAR2,    attribute      IN VARCHAR2,    value          OUT {VARCHAR2|PLS_INTEGER|BOOLEAN|DATE|TIMESTAMP|                         TIMESTAMP WITH TIME ZONE|TIMESTAMP WITH LOCAL TIME ZONE|                         INTERVAL DAY TO SECOND}); DBMS_SCHEDULER.SET_ATTRIBUTE (    name           IN VARCHAR2,    attribute      IN VARCHAR2,    value          IN {BOOLEAN|DATE|TIMESTAMP|                         TIMESTAMP WITH TIME ZONE|TIMESTAMP WITH LOCAL TIME ZONE|                         INTERVAL DAY TO SECOND}); DBMS_SCHEDULER.SET_ATTRIBUTE_NULL (    name              IN VARCHAR2,    attribute         IN VARCHAR2); *一些可以設置的參數： logging_level 定義如何記錄log到dba_scheduler_job_log/dba_scheduler_job_run_details視圖。 可用選項如下，是些預定義的常量。 需要注意，實際上的logging level還取決job所屬的job_class, 取兩者中的最高值。 例如創建job的時候如果不指定job class，默認是DEFAULT_JOB_CLASS， 而DEFAULT_JOB_CLASS的默認logging level是DBMS_SCHEDULER.LOGGING_RUNS, 所以創建的job的logging level至少是LOGGING_RUNS。 1) DBMS_SCHEDULER.LOGGING_OFF 不記錄 2) DBMS_SCHEDULER.LOGGING_FAILED_RUNS 只記錄失敗的job運行 3) DBMS_SCHEDULER.LOGGING_RUNS 記錄每次job運行 4) DBMS_SCHEDULER.LOGGING_FULL 不僅記錄每次job運行，還包括針對job的任何操作。 max_failures 默認為null,即沒有限制。 max_runs 默認為null,即沒有限制。 restartable job執行失敗后是否retry，默認為false。  當設置為true,執行失敗1秒后進行第一次retry, 然后是10秒，100秒，每次時間間隔乘10。 最多執行6次retry（大概30小時后）。如果時間超過了下次正常的計划執行的時間，停止retry過程。 對於retry,*_scheduler_jobs視圖中的RUN_COUNT, FAILURE_COUNT 不會增加。 此外，repeat_interval，start_date，end_date等都可以設置。

 

 

參數說明
1）schedule_name,program_name,job_name
這些名字在整個sql名字空間內必須唯一。比如,job_name不能和某個表名相同。

2）repeat_interval
定義job的計划，可以指定的形式相當豐富，也相當靈活，很強大。
regular_schedule = frequency_clause
[";" interval_clause] [";" bymonth_clause] [";" byweekno_clause]
[";" byyearday_clause] [";" bydate_clause] [";" bymonthday_clause]
[";" byday_clause] [";" byhour_clause] [";" byminute_clause]
[";" bysecond_clause] [";" bysetpos_clause] [";" include_clause]
[";" exclude_clause] [";" intersect_clause][";" periods_clause]
[";" byperiod_clause]

frequency_clause = "FREQ" "=" "YEARLY" | "MONTHLY" | "WEEKLY" | "DAILY" | 
   "HOURLY" | "MINUTELY" | "SECONDLY"

interval_clause = "INTERVAL" "=" 1 through 99

bymonth_clause = "BYMONTH" "=" {month ( "," month)*}
   month = numeric_month | char_month
   numeric_month = 1 | 2 | 3 ...  12
   char_month = "JAN" | "FEB" | "MAR" | "APR" | "MAY" | "JUN" |
   "JUL" | "AUG" | "SEP" | "OCT" | "NOV" | "DEC"

byweekno_clause = "BYWEEKNO" "=" {weeknumber ( "," weeknumber)*}
   weeknumber = [minus] 1 through 53

byyearday_clause = "BYYEARDAY" "=" {yearday ( "," yearday)*}
   yearday = [minus] 1 through 366
   
bydate_clause = "BYDATE" "=" {date ( "," date)*}
   date = [YYYY]MMDD [ offset | span ]

bymonthday_clause = "BYMONTHDAY" "=" {monthday ( "," monthday)*}
   monthday = [minus] 1 through 31

byday_clause = "BYDAY" "=" {byday ( "," byday)*}
   byday = [weekdaynum] day
   weekdaynum = [minus] daynum
   daynum = 1 through 53 /* if frequency is yearly */
   daynum = 1 through 5  /* if frequency is monthly */
   day = "MON" | "TUE" | "WED" | "THU" | "FRI" | "SAT" | "SUN"
   
byhour_clause = "BYHOUR" "=" {hour ( "," hour)*}
   hour = 0 through 23
   
byminute_clause = "BYMINUTE" "=" {minute ( "," minute)*}
   minute = 0 through 59
 
bysecond_clause = "BYSECOND" "=" {second ( "," second)*}
   second = 0 through 59
   
bysetpos_clause = "BYSETPOS" "=" {setpos ("," setpos)*}
   setpos = [minus] 1 through 9999

include_clause = "INCLUDE" "=" schedule_list
exclude_clause = "EXCLUDE" "=" schedule_list
intersect_clause = "INTERSECT" "=" schedule_list
periods_clause = "PERIODS" "=" periodnum
byperiod_clause = "BYPERIOD" "=" {periodnum ("," periodnum)*}
periodnum = 1 through 100

offset = ("+" | "-") ["OFFSET:"] duration_val
span = ("+" | "-" | "^") "SPAN:" duration_val
duration_val = dur-weeks | dur_days
dur_weeks = numofweeks "W"
dur_days = numofdays "D"
numofweeks = 1 through 53
numofdays = 1 through 376
minus = "-"

舉幾個例子
a) 05/02 和 09/22 的 8:00 a.m., 1:00 p.m., 6:00 p.m.
'freq=daily;byhour=8,13,18;byminute=0;bysecond=0;bydate=0502,0922'

b) 每個月的最后一個工作日（注意,INTERVAL如果不指定,默認為1）
'FREQ=MONTHLY;BYDAY=MON,TUE,WED,THU,FRI;BYSETPOS=-1'

c) 1/10開始的5天，即1/10~1/14
BYDATE=0110+SPAN:5D
+表示從指定日期開始;-表示到指定日期結束;
^表示圍繞指定日期的n天，如果n為偶數，調整為n+1。

d) 以下三種表示方法等同
BYDATE=0205-OFFSET:2W
BYDATE=0205-14D (the OFFSET: keyword is optional)
BYDATE=0122

3）start_date
實際上是schedule生效的日期，
對於一個定時執行的schedule,實際上的開始日期取決於repeat_interval參數。
如果start_date為null,等同於job被enable的時刻。

Oracle取start_date來作為repeat_interval的default值。
例如，如果指定start_date為1/31/2010 9:45:58，指定repeat_interval為'FREQ=YEARLY'，
等同於'freq=yearly;bymonth=1;bymonthday=31;byhour=9;byminute=45;bysecond=58'

不能給repeat_interval指定時區信息，Oracle取start_date的時區信息作為指定的時區。

4）end_date
這個時間之后，job將不再被執行。

5）program_type/program_action/number_of_arguments/job_type/job_action
program_type有三種形式
-'PLSQL_BLOCK'
program_action是一個PL/SQL block. 不支持參數，number_of_arguments必須為0.
必須以分號結尾。例如以下三種形式
'my_proc();'
'BEGIN my_proc(); END;'
'DECLARE arg pls_integer:= 10; BEGIN my_proc2(arg); END;'

-'STORED_PROCEDURE'
program_action是一個存儲過程，注意不支持INOUT or OUT參數，也不支持function.
參數最多255個，可以通過SET_JOB_ARGUMENT_VALUE過程來設定。
例如'"Schema"."Procedure"'.

-'EXECUTABLE'
program_action是一個外部操作系統的命令行程序，包含完整路徑，不能帶任何命令行參數。
開始的'?'會被替換為oracle home目錄;'@'會被替換為當前oracle實例的SID。

job_type類似於program_type，只是多了'CHAIN'這種類型來創建任務鏈。
 
6) enabled
如果為TRUE, 創建時候檢查program/job有效性，如果通過檢查把program/job置為ENABLED.
在program/job使用前必須通過ENABLE過程把它置為ENABLED。
如果program為disabled，僅僅enable一個job，那么job會按計划執行，但是會失敗。

7）auto_drop
如果為TRUE, 在job完成之后或者被自動disabled之后job將被自動刪除。
如果滿足以下條件，job被視為完成。
a) 過了end_date。
b) 達到了最大運行次數（max_runs,可以通過SET_ATTRIBUTE來指定）
c) 非重復任務，即只運行一次的任務，並且已經運行了1次。
如果滿足以下條件，job被視為自動disabled.
a) 達到了最大運行失敗次數（max_failures,可以通過SET_ATTRIBUTE來指定）

相關數據字典
1) dba_scheduler_jobs/user_scheduler_jobs
Enabling 一個 disabled 狀態的job會重設本視圖中的RUN_COUNT, FAILURE_COUNT and RETRY_COUNT.

2) dba_scheduler_programs/user_scheduler_programs

3) dba_scheduler_schedules/user_scheduler_schedules
 
4) dba_scheduler_job_log/dba_scheduler_job_run_details

5) dba_scheduler_job_classes

6) 默認情況下，數據庫自身定義了一個PURGE_JOB的任務。
該任務每天凌晨3點鍾啟動，清除30天前所產生的任務日志。

檢驗運行時間

dbms_scheduler提供了一個過程可以很方便的檢驗指定的計划(repeat_interval)。
DBMS_SCHEDULER.EVALUATE_CALENDAR_STRING (
   calendar_string    IN  VARCHAR2,
   start_date         IN  TIMESTAMP WITH TIME ZONE,
   return_date_after  IN  TIMESTAMP WITH TIME ZONE,
   next_run_date      OUT TIMESTAMP WITH TIME ZONE);

下面創建一個過程evaluate_repeat_interval，
傳入repeat_interval字符串和計算的次數，會把每次的執行時間打印出來。

create or replace procedure evaluate_repeat_interval(
  p_repeat_interval in varchar2,
  p_number_of_evaluation in int,
  p_start_date in timestamp with time zone default sysdate
)
as
  l_return_date_after timestamp with time zone;
  l_next_run_date  timestamp with time zone;
begin
  l_return_date_after := p_start_date;
  for i in 1..p_number_of_evaluation loop
    dbms_scheduler.evaluate_calendar_string(
      calendar_string=>p_repeat_interval,
      start_date=>p_start_date,
      return_date_after=>l_return_date_after,
      next_run_date=>l_next_run_date);
    dbms_output.put_line(l_next_run_date);
    l_return_date_after := l_next_run_date;
  end loop;
end;

--調用的例子1：每個月的最后一天
begin
evaluate_repeat_interval(
  p_repeat_interval=>'FREQ=MONTHLY;BYMONTHDAY=-1',
  p_number_of_evaluation=>3,
  p_start_date=>to_timestamp_tz('2012-01-01 00:00:00.000 +08:00',
    'yyyy-mm-dd hh24:mi:ss.ff tzh:tzm')
  );
end;
--執行結果
<p>31-JAN-12 12.00.00.000000 AM +08:00
29-FEB-12 12.00.00.000000 AM +08:00
31-MAR-12 12.00.00.000000 AM +08:00</p><p>PL/SQL procedure successfully completed.</p>
--調用的例子2：每個月的最后一個工作日
begin
evaluate_repeat_interval(
  p_repeat_interval=>'FREQ=MONTHLY;BYDAY=MON,TUE,WED,THU,FRI;BYSETPOS=-1',
  p_number_of_evaluation=>3,
  p_start_date=>to_timestamp_tz('2012-01-01 00:00:00.000 +08:00',
    'yyyy-mm-dd hh24:mi:ss.ff tzh:tzm')
  );
end;
--執行結果
<p>31-JAN-12 12.00.00.000000 AM +08:00
29-FEB-12 12.00.00.000000 AM +08:00
30-MAR-12 12.00.00.000000 AM +08:00</p><p>PL/SQL procedure successfully completed.</p>