JDBC操作存儲過程、存儲函數、out參數使用遊標
阿新 • • 發佈:2018-08-01
輸入參數 獲取值 cti rep inf 定義 java ber util
JDBC工具類
public class JDBCUtils { private static String driver = "oracle.jdbc.OracleDriver"; private static String url = "jdbc:oracle:thin:@192.168.79.128:1521/orcl"; private static String user = "scott"; private static String password = "tiger"; static{ //註冊驅動//DriverManager.registerDriver(driver) try { Class.forName(driver); } catch (ClassNotFoundException e) { throw new ExceptionInInitializerError(e); } } public static Connection getConnection(){ try { return DriverManager.getConnection(url, user, password); }catch (SQLException e) { e.printStackTrace(); } return null; } public static void release(Connection conn,Statement st,ResultSet rs){ if(rs != null){ try { rs.close(); } catch (SQLException e) { e.printStackTrace(); }finally{ rs = null; ///-----> 原因:Java GC: Java的GC不受代碼的控制 } } if(st != null){ try { st.close(); } catch (SQLException e) { e.printStackTrace(); }finally{ st = null; } } if(conn != null){ try { conn.close(); } catch (SQLException e) { e.printStackTrace(); }finally{ conn = null; } } } }
存儲過程
--存儲過程 create or replace procedure queryEmpInformation(eno in number, pename out varchar2, psal out number, pjob out varchar2) is begin select ename,sal,job into pename,psal,pjob from emp where empno = eno; end queryEmpInformation;
java代碼
@Test public void testProcedure(){ //jdbc調用存儲過程sql語句: //{call <procedure-name>[(<arg1>,<arg2>, ...)]} String sql = "{call queryEmpInformation(?,?,?,?)}"; Connection conn = null; CallableStatement call = null; try{ conn = JDBCUtils.getConnection(); call = conn.prepareCall(sql); //輸入參數賦值 call.setInt(1, 7839); //輸出參數,聲明為輸出參數 call.registerOutParameter(2, OracleTypes.VARCHAR); call.registerOutParameter(3, OracleTypes.NUMBER); call.registerOutParameter(4, OracleTypes.VARCHAR); //執行 call.execute(); //獲取值 String name = call.getString(2); double sal = call.getDouble(3); String job = call.getString(4); System.out.println(name+"\t"+sal+"\t"+job); }catch (Exception e){ e.printStackTrace(); }finally{ JDBCUtils.release(conn, call, null); } }
存儲函數
--存儲函數 create or replace function queryEmpIncome(eno in number) return number is psal emp.sal%type; pcomm emp.comm%type; begin select sal,comm into psal,pcomm from emp where empno = eno; return psal*12+nvl(pcomm,0); end queryEmpIncome;
java代碼
@Test public void testFuntion(){ //jdbc調用存儲函數sql語句: //{?= call <procedure-name>[(<arg1>,<arg2>, ...)]} String sql = "{? = call queryEmpIncome(?)}"; Connection conn = null; CallableStatement call = null; try{ conn = JDBCUtils.getConnection(); call = conn.prepareCall(sql); //註冊輸出參數 call.registerOutParameter(1, OracleTypes.NUMBER); //輸入參數 call.setInt(2, 7839); //執行 call.execute(); //取出返回值 double income = call.getDouble(1); System.out.println("年薪:"+income); }catch (Exception e){ e.printStackTrace(); }finally{ JDBCUtils.release(conn, call, null); } }
out參數遊標
--創建包頭 create or replace package mypackage is --定義一個cursor類型變量 type empcursor is ref cursor; procedure queryEmpList(dno in number,empList out empcursor); end mypackage; --創建包體 create or replace package body mypackage is procedure queryEmpList(dno in number,empList out empcursor) as begin open empList for select * from emp where deptno = dno; end; end mypackage;
java代碼
@Test public void testCursor(){ String sql = "call mypackage.queryEmpList(?,?)"; Connection conn = null; CallableStatement call = null; ResultSet rs = null; try{ conn = JDBCUtils.getConnection(); call = conn.prepareCall(sql); call.setInt(1, 20); call.registerOutParameter(2, OracleTypes.CURSOR); call.execute(); rs = ((OracleCallableStatement)call).getCursor(2); while(rs.next()){ String name = rs.getString("ename"); double sal = rs.getDouble("sal"); System.out.println(name+"\t"+sal); } }catch (Exception e){ e.printStackTrace(); }finally{ JDBCUtils.release(conn, call, null); } }
JDBC操作存儲過程、存儲函數、out參數使用遊標