java调用Oracle存储过程的方法实例
作者:
1.测试添加数据的procedure
public void testProcedure() {
Connection con = getConnction();
// **1.测试添加数据的procedure
String procedure = "{call users_insert_proc(?,?,?,?) }";
CallableStatement cs = null;
try {
cs = con.prepareCall(procedure);
cs.setInt(1, 123450);
cs.setString(2, "xxiaox");
cs.setString(3, "Ww342864");
cs.setString(4, "742621646@qq.com");
} catch (SQLException e) {
e.printStackTrace();
}
try {
cs.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
}
}
2.测试删除数据的procedure
public void testDelPro() {
Connection con = getConnction();
// **2.测试删除数据的procedure
String procedure = "{call delete_usersbyid_proc(?) }";
CallableStatement cs = null;
try {
cs = con.prepareCall(procedure);
cs.setInt(1, 123450);
} catch (SQLException e) {
e.printStackTrace();
}
try {
cs.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
}
}
3.测试更新数据的procedure
public void testDelPro() {
Connection con = getConnction();
// **3.测试更新数据的procedure
String procedure = "{call users_updatebyId_proc(?,?,?,?) }";
CallableStatement cs = null;
try {
cs = con.prepareCall(procedure);
cs.setInt(1, 101); cs.setString(2, "小第三方的浩"); cs.setString(3, "asdf342864"); cs.setString(4, "742621646@qq.com");
} catch (SQLException e) {
e.printStackTrace();
}
try {
cs.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
}
}
4.测试查找数据的procedure
a)建包体
b)创建查询的procedure
create or replace package userspackage as
type users_cursor is ref cursor;
end userspackage;
create or replace procedure users_packageAll(
s_id in number ,u_cursor out userspackage.users_cursor) is
begin
if s_id = 0 then
open u_cursor for select id,name,pword,email from users;
else
open u_cursor for select id,name,pword,email from users where id=s_id;
end if;
end;
c)Java调用
public void testDelPro() {
Connection con = getConnction();
// 返回查询procedure
String procedure = "{call users_packageAll(?,?) }";
CallableStatement cs = null;
try {
cs = con.prepareCall(procedure);
cs.setInt(1, 0);
cs.registerOutParameter(2, oracle.jdbc.OracleTypes.CURSOR);
} catch (SQLException e) {
e.printStackTrace();
}
try {
cs.execute();
ResultSet rs = (ResultSet)cs.getObject(2);
while (rs.next()) {
System.out.println(rs.getInt(1) + " " + rs.getString(2));
}
} catch (SQLException e) {
e.printStackTrace();
}
}
您可能感兴趣的文章:
- Java Spring动态生成Mysql存储过程详解
- 详解java调用存储过程并封装成map
- MyBatis创建存储过程的实例代码_动力节点Java学院整理
- Java调用Oracle存储过程详解
- Java实现调用MySQL存储过程详解
- 详解Java的JDBC API的存储过程与SQL转义语法的使用
- java编程调用存储过程中得到新增记录id号的实现方法
- Java调用MySQL存储过程并获得返回值的方法
- java调用mysql存储过程实例分析
- Java中调用SQL Server存储过程详解
- java调用oracle分页存储过程示例
- Java下使用Oracle存储过程(详解)
- Java存储过程调用CallableStatement的方法