java 调用 oracle 存储过程
2014-12-05 00:00
483 查看
摘要: java 调用 oracle 存储过程
-- 编写过程,要求输入雇员编号,返回雇员姓名。
create or replace procedure getNameByNo(no in number, name out varchar2) is
begin
select ename into name from emp where empno = no;
end;
-- 输入部门号,返回该部门所有员工
-- 先建一个包,定义一个游标类型
create or replace package pkg_cursor is
type my_cursor_type is ref cursor;
end pkg_cursor;
-- 创建过程
create or replace procedure getByDeptno(depno in number, emp_cursor out pkg_cursor.my_cursor_type) is
begin
open emp_cursor for
select * from emp where deptno = depno;
end;
2) java中调用的过程
a. 注册驱动类,并获取数据库连接
b. 用过程调用SQL语句(用{}括起来)获取CallableStatement对象。
c. 设置输入参数,如:cs.setInt(1, 7788);
d. 注册输出参数,如:cs.registerOutParameter(2, oracle.jdbc.OracleTypes.VARCHAR);
e. 执行过程cs.execute();
f. 获取过程返回结果,如:ResultSet rs = (ResultSet)cs.getObject(2);
g. 最后在finally中关闭资源。 import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
public class TestPro1 {
static final int empno = 7788;
static final int depno = 10;
public static void main(String[] args) {
Connection con = null;
CallableStatement cs = null;
try {
//注册JDBC驱动类
Class.forName("oracle.jdbc.driver.OracleDriver");
//获取连接
con = DriverManager.
getConnection("jdbc:oracle:thin:
@localhost :1521:orcltest", "test", "mm");
/************************* getNameByNo start ****************************/
cs = con.prepareCall("{call getNameByNo(?,?)}");
//设置参数
cs.setInt(1, empno);
//注册输出参数
cs.registerOutParameter(2, oracle.jdbc.OracleTypes.VARCHAR);
//执行过程
cs.execute();
//获取结果
String ename = cs.getString(2);
System.out.println("编号为" + empno + " 的姓名为:" + ename);
//编号为7788 的姓名为:SCOTT
/************************* getNameByNo end ****************************/
/************************* getByDeptno start ****************************/
cs = con.prepareCall("{call getByDeptno(?, ?)}");
//设置参数
cs.setInt(1, depno);
//注册输出参数
cs.registerOutParameter(2, oracle.jdbc.OracleTypes.CURSOR);
cs.execute();
//得到结果集
ResultSet rs = (ResultSet)cs.getObject(2);
System.out.println("部门号为" + depno + "的所有员工如下:");
while(rs.next()) {
System.out.println("员工编号:" + rs.getInt(1) +
", 员工姓名:" + rs.getString(2));
}
/************************* getByDeptno end ****************************/
//关闭资源(应在finally, 由于是示例就在这里关了)
cs.close();
con.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
-- 编写过程,要求输入雇员编号,返回雇员姓名。
create or replace procedure getNameByNo(no in number, name out varchar2) is
begin
select ename into name from emp where empno = no;
end;
-- 输入部门号,返回该部门所有员工
-- 先建一个包,定义一个游标类型
create or replace package pkg_cursor is
type my_cursor_type is ref cursor;
end pkg_cursor;
-- 创建过程
create or replace procedure getByDeptno(depno in number, emp_cursor out pkg_cursor.my_cursor_type) is
begin
open emp_cursor for
select * from emp where deptno = depno;
end;
2) java中调用的过程
a. 注册驱动类,并获取数据库连接
b. 用过程调用SQL语句(用{}括起来)获取CallableStatement对象。
c. 设置输入参数,如:cs.setInt(1, 7788);
d. 注册输出参数,如:cs.registerOutParameter(2, oracle.jdbc.OracleTypes.VARCHAR);
e. 执行过程cs.execute();
f. 获取过程返回结果,如:ResultSet rs = (ResultSet)cs.getObject(2);
g. 最后在finally中关闭资源。 import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
public class TestPro1 {
static final int empno = 7788;
static final int depno = 10;
public static void main(String[] args) {
Connection con = null;
CallableStatement cs = null;
try {
//注册JDBC驱动类
Class.forName("oracle.jdbc.driver.OracleDriver");
//获取连接
con = DriverManager.
getConnection("jdbc:oracle:thin:
@localhost :1521:orcltest", "test", "mm");
/************************* getNameByNo start ****************************/
cs = con.prepareCall("{call getNameByNo(?,?)}");
//设置参数
cs.setInt(1, empno);
//注册输出参数
cs.registerOutParameter(2, oracle.jdbc.OracleTypes.VARCHAR);
//执行过程
cs.execute();
//获取结果
String ename = cs.getString(2);
System.out.println("编号为" + empno + " 的姓名为:" + ename);
//编号为7788 的姓名为:SCOTT
/************************* getNameByNo end ****************************/
/************************* getByDeptno start ****************************/
cs = con.prepareCall("{call getByDeptno(?, ?)}");
//设置参数
cs.setInt(1, depno);
//注册输出参数
cs.registerOutParameter(2, oracle.jdbc.OracleTypes.CURSOR);
cs.execute();
//得到结果集
ResultSet rs = (ResultSet)cs.getObject(2);
System.out.println("部门号为" + depno + "的所有员工如下:");
while(rs.next()) {
System.out.println("员工编号:" + rs.getInt(1) +
", 员工姓名:" + rs.getString(2));
}
/************************* getByDeptno end ****************************/
//关闭资源(应在finally, 由于是示例就在这里关了)
cs.close();
con.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
相关文章推荐
- java 调用oracle的存储过程
- java 调用oracle的存储过程返回记录集
- java调用存储过程(oracle)
- JAVA调用oracle三种存储过程实例
- java调用Oracle分页存储过程
- Java调用Oracle的存储过程(实例)
- Java 调用 Oracle 存储过程返回结果集
- 当java调用oracle的存储过程时,存储过程的返回值类型不能为boolean
- java下实现调用oracle的存储过程和函数
- Oracle分页存储过程及java的具体调用方法
- java 调用oracle的存储过程返回记录集
- java调用oracle存储过程传入参数为数组的处理
- java调用oracle的存储过程
- Java调用Oracle 存储过程
- java oracle 存储过程调用
- java下实现调用oracle的存储过程和函数
- 最完整的:JAVA调用ORACLE的存储过程、函数的返回结果集例子
- JAVA调用Oracle存储过程传入结构化参数
- JAVA调用ORACLE带数组输入参数和返回游标结果集的存储过程
- java 调用oracle存储过程传入 数组参数 不用纯jdbc连接