author:skate

time:2007-09-12

今天總結下oracle的任務佇列管理器(job queue ),以後也方便查詢. 我們要做定時任務時,有兩種辦法

一種是: 作業系統的定時,win的定時任務,unix的crontab一種是: 資料庫級的定時,她的效率更高,

再有大量的表級操作時,建議用資料庫本身的job queue,這樣方便,效率高;如果用系統級定時,會增加很多程式設計工作,成本增加了,還很容易出錯,事情越簡單出錯的機率越小.

再使用job queue之前,我們還要簡單配置下,oracle定時執行job queue 的後臺程序是SNP,要啟動

snp,首先看系統模式是否支援

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()過程。

1、 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引數指示在什麼時候此工作將再次執行。此引數預設值為當前日期和時間。

2、 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引數指示一個工作重執行的頻度。

3、 Interval()過程用來顯式地設定重執行一個工作之間的時間間隔數。 這個過程有兩個引數：job與interval。

PROCEDURE Interval (job      IN binary_integer,                     Interval IN varchar2)

job引數標識一個特定的工作。interval引數指示一個工作重執行的頻度。

4、 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型引數傳遞且包括一個 由開發者提供的工作號。如果提供的工作號已被使用，將產生一個錯誤。

5、 Next_Date()過程用來顯式地設定一個工作的執行時間。這個過程接收兩個引數：job與next_date。

PROCEDURE Next_Date(job         IN binary_ineger,                     next_date   IN date)

job標識一個已存在的工作。next_date引數指示了此工作應被執行的日期與時間。

6、 Remove()過程來刪除一個已計劃執行的工作。這個過程接收一個引數：

PROCEDURE Remove(job IN  binary_ineger);

job引數唯一地標識一個工作。這個引數的值是由為此工作呼叫Submit()過程返回的job引數的值。 已正在執行的工作不能由呼叫過程式刪除。

7、 Run()過程用來立即執行一個指定的工作。這個過程只接收一個引數：

PROCEDURE Run(job IN binary_ineger) 

job引數標識將被立即執行的工作。

8、 使用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程式碼應立即進行語法分析。

9、 User_Export()過程返回一個命令，此命令用來安排一個存在的工作以便此工作能重新提交。 此程式有兩個引數：job與my_call。

PROCEDURE User_Export(job        IN binary_ineger,                       my_call    IN OUT varchar2)

job引數標識一個安排了的工作。my_call引數包含在它的當前狀態重新提交此工作所需要 的正文。

10、 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日期表示式也不能滿足要求。這時因為一個任務的下一次執行時間在任務開始時才計算，而在此時是不知道任務在何時結束的。遇到這種情況怎麼辦呢？當然辦法肯定是有的，我們可以通過為任務佇列寫過程的辦法來實現。這裡我只是簡單介紹以下，可以在前一個任務佇列執行的過程中，取得任務完成的系統時間，然後加上指定的時間間隔，拿這個時間來控制下一個要執行的任務。這裡有一個前提條件，就是目前執行的任務本身必須要嚴格遵守自己的時間計劃。