Java jdbc调用Oracle数据库存储过程
一、了解CallableStatement接口
1.callablestatement接口提供了两种调用形式
{?= call <procedure-name>[(<arg1>,<arg2>, ...)]} //包含结果参数的调用形式 如:函数(funciton)
{call <procedure-name>[(<arg1>,<arg2>, ...)]} //不包含结果参数的调用形式 如:存储过程(procedure)
2.callablestatement接口提供的方法
void registerOutParameter(int parameterIndex, int sqlType)
throws SQLException; //在调用存储过程的时候设置输出参数的类型,用于接收输出结果
registerOutParameter接口中有四个该方法的重载实现,具体的可以查看源码了解
setXXX(int parameterIndex,XXX x) //主要用于设置过程调用时候需要的输入参数信息 其中XXX代表对应类型
getXXX(int x) //主要用于获取过程调用后返回的参数的信息
3.callablestatement接口产生的异常提示
如下源码:
/*
* @exception SQLFeatureNotSupportedException if <code>sqlType</code> is
* a <code>ARRAY</code>, <code>BLOB</code>, <code>CLOB</code>,
* <code>DATALINK</code>, <code>JAVA_OBJECT</code>, <code>NCHAR</code>,
* <code>NCLOB</code>, <code>NVARCHAR</code>, <code>LONGNVARCHAR</code>,
* <code>REF</code>, <code>ROWID</code>, <code>SQLXML</code>
* or <code>STRUCT</code> data type and the JDBC driver does not support
* this data type
* @see Types
*/
void registerOutParameter(int parameterIndex, int sqlType)
throws SQLException;
当我们使用registerOutParameter方法设置输出参数类型的时候,需要注意对于某一些类型是不能够
进行设置的如上中所以提到的类型都会引发SQLFeatureNotSupportedException异常,对于能够支持
的类型可以查看java.sql.Types和oracle.jdbc.OracleTypes
如下源码:
/*
* java.sql.SQLException: 不允许的操作: Ordinal binding and Named binding cannot be
* combined! at
* oracle.jdbc.driver.DatabaseError.throwSqlException(DatabaseError.java:112) at
* oracle.jdbc.driver.DatabaseError.throwSqlException(DatabaseError.java:146) at
* oracle
* .jdbc.driver.OracleCallableStatement.execute(OracleCallableStatement.java
* :4219) at
* org.viancent.call.procedure.CallProcedure.main(CallProcedure.java:36)
*/
当我们在给过程设置参数信息的时候,不能够同时使用下标和名称来指定对应参数的。
二、具体的Java代码实现
package org.viancent.call.procedure;
import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Types;
import com.sun.corba.se.spi.orbutil.fsm.Guard.Result;
import oracle.jdbc.OracleTypes;
/**
*
* @author PerfectPlans
* @date 2012-7-7
*
*/
@SuppressWarnings("unused")
public class CallProcedure {
private static Connection conn = null; // 数据库连接对象
private static CallableStatement cs = null;// 存储过程执行对象
private static ResultSet rs = null;// 结果集对象
//静态处理块
static {
try {
// 利用java反射技术获取对应驱动类
Class.forName("oracle.jdbc.driver.OracleDriver");
// 获取连接对象
conn = DriverManager.getConnection(
"jdbc:oracle:thin:@0.0.0.0:1521:orcl", "scott", "tiger");
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
/**
*
* @Discription 执行有参数,无返回值的存储过程
* @return void
* @param conn
* @throws Exception
*/
/* 对应的存储过程语句
--有参数无返回值
create or replace procedure updateName(byNo in number,useName in varchar2)
as
begin
update emp e set e.ename = useName where e.empno = byNo;
end;
*/
public void callProcedureY(Connection conn) throws Exception
{
//指定调用的存储过程
cs = conn.prepareCall("{call updateName(?,?)}");
cs.setInt(1, 7499);//设置存储过程对应的输入参数
cs.setString(2, "www");//对应下标从1 开始
//执行存储过程调用
cs.execute();
}
/**
*
* @Discription 执行无参数,无返回值的存储过程
* @return void
* @param conn
* @throws Exception
*/
/*对应的存储过程语句
--无参数
create or replace procedure insertLine
as
begin
insert into emp values(7333,'ALLEN','SAL',7698,to_date('2011/11/11','yyyy-MM-dd'),1600,300,30);
end;
*/
public void callProcedure(Connection conn) throws Exception
{
//指定调用的存储过程
cs = conn.prepareCall("{call insertLine}");
//执行存储过程的调用
cs.execute();
}
/**
*
* @Discription 执行有参数,有返回值的存储过程
* @return void
* @param conn
* @throws Exception
*/
/*对应的存储过程语句
--有参数,有返回值
create or replace procedure deleteLine(byNo in number,getCount out number)
as
begin
delete from emp e where e.empno = byNo;
select count(*) into getCount from emp e;
end;
*/
public void callProcedureYY(Connection conn) throws Exception
{
//指定调用的存储过程
cs = conn.prepareCall("{call deleteLine(?,?)}");
//设置参数
cs.setInt(1, 7839);
//这里需要配置OUT的参数新型
cs.registerOutParameter(2, OracleTypes.NUMBER);
//执行调用
cs.execute();
//输入返回值
System.out.println(cs.getString(2));
}
/**
*
* @Discription 执行有参数,返回集合的存储过程
* @return void
* @param conn
* @throws Exception
*/
/*对应的存储过程语句
--有参数返回一个列表,使用package
create or replace package someUtils
as
type cur_ref is ref cursor;
procedure selectRows(cur_ref out someUtils.cur_ref);
end someUtils;
create or replace package body someUtils
as
procedure selectRows(cur_ref out someUtils.cur_ref)
as
begin
open cur_ref for select * from emp e;
end selectRows;
end someUtils;
*/
public void callProcedureYYL(Connection conn) throws Exception
{
//执行调用的存储过程
cs = conn.prepareCall("{call someUtils.selectRows(?)}");
//设置返回参数
cs.registerOutParameter(1, OracleTypes.CURSOR);
//执行调用
cs.execute();
// 获取结果集 结果集是一个Object类型,需要进行强制转换 rs = (ResultSet)
rs = (ResultSet) cs.getObject(1);
//输出返回值
while(rs.next())
{
System.out.println(rs.getInt(1)+"\t"+rs.getString(2));
}
}
/**
*
* @Discription 执行有参数的函数
* @return void
* @param conn
* @throws Exception
*/
/*对应的存储过程语句
--创建函数,有参数
create or replace function useOther(byNo in number)
return String
as
returnValue char(10);
begin
select count(*) into returnValue from emp e where e.empno > byNo;
return returnValue;
end;
*/
public void callProcedureFY(Connection conn) throws Exception
{
//指定调用的函数
cs = conn.prepareCall("{? = call useOther(?)}");
//配置OUT参数信息
cs.registerOutParameter(1, OracleTypes.CHAR);
//配置输入参数
cs.setInt(2, 1111);
//执行过程调用
cs.execute();
//输入返回值
System.out.println(cs.getString(1));
}
/**
*
* @Discription 执行相应关闭操作
* @return void
* @param conn
* @param rs
*/
public void closeConn(Connection conn,ResultSet rs)
{
if (rs != null) {
try {
rs.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
if (conn != null) {
try {
conn.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
public static void main(String[] args) {
CallProcedure cp = new CallProcedure();
try {
//开启事务管理
conn.setAutoCommit(true);
cp.callProcedure(conn);
cp.callProcedureY(conn);
cp.callProcedureFY(conn);
cp.callProcedureYY(conn);
cp.callProcedureYYL(conn);
conn.commit();
} catch (Exception e) {
e.printStackTrace();
try {
conn.rollback();
} catch (Exception e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
// TODO: handle exception
}finally
{
cp.closeConn(conn, rs);
}
}
}
分享到:
相关推荐
在给出的“简单的存储过程.txt”文件中,可能包含了一个示例存储过程的定义和如何通过JDBC调用它的Java代码。例如,一个存储过程可能用于插入数据: ```sql CREATE OR REPLACE PROCEDURE insert_user ( p_username...
我们将首先编写 Oracle 存储过程,然后编写 Java 代码使用 Spring JdbcTemplate 调用这些存储过程。 Oracle 存储过程 首先,我们编写了两个 Oracle 存储过程:`P_EMP_SELECT` 和 `P_EMP_ADD`。 `P_EMP_SELECT` ...
在Java应用程序中调用Oracle数据库中的存储过程或函数是一项常见的任务。这不仅能够提高代码的执行效率,还可以有效地管理事务处理,确保数据的一致性和完整性。本文将详细介绍如何在Java环境中通过`...
选择合适的驱动程序、关闭自动提交、使用PreparedStatement对象、批量处理、调用存储过程以及优化连接池等策略,都是提高Java应用程序与Oracle数据库交互性能的有效手段。同时,定期对系统进行性能监控和调优,是...
在Java编程中,调用Oracle数据库的存储过程和函数是常见的任务,这通常涉及到JDBC(Java Database Connectivity)API的使用。以下将详细介绍这个过程,包括必要的步骤、使用的类和方法,以及可能遇到的问题和解决...
3. Java调用Oracle存储过程:Java程序可以通过JDBC来调用Oracle存储过程,获取结果集。 4. Type类型:Type类型是Oracle中的一种数据类型,用于定义复杂数据结构。 5. PACKAGE和PROCEDURE:PACKAGE和PROCEDURE是...
Java连接Oracle数据库主要依赖于两种方法:JDBC和SQLJ。这两种方法都是Oracle8i及其后续版本中为Java开发者提供的数据库交互方式。 JDBC(Java Database Connectivity)是一种标准的Java API,它允许Java应用程序...
### 通过JDBC连接Oracle数据库的十大技巧 #### 1. 使用Thin驱动程序 在Java客户端软件开发过程中,Oracle提供了多种驱动程序供开发者选择。其中,OCI(Oracle Call Interface)驱动程序通过Java本地接口(JNI)与...
针对Oracle数据库,JDBC提供了特殊的功能,如使用Oracle的CallableStatement执行PL/SQL存储过程。以下是一些示例代码: ```java // 加载Oracle驱动 Class.forName("oracle.jdbc.OracleDriver"); // 建立连接 ...
在Java编程中,与Oracle数据库交互是常见的任务之一,尤其是当需要执行复杂的SQL操作或存储过程时。本篇文章将深入探讨如何使用Java调用Oracle存储过程,并通过游标获取存储过程中返回的临时表数据。 首先,Oracle...
总结,通过Java调用Oracle存储过程,我们需要配置JDBC驱动,建立数据库连接,创建CallableStatement,设置参数,执行存储过程,并处理返回的结果。在这个例子中,我们展示了如何调用一个简单的存储过程并打印返回的...
Java 程序调用 Oracle 中的存储过程 在 Java 程序中调用 Oracle 中的存储过程是非常实用的技术, 它可以帮助开发者将业务逻辑封装在存储过程中,以提高应用程序的性能和安全性。下面将详细介绍如何使 Java 类调用 ...
在Java编程中,调用Oracle数据库的存储过程是常见的任务,尤其在处理复杂业务逻辑或高效数据操作时。本文将全面总结如何使用Java与Oracle存储过程进行交互。 首先,理解Oracle存储过程的基本概念。存储过程是预编译...
本篇将深入探讨如何使用JDBC来调用Oracle的存储过程并处理返回值。 首先,了解存储过程的概念。存储过程是预编译的SQL语句集合,它们存储在数据库服务器中,可以接受参数,执行一系列操作,并可能返回结果。在...
以上代码展示了如何在Java中调用Oracle数据库的三种类型的存储过程:无返回值的存储过程、有单个返回值的存储过程以及返回列表的存储过程。对于无返回值的存储过程,主要涉及的是参数的输入,通过`execute()`方法...
### Java通过JDBC连接Oracle数据库知识点详解 #### 一、JDBC简介 Java Database Connectivity (JDBC) 是一种用于执行 SQL 语句的 Java API,它可以为多种关系型数据库提供统一访问,它由一组用 Java 编程语言编写的...
对于存储过程的调用,则使用CallableStatement。 6. 数据库连接池: 在实际应用中,为了提高性能和资源利用率,通常会使用数据库连接池,如C3P0、Apache DBCP或HikariCP等,它们能管理和复用数据库连接,避免频繁...
本文将深入探讨如何使用JDBC(Java Database Connectivity)API来调用Oracle数据库的存储过程。 首先,确保你的项目中已经包含了Oracle JDBC驱动,通常为ojdbc.jar或ojdbc6.jar。这个驱动允许Java应用程序与Oracle...
在Java编程中,调用Oracle数据库的存储过程是常见的任务,尤其在处理复杂业务逻辑或大量数据时。本文将深入探讨如何使用Java来调用Oracle的存储过程,并提供相关源码示例。首先,我们需要了解Java与Oracle数据库交互...