(文章本人原創，若轉載請注明出處)

下面看一下一些具體的實現，先看一下Sender接口的commitData方法的MySql實現，即SenderMySqlImp類：

    很簡單吧，其實就是用Stream來做，另外在網上可以找到有關Oracle上傳blob的實現，一般都是先insert一條記錄，blob字段用empty_blob()函數插入一個空數據，然后再取出這個blob字段，最后按字節寫入blob，具體參考SenderOracleImp類吧。個人感覺還是在mysql的這個效率高些并且看起來簡單了很多。

    然后來看看使用線程池的ProcessMulti類：

(文章本人原創，若轉載請注明出處)

　　在實際當中的情況是系統數據庫中需要上傳大量照片到數據庫中，數據量比較大，且不能在界面中通過操作逐個上傳，要批量自動進行。其實起來也比較簡單直接利用線程池將照片數據讀取成流再存入BLOB字段即可。但是在實現后些功能后又進入了一些改造，實現了線程池、單線程、是否使用用連接池、不同數據庫等不同的配置，這樣在不同配置下可以觀察到程序性能的不同。并且經過設計切換這些配置不需要修改程序。

使用DbAccess接口的getConnect()取得數據庫連接，DbImp和DbPoolingImp實現了不使用連接池和使用連接池的兩個版本。Sender接口的commitData()用來把BLOB數據寫到數據庫中，因為不同數據庫可能寫法有點不同所以這里SenderMySqlImp和SenderOracleImp分別是Mysql和Oracle的實現。Process接口的doProcess()是開始進行處理的方法，無論是單線程還是多線程。因此ProcessMulti和ProcessSingle是分別使用線程池以及單線程處理的類。ConfigMgr用于取得config.properties文件內配置信息，Logger是日志類，Helper中匯集了一些共用的靜態方法。最后DataSender是主程序的類：）

(文章本人原創，若轉載請注明出處)

　　　在JDK1.5提供了一個線程池ThreadPoolExecutor，可以處理用戶提交過來的線程。如果把要處理的任務比作蓋一個大樓，那么每一個建筑工人就相當于一個線程，那么這個ThreadPoolExecutor就好像包工頭，它來控制蓋這個大樓需要多少個工人，何時招進新工人，何時辭退已經長時間沒有事做的工人，等等此類事務。也就是說用戶程序不斷提交新的線程，ThreadPoolExecutor執行提交線程的同時會控制目前總共同時執行的線程數，銷毀已執行完閑置的線程等控制行為，保留最少閑置線程數，并且可以配置不同的處理策略。

　　　為什么要使用線程池呢，這與數據庫連接池的原理有點相仿，線程的創建是需要成本的，包括服務器CPU和內存資源，由于多線程是并行運行，程序運行過程中可能有的線程已經完成自身處理任務，處于閑置狀態，如果在這種情況下再不斷創建新任務就是在浪費服務器資源，此時應該盡量使用先前創建的好的并且是處理閑置狀態的線程來處理新任務，而線程池就可以有效的對此進行自動化管理，當然這個管理是可以由用戶配置的。

ThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
RejectedExecutionHandler handler)

這是線程池的構建器，用戶程序通過這個構建器傳參數，corePoolSize是線程池中核心線程數，運行的線程數不能少于這個核心線程數，否則就新建線程。maximumPoolSize是充許最大的線程數。keepAliveTime設置除核心線程外其它線程的空閑時間，超過這個時間線程就自動終止。unit是指的keepAliveTime的時間單位。BlockingQueue接口按生產則消費者算法設計的一個線程池內部處理線程隊列的接口，有三種實現SynchronousQueue、LinkedBlockingQueue和ArrayBlockingQueue，在實際運行程序時可以根據這三種實現得到不同的性能，比如有的實現可能在有新任務來時不新建線程，而是將其加入等待隊列，等有線程運行完時再分配給其使用。具體實現還是參看它們的JDK文檔吧，這里站在使用的角度它們是可以調整運行性能的開關。當最大線程和工作隊列容量都達到最大值時，再提交給線程池新任務就會被拒絕，此時線程池會調用RejectedExecutionHandler 接口進行處理，具體實現有四種策略。我們只需要選用其中一種在構建ThreadPoolExecutor時傳入即可。具體四種實現還是參看JDK文檔吧。關于ThreadPoolExecutor的JDK文檔。至此控制線程池運作的幾個參數都從構建器中傳入了。

