java程序调用存储过程
PL/SQL子程序,很多情况下是给应用程序来调用的,所有我们要掌握使用其他编程语言来调用我们写好的存储过程。下面我们介绍下使用java调用Oracle的存储过程。
准备代码:
package com.mscncn.plsql.util; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; public class DBUtil { static{ try { Class.forName("oracle.jdbc.OracleDriver"); } catch (ClassNotFoundException e) { e.printStackTrace(); } } public static Connection getConntection(){ Connection ct=null; try { ct = DriverManager.getConnection( "jdbc:oracle:thin:@192.168.0.25:1521:oracle", "scott", "scott"); } catch (SQLException e) { e.printStackTrace(); } return ct; } }
create or replace package pro_pk is type pager_cursor is ref cursor; procedure add_dept(dept_no in number,dept_name in varchar2,location in varchar2); procedure delete_dept(dept_no in number,num out number); end pro_pk; create or replace package body pro_pk is procedure add_dept(dept_no in number,dept_name in varchar2,location in varchar2) is exp_remaining exception; pragma exception_init(exp_remaining,-1);/*非预定义错误,-1是违反唯一约束*/ begin insert into dept values(dept_no,dept_name,location); if sql%found then /*隐式游标,sql*/ return 1; else return 0; end if; exception when exp_remaining then dbms_output.put_line(‘违反唯一约束.‘); end add_dept; procedure delete_dept(dept_no in number,num out number) is begin delete from dept where deptno=dept_no; if sql%found then num:=1; else num:=1; end if; end delete_dept; end pro_pk;
create or replace package pageUtil is type page_cursor is ref cursor;--定义一个游标类型 procedure pager( tName in varchar2, --表名 pageNum in number, --页数 pageSize in number,--每页记录数 totalRecord out number,--总记录数 totalPage out number,--总页数 p_cursor out page_cursor); end pageUtil; create or replace package body pageUtil is procedure pager( tName in varchar2, --表名 pageNum in number, --页数 pageSize in number,--每页记录数 totalRecord out number,--总记录数 totalPage out number,--总页数 p_cursor out page_cursor) is --定义sql语句字符串 v_sql varchar2(1000); --分页开始位置,与结束位置 v_begin number:=(pageNum-1)*pageSize+1; v_end number:=pageNum*pageSize; begin v_sql:=‘select * from ( select t.*,rownum rn from ‘ ||tName||‘ t where rownum<=‘||v_end||‘) where rn>=‘||v_begin; --把游标和sql关联 dbms_output.put_line(v_sql); open p_cursor for v_sql; --计算totalRecord与totalPage v_sql:=‘select count(*) from ‘||tName; -- execute immediate v_sql into totalRecord; if mod(totalRecord,pageSize)=0 then totalPage:=totalRecord/pageSize; else totalPage:=totalRecord/pageSize+1; end if; --关闭游标,这儿需要注意,如果我们在java程序中使用cursor,那么就一定不能关闭cursor --否则关闭cursor后,java程序中返回的结果集就是null --close p_cursor; end pager; end pageUtil;
1. java调用没有返回值的存储过程。
/** * java调用没有返回值的存储过程 */ @Test public void proNoReulstTest(){ Connection ct=DBUtil.getConntection(); try { CallableStatement cs=ct.prepareCall("{call pro_pk.add_dept(?,?,?)}"); cs.setInt(1, 13); cs.setString(2, "java开发部"); cs.setString(3, "中国信阳"); cs.execute(); } catch (SQLException e) { e.printStackTrace(); }finally{ try { ct.close(); } catch (SQLException e) { e.printStackTrace(); } } }
2. java程序调用有返回值的存储过程
/** * java调用有返回值的存储过程(返回值类型为number) */ @Test public void proHasReulstTest(){ Connection ct=DBUtil.getConntection(); try { CallableStatement cs=ct.prepareCall("{call pro_pk.delete_dept(?,?)}"); cs.setInt(1, 13); //注册第二个参数为存储过程的返回值 cs.registerOutParameter(2, OracleType.STYLE_INT); cs.execute(); //通过参数的索引,来获取存储过程的返回值,索引从1开始 int num=cs.getInt(2); System.out.println(num==1?"删除成功":"删除失败"); } catch (SQLException e) { e.printStackTrace(); }finally{ try { ct.close(); } catch (SQLException e) { e.printStackTrace(); } } }
3. java程序调用存储过程返回值为游标
/** * 存储过程返回一个游标 */ @Test public void proReturnCursorTest(){ Connection ct=DBUtil.getConntection(); try { CallableStatement cs=ct.prepareCall("{call pageUtil.pager(?,?,?,?,?,?)}"); cs.setString(1, "emp"); cs.setInt(2, 2); cs.setInt(3, 5); cs.registerOutParameter(4, OracleTypes.NUMBER); cs.registerOutParameter(5, OracleTypes.NUMBER); cs.registerOutParameter(6, OracleTypes.CURSOR); cs.execute(); //通过参数的索引,来获取存储过程的返回值,索引从1开始 int totalRecord=cs.getInt(4); int totalPage=cs.getInt(5); ResultSet rs=(ResultSet)cs.getObject(6); System.out.println("总记录数为:"+totalRecord+",总页数为:"+totalPage); while(rs.next()){ System.out.println("雇员编号:"+rs.getInt("empno")+",雇员姓名:"+rs.getString("ename")); } } catch (SQLException e) { e.printStackTrace(); }finally{ try { ct.close(); } catch (SQLException e) { e.printStackTrace(); } } }
时间: 2024-10-05 08:45:27