1. 程式人生 > >oracle定時任務(dbms_job)

oracle定時任務(dbms_job)

eat 更改 gin session 啟動參數 code bin 之前 今天

今天總結下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
  begin
   insert into a values(sysdate);
  end;

過程已創建。

創建JOB

描述 Interval參數值
每天運行一次 ‘SYSDATE + 1‘
每小時運行一次 ‘SYSDATE + 1/24‘
每10分鐘運行一次 ‘SYSDATE + 10/(60*24)‘
每30秒運行一次 ‘SYSDATE + 30/(60*24*60)‘
每隔一星期運行一次 ‘SYSDATE + 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)‘

將要執行的任務寫成存儲過程或其他的數據庫可執行的pl/sql程序段
例如,我們已經建立了一個存儲過程,其名稱為my_job,在sql/plus中以scott用戶身份登錄,執行如下命令:
sql> variable n number;
sql> begin
dbms_job.submit(:n‘my_job;’,sysdate,
‘sysdate+1/360’);
commit;
end;
/
系統提示執行成功。
Sql> print :n;
系統打印此任務的編號,例如結果為300。
如上,我們創建了一個每隔4分鐘執行一次的任務號為300的任務。可以通過Oracle提供的數據字典user_jobs察看該任務的執行情況:
sql> select job,next_date,next_sec,failures,broken from user_jobs;

執行結果如下:
job next_date next_sec failures broken
300 2000/10/10 11:45:15 0 N
這表示任務號為300的任務,下一次將在2000/10/10 11:45:15執行,此任務的執行失敗記錄為0次。註意:當執行job出現錯誤時,Oracle將其記錄在日誌裏,失敗次數每次自動加1。當執行失敗次 數達到16時,Oracle就將該job標誌為broken。此後,Oracle不再繼續執行它,直到用戶調用過

例子:

begin
  sys.dbms_job.submit(job => :job,
                      what => ADD_PLY_INTOXG;,
                      next_date => to_date(01-01-4000, dd-mm-yyyy),
                      interval => to_date(to_char(SYSDATE,‘‘yyyy/mm/dd hh24‘‘)||‘‘:00:00‘‘,‘‘yyyy/mm/dd hh24:mi:ss‘‘)+65/1440);
  sys.dbms_job.broken(job => :job,
                      broken => true,
                      next_date => to_date(01-01-4000, dd-mm-yyyy));
  commit;
end;
/

oracle定時任務(dbms_job)