google了一篇不錯的例子，加了點注解，這樣看起來更方便了：）

Oracle不像SQLServer那樣在存儲過程中用Select就可以返回結果集，而是通過Out型的參數進行結果集返回的。實際上是利用REF CURSOR

--procedure返回記錄集：

----------------------聲明一個Package--------------
CREATE OR REPLACE PACKAGE pkg_test
AS
TYPE myrctype IS REF CURSOR;

PROCEDURE get (p_id NUMBER, p_rc OUT myrctype); --Package中聲明名為get 的Procedure(只有接口沒內容)

END pkg_test;

--------------------------------------------------------

-----------------聲明Package Body，即上面Package中的內容，包括Procedure get---------------------
CREATE OR REPLACE PACKAGE BODY pkg_test
AS
PROCEDURE get (p_id NUMBER, p_rc OUT myrctype)
IS
sqlstr VARCHAR2 (500);
BEGIN
IF p_id = 0 THEN
OPEN p_rc FOR
SELECT ID, NAME, sex, address, postcode, birthday
FROM student;
ELSE
sqlstr :=
'select id,name,sex,address,postcode,birthday
from student where id=:w_id'; --w_id是個參數，

--以下 p_rc是個REF CURSOR游標類型，而且是OUT型參數，即可返回一個記錄集了。USING p_id就是替換上面SQL中:w_id值拉:)
OPEN p_rc FOR sqlstr USING p_id;　

END IF;
END get;
END pkg_test;


--function返回記錄集的例子，原理和上面相同，而是用function的return值來返回記錄集。

函數返回記錄集:
建立帶ref cursor定義的包和包體及函數：
CREATE OR REPLACE
package pkg_test as
/* 定義ref cursor類型
不加return類型，為弱類型，允許動態sql查詢，
否則為強類型，無法使用動態sql查詢;
*/
type myrctype is ref cursor;
function get(intID number) return myrctype;
end pkg_test;
/

CREATE OR REPLACE
package body pkg_test as
--函數體
function get(intID number) return myrctype is
rc myrctype; --定義ref cursor變量
sqlstr varchar2(500);
begin
if intID=0 then
--靜態測試，直接用select語句直接返回結果
open rc for select id,name,sex,address,postcode,birthday from student;
else
--動態sql賦值，用:w_id來申明該變量從外部獲得
sqlstr := 'select id,name,sex,address,postcode,birthday from student where id=:w_id';
--動態測試，用sqlstr字符串返回結果，用using關鍵詞傳遞參數
open rc for sqlstr using intid;
end if;

return rc;
end get;

end pkg_test;

在ORACLE存儲過程中創建臨時表

存儲過程里不能直接使用DDL語句，所以只能使用動態SQL語句來執行

--ON COMMIT DELETE ROWS 說明臨時表是事務指定，每次提交后ORACLE將截斷表（刪除全部行）
--ON COMMIT PRESERVE ROWS 說明臨時表是會話指定，當中斷會話時ORACLE將截斷表。

CREATE OR REPLACE PROCEDURE temptest
(p_searchDate IN DATE)
IS
v_count INT;
str varchar2(300);
BEGIN
v_count := 0;
str:='drop table SETT_DAILYTEST';
execute immediate str;
str:='CREATE GLOBAL TEMPORARY TABLE SETT_DAILYTEST (
NACCOUNTID NUMBER not null,
NSUBACCOUNTID NUMBER not null)
ON COMMIT PRESERVE ROWS';
execute immediate str; ----使用動態SQL語句來執行
str:='insert into SETT_DAILYTEST (select naccountid,nsubaccountid from sett_dailyaccountbalance)';
execute immediate str;
END temptest;

上面建立一個臨時表的存儲過程

