1. 前言 在ＯＲＡＣＬＥ數(shù)據(jù)庫實(shí)際應(yīng)用過程中，經(jīng)常把業(yè)務(wù)處理邏輯的放在存儲(chǔ)過程，客戶端通過ＡＤＯ進(jìn)行調(diào)用。有些業(yè)務(wù)邏輯處理量大并且復(fù)雜，使客戶端調(diào)用存儲(chǔ)過程后，長時(shí)間沒有反應(yīng)，也不知存儲(chǔ)過程運(yùn)行狀態(tài)，本文講述如何在ＯＲＡＣＬＥ通過任務(wù)和管道的應(yīng)用，異步調(diào)用存儲(chǔ)過程的方法。 2. 基本原理 1.使用DBMS_JOB包將主處理存儲(chǔ)過程作為任務(wù)提交到任務(wù)隊(duì)列中； 2.主處理存儲(chǔ)過程在運(yùn)行過程中通過DBMS_PIPE包將處理情況放在管道中； 3.監(jiān)控存儲(chǔ)過程讀取管道，從而了解處理情況； 4.本文沒有描述雙向通信的方式，監(jiān)控存儲(chǔ)過程可以通過管道發(fā)送信息給主處理存儲(chǔ)過程。 3. 具體實(shí)現(xiàn)測試 建立測試環(huán)境 3.1. 對數(shù)據(jù)庫的ini進(jìn)行相關(guān)修改，使系統(tǒng)的任務(wù)隊(duì)列功能打開 對于Oracle9I，只需修設(shè)定數(shù)據(jù)庫的INI內(nèi)的'JOB_QUEUE_PROCESSES=非0值'，如 'JOB_QUEUE_PROCESSES=10'，對于ORACLE8I除設(shè)定實(shí)例ini文件中的'JOB_QUEUE_PROCESSES=非0值'外，還需設(shè)定'job_queue_interval=1'。 3.2. 設(shè)用用戶權(quán)限 由于使用ORACLE中特定的程序包，所以要注重要明文給于用戶系統(tǒng)權(quán)限。對當(dāng)前用戶（測試用戶），賦于以下權(quán)力： EXECUTE DBMS_PIPEEXECUTE DBMS_LOCKEXECUTE DBMS_JOB3.3. 建立模擬大業(yè)務(wù)處理存儲(chǔ)過程 本存儲(chǔ)過程通過循環(huán)30次，調(diào)用DBMS_LOCK.SLEEP(1)（體眠1秒）和寫管道模擬大的處理過程。 具體代碼如下： CREATE OR REPLACE PROCEDURE maXPro ASn integer;status　NUMBER;BEGINFOR N IN 1..30 LOOPDBMS_PIPE.PURGE('maxpro'); --清除原管道信息DBMS_PIPE.PACK_MESSAGE(N); --把信息放入緩沖區(qū)status:=DBMS_PIPE.SEND_MESSAGE('maxpro');DBMS_LOCK.SLEEP(1);END LOOP;DBMS_PIPE.PURGE('maxpro');　--清除原管道信息DBMS_PIPE.PACK_MESSAGE(999999); --把信息放入緩沖區(qū),用999999 表示過程完成status:=DBMS_PIPE.SEND_MESSAGE('maxpro');END maxpro;3.4. 建立讀取管道動(dòng)態(tài)了解處理狀態(tài)的存儲(chǔ)過程 以下代碼是對于maxpro存儲(chǔ)過程的狀態(tài)進(jìn)行讀取的過程，主要使用讀取管道的方法，注重： status:= DBMS_PIPE.RECEIVE_MESSAGE('maxpro',0);中的'0'參數(shù)是很要害的，說明接受等待時(shí)間為0秒，表示,調(diào)用時(shí)假如沒有信息不等待直接返回。 具體代碼如下： CREATE OR REPLACE PROCEDURE readmaxpro　ASn integer;status integer;begin--接受等待時(shí)間為1秒,可以為0,立即調(diào)用或 DBMS_PIPE.RECEIVE_MESSAGE('mypipe') 等待100天status:= DBMS_PIPE.RECEIVE_MESSAGE('maxpro',0);--status為0為成功可以UNPACK_MESSAGE，1為超時(shí)沒有數(shù)據(jù)， 2為信息太大，3為內(nèi)部錯(cuò)誤IF status <> 0 THENDBMS_OUTPUT.PUT_LINE('管道中現(xiàn)在沒有信息返回');return;END IF;DBMS_PIPE.UNPACK_MESSAGE(n);DBMS_OUTPUT.PUT_LINE('maxpro 的當(dāng)前進(jìn)行狀態(tài)為' n);end;3.5. -起動(dòng)模擬大業(yè)務(wù)處理存儲(chǔ)過程為后臺(tái)進(jìn)程的存儲(chǔ)過程（BEGINMAXPRO） 通過DBMS_JOB.SUBMIT(JOB,'maxpro;',sysdate,NULL,FALSE);使'maxpro'為一個(gè)任務(wù)，在當(dāng)前時(shí)間（sysdate）后執(zhí)行,當(dāng)然假如把sysdate改一具體時(shí)間，那就在具體時(shí)間執(zhí)行。 具休代碼如下： CREATE OR REPLACE PROCEDURE beginmaxpro ASJOB BINARY_INTEGER;BEGINDBMS_JOB.SUBMIT(JOB,'maxpro;',sysdate,NULL,FALSE);DBMS_OUTPUT.PUT_LINE('隊(duì)列號(hào)碼JOB=' JOB);COMMIT;end;4. 代碼執(zhí)行 4.1. 執(zhí)行過程 在CMD行輸入 sqlplus 根據(jù)提示登錄設(shè)定DBMS_OUTPUT可見SQL> set serveroutput ON以下是執(zhí)行過程和相應(yīng)的返回信息SQL> call beginmaxpro();隊(duì)列號(hào)碼JOB=21調(diào)用完成。SQL> call readmaxpro();maxpro 的當(dāng)前進(jìn)行狀態(tài)為14調(diào)用完成。SQL> call readmaxpro();maxpro 的當(dāng)前進(jìn)行狀態(tài)為16調(diào)用完成。SQL> call readmaxpro();maxpro 的當(dāng)前進(jìn)行狀態(tài)為23調(diào)用完成。SQL> call readmaxpro();maxpro 的當(dāng)前進(jìn)行狀態(tài)為999999調(diào)用完成。SQL> call readmaxpro();管道中現(xiàn)在沒有信息返回調(diào)用完成。SQL>4.2. 執(zhí)行分析 beginmaxpro()，將主處理存儲(chǔ)過程放入隊(duì)列的過程，執(zhí)行后存儲(chǔ)程序馬上返回，maxpro存儲(chǔ)過程放在任務(wù)隊(duì)列中，并設(shè)定為在當(dāng)前系統(tǒng)時(shí)間執(zhí)行（馬上執(zhí)行）。 maxpro為主處理存儲(chǔ)過程，開始執(zhí)行模擬大業(yè)務(wù)處理，處理過程中將處理進(jìn)度信息寫入管道。 readmaxpro();為檢查狀態(tài)存儲(chǔ)過程，首先讀取信息，假如信息不存在，說明管道內(nèi)沒有信息可讀而退出；假如存在信息則讀出信息。 本例子可以進(jìn)行改進(jìn)，輸出不通過DBMS_OUTPUT.PUT_LINE而是用返回值，那么就可以在前端用ADO調(diào)用，發(fā)布任務(wù)，任務(wù)過程中從客戶端讀取進(jìn)度。代碼如下： CREATE OR REPLACE PROCEDURE readmaxpro(p out intergr)　ASn integer;status integer;beginstatus:= DBMS_PIPE.RECEIVE_MESSAGE('maxpro',0);IF status <> 0 THENP:=-1;return;END IF;DBMS_PIPE.UNPACK_MESSAGE(p);end;