author:skatehtml
time:2007-09-12web
http://publish.it168.com/2006/0311/20060311017002.shtml算法
今天總結下oracle的任務隊列管理器(job queue ),之後也方便查詢.
咱們要作定時任務時,有兩種辦法sql
一種是: 操做系統的定時,win的定時任務,unix的crontab
一種是: 數據庫級的定時,她的效率更高,數據庫
再有大量的表級操做時,建議用數據庫自己的job queue,這樣方便,效率高;若是用系統級定時,
會增長不少編程工做,成本增長了,還很容易出錯,事情越簡單出錯的概率越小.編程
再使用job queue以前,咱們還要簡單配置下,oracle定時執行job queue 的後臺進程是SNP,要啓動session
snp,首先看系統模式是否支持oracle
sql> alter system enable restricted session;
或
sql> alter system disenable restricted session;性能
利用上面的命令更改系統的會話方式爲disenable restricted,爲snp的啓動建立條件.測試
再有就是配置job queue的啓動參數,snp的啓動參數位於oracle的初始化文件中,
job_queue_processes=10 (oracle10gde 默認值)
job_queue_interval=N
第一行定義snp進程的啓動個數爲10,正常得女冠一範圍是0-36,根據任務的多少,能夠配置
不一樣的數值.
第二行定義系統每隔幾秒喚醒該進程一次.缺省是60,正常範圍是1-3600秒.事實上,該進程執行完
當前任務後,就進入睡眠狀態,睡眠一段時間後,由系統的總控負責將其喚醒。
若是該文件中沒有上面兩行,請按照如上配置添加。配置完成後,須要從新啓動數據庫,使其生效
。注意:若是任務要求執行的間隔很短的話,N的配置也要相應地小一點。
查看job queue的詳細信息,查詢數據庫字典 user_jobs
eg:
sql> select job,next_date,next_sec,broken from user_jobs;
包含如下子過程:
Broken()過程。
change()過程。
Interval()過程。
Isubmit()過程。
Next_Date()過程。
Remove()過程。
Run()過程。
Submit()過程。
User_Export()過程。
What()過程。
一、
Broken()過程更新一個已提交的工做的狀態,典型地是用來把一個已破工做標記爲未破工做。
這個過程有三個參數:job 、broken與next_date。
PROCEDURE Broken (job IN binary_integer,
Broken IN boolean,
next_date IN date :=SYSDATE)
job參數是工做號,它在問題中惟一標識工做。
broken參數指示此工做是否將標記爲破——TRUE說明此工做將標記爲破,而FLASE說明此工做將標記爲未破。
next_date參數指示在何時此工做將再次運行。此參數缺省值爲當前日期和時間。
二、
Change()過程用來改變指定工做的設置。
這個過程有四個參數:job、what 、next_date與interval。
PROCEDURE Change (job IN binary_integer,
What IN varchar2,
next_date IN date,
interval IN varchar2)
此job參數是一個整數值,它惟一標識此工做。
What參數是由此工做運行的一塊PL/SQL代碼塊。
next_date參數指示什麼時候此工做將被執行。
interval參數指示一個工做重執行的頻度。
三、
Interval()過程用來顯式地設置重執行一個工做之間的時間間隔數。
這個過程有兩個參數:job與interval。
PROCEDURE Interval (job IN binary_integer,
Interval IN varchar2)
job參數標識一個特定的工做。interval參數指示一個工做重執行的頻度。
四、
ISubmit()過程用來用特定的工做號提交一個工做。
這個過程有五個參數:job、what、next_date、interval與no_parse。
PROCEDURE ISubmit (job IN binary_ineger,
What IN varchar2,
next_date IN date,
interval IN varchar2,
no_parse IN booean:=FALSE)
這個過程與Submit()過程的惟一區別在於此job參數做爲IN型參數傳遞且包括一個
由開發者提供的工做號。若是提供的工做號已被使用,將產生一個錯誤。
五、
Next_Date()過程用來顯式地設定一個工做的執行時間。這個過程接收兩個參數:job與next_date。
PROCEDURE Next_Date(job IN binary_ineger,
next_date IN date)
job標識一個已存在的工做。next_date參數指示了此工做應被執行的日期與時間。
六、
Remove()過程來刪除一個已計劃運行的工做。這個過程接收一個參數:
PROCEDURE Remove(job IN binary_ineger);
job參數惟一地標識一個工做。這個參數的值是由爲此工做調用Submit()過程返回的job參數的值。
已正在運行的工做不能由調用過程序刪除。
七、
Run()過程用來當即執行一個指定的工做。這個過程只接收一個參數:
PROCEDURE Run(job IN binary_ineger)
job參數標識將被當即執行的工做。
八、
使用Submit()過程,工做被正常地計劃好。
這個過程有五個參數:job、what、next_date、interval與no_parse。
PROCEDURE Submit ( job OUT binary_ineger,
What IN varchar2,
next_date IN date,
interval IN varchar2,
no_parse IN booean:=FALSE)
job參數是由Submit()過程返回的binary_ineger。這個值用來惟一標識一個工做。
what參數是將被執行的PL/SQL代碼塊。
next_date參數指識什麼時候將運行這個工做。
interval參數什麼時候這個工做將被重執行。
no_parse參數指示此工做在提交時或執行時是否應進行語法分析——TRUE
指示此PL/SQL代碼在它第一次執行時應進行語法分析,
而FALSE指示本PL/SQL代碼應當即進行語法分析。
九、
User_Export()過程返回一個命令,此命令用來安排一個存在的工做以便此工做能從新提交。
此程序有兩個參數:job與my_call。
PROCEDURE User_Export(job IN binary_ineger,
my_call IN OUT varchar2)
job參數標識一個安排了的工做。my_call參數包含在它的當前狀態從新提交此工做所須要
的正文。
十、
What()過程應許在工做執行時從新設置此正在運行的命令。這個過程接收兩個參數:job與what。
PROCEDURE What (job IN binary_ineger,
What IN OUT varchar2)
job參數標識一個存在的工做。what參數指示將被執行的新的PL/SQL代碼。
一個簡單例子:
建立測試表
SQL> create table a(a date);
表已建立。
建立一個自定義過程
SQL> create or replace procedure test as
2 begin
3 insert into a values(sysdate);
4 end;
5 /
過程已建立。
建立JOB
SQL> variable job1 number;
SQL>
SQL> begin
2 dbms_job.submit(:job1,'test;',sysdate,'sysdate+1/1440'); --天天1440分鐘,即一分鐘運行test過程一次
3 end;
4 /
PL/SQL 過程已成功完成。
運行JOB
SQL> begin
2 dbms_job.run(:job1);
3 end;
4 /
PL/SQL 過程已成功完成。
SQL> select to_char(a,'yyyy/mm/dd hh24:mi:ss') 時間 from a;
時間
-------------------
2001/01/07 23:51:21
2001/01/07 23:52:22
2001/01/07 23:53:24
刪除JOB
SQL> begin
2 dbms_job.remove(:job1);
3 end;
4 /
PL/SQL 過程已成功完成。
下面說下經常使用的視圖與參數:
任務隊列中關於任務的數據字典視圖
視圖名 | 描述 |
DBA_JOBS | 本數據庫中定義到任務隊列中的任務 |
DBA_JOBS_RUNNING | 目前正在運行的任務 |
USER_JOBS | 當前用戶擁有的任務 |
JOB_QUEUE_PROCESSES >= 1 (若是系統在同一時間會運行不少的job, 或者還有大量須要自動refresh的snapshot, 適當加大)
JOB_QUEUE_INTERVAL : 秒數(缺省爲60秒), 根據你的job的調度頻度而定, 對於通常的一天運行一次的job, 設爲缺省值或者幾分鐘均可以. (不要設置太小, 以避免影響性能)
JOB_QUEUE_KEEP_CONNECTION (系統默認就能夠,我沒發現他的做用)
DBA_JOBS 和 USER_JOBS.字典視圖的字段含義
字段(列) | 類型 | 描述 |
JOB | NUMBER | 任務的惟一標示號 |
LOG_USER | VARCHAR2(30) | 提交任務的用戶 |
PRIV_USER | VARCHAR2(30) | 賦予任務權限的用戶 |
SCHEMA_USER | VARCHAR2(30) | 對任務做語法分析的用戶模式 |
LAST_DATE | DATE | 最後一次成功運行任務的時間 |
LAST_SEC | VARCHAR2(8) | 如HH24:MM:SS格式的last_date日期的小時,分鐘和秒 |
THIS_DATE | DATE | 正在運行任務的開始時間,若是沒有運行任務則爲null |
THIS_SEC | VARCHAR2(8) | 如HH24:MM:SS格式的this_date日期的小時,分鐘和秒 |
NEXT_DATE | DATE | 下一次定時運行任務的時間 |
NEXT_SEC | VARCHAR2(8) | 如HH24:MM:SS格式的next_date日期的小時,分鐘和秒 |
TOTAL_TIME | NUMBER | 該任務運行所須要的總時間,單位爲秒 |
BROKEN | VARCHAR2(1) | 標誌參數,Y標示任務中斷,之後不會運行 |
INTERVAL | VARCHAR2(200) | 用於計算下一運行時間的表達式 |
FAILURES | NUMBER | 任務運行連續沒有成功的次數 |
WHAT | VARCHAR2(2000) | 執行任務的PL/SQL塊 |
CURRENT_SESSION_LABEL | RAW MLSLABEL | 該任務的信任Oracle會話符 |
CLEARANCE_HI | RAW MLSLABEL | 該任務可信任的Oracle最大間隙 |
CLEARANCE_LO | RAW MLSLABEL | 該任務可信任的Oracle最小間隙 |
NLS_ENV | VARCHAR2(2000) | 任務運行的NLS會話設置 |
MISC_ENV | RAW(32) | 任務運行的其餘一些會話參數 |
視圖DBA_JOBS_RUNNING的字段含義
列 | 數據類型 | 描述 |
SID | NUMBER | 目前正在運行任務的會話ID |
JOB | NUMBER | 任務的惟一標示符 |
FAILURES | NUMBER | 連續不成功執行的累計次數 |
LAST_DATE | DATE | 最後一次成功執行的日期 |
LAST_SEC | VARCHAR2(8) | 如HH24:MM:SS格式的last_date日期的小時,分鐘和秒 |
THIS_DATE | DATE | 目前正在運行任務的開始日期 |
THIS_SEC | VARCHAR2(8) | 如HH24:MM:SS格式的this_date日期的小時,分鐘和秒 |
任務重複運行間隔和間隔設計
算法任務重複運行的時間間隔取決於interval參數中設置的日期表達式。下面就來詳細談談該如何設置interval參數才能準確知足咱們的任務需求。通常來說,對於一個任務的定時執行,有三種定時要求。
在一個特定的時間間隔後,重複運行該任務。
在特定的日期和時間運行任務。
任務成功完成後,下一次執行應該在一個特定的時間間隔以後。
第一種調度任務需求的日期算法比較簡單,即'SYSDATE+n',這裏n是一個以天爲單位的時間間隔。表6給出了一些這種時間間隔設置的例子。
表6 一些簡單的interval參數設置例子
描述 | Interval參數值 |
天天運行一次 | 'SYSDATE + 1' |
每小時運行一次 | 'SYSDATE + 1/24' |
每10分鐘運行一次 | 'SYSDATE + 10/(60*24)' |
每30秒運行一次 | 'SYSDATE + 30/(60*24*60)' |
每隔一星期運行一次 | 'SYSDATE + 7' |
再也不運行該任務並刪除它 | NULL |
表6所示的任務間隔表達式不能保證任務的下一次運行時間在一個特定的日期或者時間,僅僅可以指定一個任務兩次運行之間的時間間隔。例如,若是一個任務第一次運行是在凌晨12點,interval指定爲'SYSDATE + 1',則該任務將被計劃在次日的凌晨12點執行。可是,若是某用戶在下午4點手工(DBMS_JOB.RUN)執行了該任務,那麼該任務將被從新定時到次日的下午4點。還有一個可能的緣由是若是數據庫關閉或者說任務隊列很是的忙以致於任務不能在計劃的那個時間點準時執行。在這種狀況下,任務將試圖儘快運行,也就是說只要數據庫一打開或者是任務隊列不忙就開始執行,可是這時,運行時間已經從原來的提交時間漂移到了後來真正的運行時間。這種下一次運行時間的不斷「漂移」是採用簡單時間間隔表達式的典型特徵。
第二種調度任務需求相對於第一種就須要更復雜的時間間隔(interval)表達式,表7是一些要求在特定的時間運行任務的interval設置例子。
表 7. 定時到特定日期或時間的任務例子
描述 | 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)' |
第三種調度任務需求不管經過怎樣設置interval日期表達式也不能知足要求。這時由於一個任務的下一次運行時間在任務開始時才計算,而在此時是不知道任務在什麼時候結束的。遇到這種狀況怎麼辦呢?固然辦法確定是有的,咱們能夠經過爲任務隊列寫過程的辦法來實現。這裏我只是簡單介紹如下,能夠在前一個任務隊列執行的過程當中,取得任務完成的系統時間,而後加上指定的時間間隔,拿這個時間來控制下一個要執行的任務。這裏有一個前提條件,就是目前運行的任務自己必需要嚴格遵照本身的時間計劃。