下面是執行一些操作,向臨時表寫數據。

CREATE OR REPLACE PROCEDURE PR_DAILYCHECK
(
p_Date IN DATE,
p_Office IN INTEGER,
p_Currency IN INTEGER,
P_Check IN INTEGER,
p_countNum OUT INTEGER)
IS
v_count INT;
BEGIN
v_count := 0;
IF p_Date IS NULL THEN
dbms_output.put_line('日期不能為空');
ELSE
IF P_Check = 1 THEN
insert into SETT_DAILYTEST (select naccountid,nsubaccountid from sett_dailyaccountbalance
where dtdate = p_Date);
select
count(sd.naccountid) into v_count
from sett_subaccount ss,sett_account sa,sett_dailytest sd
where sd.naccountid = sa.id and sd.nsubaccountid = ss.id and sa.id = ss.naccountid
AND sa.nofficeid = p_Office AND sa.ncurrencyid = p_Currency
and rownum < 2;
COMMIT;
p_countNum := v_count;
dbms_output.put_line(p_countNum);
END IF;
IF P_Check = 2 THEN
insert into SETT_DAILYTEST (select naccountid,nsubaccountid from sett_dailyaccountbalance
where dtdate = p_Date);
select
count(sd.naccountid) into v_count
from sett_cfsubaccount ss,sett_account sa,sett_dailytest sd
where sd.naccountid = sa.id and sd.nsubaccountid = ss.id and sa.id = ss.naccountid
AND sa.nofficeid = p_Office AND sa.ncurrencyid = p_Currency
and rownum < 2;
COMMIT;
p_countNum := v_count;
dbms_output.put_line(p_countNum);
END IF;
END IF;
END PR_DAILYCHECK;

Oracle本身沒數組的概念，但是通過Oracle的Collections和Records類型可以模仿出單維數組和多維數組。

請參考<<Oracle PL/SQL Programming>> Chapter 11、Chapter 12。

---------------------- 單維數組 ------------------------
DECLARE
TYPE emp_ssn_array IS TABLE OF NUMBER INDEX BY BINARY_INTEGER; ----注：聲明一個Collection

best_employees emp_ssn_array;
worst_employees emp_ssn_array;

BEGIN
best_employees(1) := '123456';
best_employees(2) := '888888';

worst_employees(1) := '222222';
worst_employees(2) := '666666';

FOR i IN 1..best_employees.count LOOP
DBMS_OUTPUT.PUT_LINE('i='|| i || ', best_employees= ' ||best_employees(i)
|| ', worst_employees= ' ||worst_employees(i));
END LOOP;

END;

---------------------- 多維數組 ------------------------

DECLARE

TYPE emp_type IS RECORD ---------注：聲明一個Record類型　emp_type
( emp_id employee_table.emp_id%TYPE, 　　　　　　　　　　----Record類型中的成員...
emp_name employee_table.emp_name%TYPE,
emp_gender employee_table.emp_gender%TYPE );

TYPE emp_type_array IS TABLE OF ----注：聲明一個Collection類型 emp_type_array ，其中元素為emp_type類型
emp_type INDEX BY BINARY_INTEGER;

emp_rec_array emp_type_array;
emp_rec emp_type;

BEGIN
emp_rec.emp_id := 300000000;
emp_rec.emp_name := 'Barbara';
emp_rec.emp_gender := 'Female';

emp_rec_array(1) := emp_rec;

emp_rec.emp_id := 300000008;
emp_rec.emp_name := 'Rick';
emp_rec.emp_gender := 'Male';

emp_rec_array(2) := emp_rec;

FOR i IN 1..emp_rec_array.count LOOP
DBMS_OUTPUT.PUT_LINE('i='||i
||', emp_id ='||emp_rec_array(i).emp_id
||', emp_name ='||emp_rec_array(i).emp_name
||', emp_gender = '||emp_rec_array(i).emp_gender);
END LOOP;

END;
-------------- Result --------------
i=1, emp_id =300000000, emp_name =Barbara, emp_gender = Female
i=2, emp_id =300000008, emp_name =Rick, emp_gender = Male