日期:2014-05-16  浏览次数:20412 次

JDBC执行Oracle传入参数为集合对象的存储过程

当需要把插入多条数据的行为合并为一个事务时,可以考虑把一个list型数据作为参数传入存储过程,
可以调用jdbc内部实现类来实现,这些类在classes12.zip(oracle 8,别的版本可能是其他名字的zip包)。
?如:
(一)??需要将一个list传入存储过程。
?具体操作如下:
??1,建立数据库对象来映射list数据类型。
???--定义一个与list中各元素的数据类型相同的数据库对象
???CREATE TYPE AOBJECT AS OBJECT(
????? aaaa????????? NUMBER(8),
????? bbbb???????? NUMBER(8)
??? )
???/
???--定义一个list数据库对象
???CREATE TYPE ALIST AS VARRAY(100) OF AOBJECT
???/

??2,具体java代码如下:
??import java.sql.CallableStatement;
??import java.sql.Connection;
??import java.sql.PreparedStatement;
??import java.util.ArrayList;
??
??/*
?? * 以下就是classes12.zip中的实现类
??*/
??import oracle.jdbc.driver.OracleCallableStatement;
??import oracle.sql.ARRAY;
??import oracle.sql.ArrayDescriptor;
??import oracle.sql.STRUCT;
??import oracle.sql.StructDescriptor;?
??
??.......
??
??public static long addRecords(ArrayList list) {
???Connection con = null;
???CallableStatement stmt = null;
???int backVal = 0;
???try {
????con = pool.getConnection();
????if (con != null) {
?????ARRAY aArray = getArray(con, "AOBJECT","ALIST", list);//该函数调用的第二三个参数必须大写
?????stmt = con.prepareCall("{call produce1(?,?)}");?//调用某个存储过程
?????((OracleCallableStatement) stmt).setARRAY(1, aArray);
?????stmt.registerOutParameter(2, java.sql.Types.INTEGER);
?????stmt.execute();
?????backVal = stmt.getInt(2);
????}?
???} catch (Exception e) {
????....
???} finally {
????....//释放数据库连接
???}
???return backVal;
??}

??private static ARRAY getArray(Connection con, String OracleObj,
???String Oraclelist, ArrayList objlist) throws Exception {
???ARRAY list = null;
???if (objlist != null && objlist.size() > 0) {
????StructDescriptor structdesc = new StructDescriptor(OracleObj, con);
????STRUCT[] structs = new STRUCT[objlist.size()];
????Object[] result = new Object[0];
????for (int i = 0; i < objlist.size(); i++) {
?????result = new Object[2];//数组大小应和你定义的数据库对象(AOBJECT)的属性的个数
?????result[0] = new Integer(..);??//将list中元素的数据传入result数组
?????result[1] = new Integer(..);??//
?????
?????structs[i] = new STRUCT(structdesc, con, result);
????}
????ArrayDescriptor desc = ArrayDescriptor.createDescriptor(Oraclelist,
??????con);
????list = new ARRAY(desc, con, structs);
???} // if
???return list;
??} // function
??
(二)?当需要传入存储过程的参数的集合类型的数据时,这个集合容器中的元素可能不需要一个类似结构体的类型,具有多个元素。
而是一个基本类型的集合,可以采用oracle的数组的概念。
?1,建立数据库对象来映射list数据类型。
?? --定义一个list数据库对象
???CREATE TYPE ALIST AS VARRAY(100) OF? NUMBER(12, 2);
???/
? 2,具体java代码如下:
??import java.sql.CallableStatement;
??import java.sql.Connection;
??import java.sql.PreparedStatement;
??import java.util.ArrayList;
??
??/*
?? * 以下就是classes12.zip中的实现类
??*/
??import oracle.jdbc.driver.OracleCallableStatement;
??import oracle.sql.ARRAY;
??import oracle.sql.ArrayDescriptor;
??import oracle.sql.STRUCT;
??import oracle.sql.StructDescriptor;?
??
??.......
??
??public static long addRecords(ArrayList list) {
???Connection con = null;
???CallableStatement stmt = null;
???int backVal = 0;
???try {
????con = pool.getConnection();
????if (con != null) {
??????
??????int elements[] = { 300, 400, 500, 600 };??????????????? // line 59
???? ArrayDescriptor desc = ArrayDescriptor.createDescriptor("ALIST", conn);
???? ARRAY aArray = new ARRAY(desc, conn, elements);

?????stmt = con.prepareCall("{call produce1(?,?)}");