日期:2014-05-20 浏览次数:20922 次
--初始化数据 create table student ( id int, name varchar(20), age int, sex varchar(2), birth date ); insert into student values(1,'张三',23,'男',sysdate); insert into student values(2,'李四',24,'男',sysdate); insert into student values(3,'王五',25,'男',sysdate); --创建包 create or replace package TestPackage as type TestRecord1 is record(id int,name varchar(20)); type TestTable1 is table of TestRecord1 index by binary_integer; procedure TestProcedure1(result out TestTable1); end TestPackage; --建存储过程 create or replace package body TestPackage as procedure TestProcedure1(result out TestTable1) as record1 TestRecord1; v_id int; v_name varchar(20); cursor1 sys_refcursor; begin open cursor1 for select id,name from student; loop fetch cursor1 into v_id,v_name; if cursor1%notfound then exit; else record1.id := v_id; record1.name := v_name; result(result.count) := record1; end if; end loop; end TestProcedure1; end TestPackage; --调用存储过程正确 declare table1 TestPackage.TestTable1; i int := 0; begin TestPackage.TestProcedure1(table1); while i < table1.count loop dbms_output.put_line(table1(i).id); i := i + 1; end loop; end;
//这个就有错了 Class.forName("oracle.jdbc.driver.OracleDriver"); Connection con = DriverManager.getConnection("jdbc:oracle:thin:@127.0.0.1:1521:test","xxx","yyy"); OracleCallableStatement cs = (OracleCallableStatement) con.prepareCall("{call TestPackage.TestProcedure1(?)}"); cs.registerOutParameter(1, oracle.jdbc.OracleTypes.ARRAY,"TestPackage.testTable1".toUpperCase()); cs.execute(); ARRAY array = cs.getARRAY(1); Datum[] data = array.getOracleArray(); for(Datum d:data) { STRUCT struct = (STRUCT)d; Datum[] stringValue = struct.getOracleAttributes(); Object[] noStringValue = struct.getAttributes(); System.out.print((BigDecimal)noStringValue[0]);//id System.out.println(new String(stringValue[1].getBytes()));//name } cs.close(); con.close();
//java调用oracle存储过程时数组参数 import oracle.sql.STRUCT; import oracle.sql.StructDescriptor; public ReturnType BatchAddTerminals(TerminalUsersType[] tus) { ReturnType ret = new ReturnType(); ret.setCode(0); //Connection conn = C3P0Pool.getInstance().getConn(); GeneralConnect gc = new GeneralConnect(); Connection conn = gc.getConnection(); oracle.jdbc.OracleConnection oracleConn = (oracle.jdbc.OracleConnection) conn; CallableStatement stat = null; if (oracleConn != null) { try { StructDescriptor sd = new StructDescriptor( "TYPE_TERMINAL_USER", oracleConn); STRUCT[] results = new STRUCT[tus.length]; for (int i = 0; i < tus.length; i++) { Object[] o = new Object[7]; o[0] = new Integer(tus[i].getEpid()); o[1] = new String(tus[i].getUserName()); o[2] = new String(tus[i].getMobile()); o[3] = new String(tus[i].getTermCode()); o[4] = new String(tus[i].getUserDesc()); o[5] = new String(tus[i].getSmsMobile()); o[6] = new String(tus[i].getPassword()); results[i] = new STRUCT(sd, oracleConn, o); } String sql = "{call PACK_USER_TERMINALS.BatchAddTerminals(?,?,?)}"; stat = oracleConn.prepareCall(sql); stat.registerOutParameter(2, java.sql.Types.INTEGER); stat.registerOutParameter(3, java.sql.Types.VARCHAR); oracle.sql.ArrayDescriptor des_TABLE_TERMINAL_USER = oracle.sql.ArrayDescriptor .createDescriptor("TABLE_TERMINAL_USER", oracleConn); oracle.sql.ARRAY ora_array1 = new oracle.sql.ARRAY( des_TABLE_TERMINAL_USER, oracleConn, results); stat.setArray(1, ora_array1); stat.execute(); ret.setCode(stat.getInt(2)); ret.setDesc(stat.getString(3)); } catch (java.sql.SQLException ex) { Log.getInstance().outLog("访问数据库异常" + ex.getMessage()); ret.setDesc("访问数据库异常" + ex.getMessage()); } catch (Exception ex) { Log.getInstance().outLog("其他异常" + ex.getMessage()); ret.setDesc("其他异常" + ex.getMessage()); } finally { CloseDB.attemptClose(stat); CloseDB.attemptClose(conn); } } return ret; }