(文章本人原创，若转载请注明出处)

下面看一下一些具体的实现，先看一下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