`

Java jdbc调用Oracle数据库存储过程

阅读更多

http://perfectplan.iteye.com/blog/1582331

 

Java jdbc调用Oracle数据库存储过程

 

 一、了解CallableStatement接口

1.callablestatement接口提供了两种调用形式

{?= call <procedure-name>[(<arg1>,<arg2>, ...)]}  //包含结果参数的调用形式   如:函数(funciton)
{call <procedure-name>[(<arg1>,<arg2>, ...)]}  //不包含结果参数的调用形式     如:存储过程(procedure)

 

2.callablestatement接口提供的方法

Java代码  收藏代码
  1. void registerOutParameter(int parameterIndex, int sqlType)  
  2.         throws SQLException; //在调用存储过程的时候设置输出参数的类型,用于接收输出结果  

   registerOutParameter接口中有四个该方法的重载实现,具体的可以查看源码了解

    

Java代码  收藏代码
  1. setXXX(int parameterIndex,XXX x) //主要用于设置过程调用时候需要的输入参数信息  其中XXX代表对应类型  
Java代码  收藏代码
  1. getXXX(int x) //主要用于获取过程调用后返回的参数的信息  

 

3.callablestatement接口产生的异常提示

如下源码:

Java代码  收藏代码
  1. /* 
  2.  * @exception SQLFeatureNotSupportedException if <code>sqlType</code> is 
  3.  * a <code>ARRAY</code>, <code>BLOB</code>, <code>CLOB</code>,  
  4.  * <code>DATALINK</code>, <code>JAVA_OBJECT</code>, <code>NCHAR</code>,  
  5.  * <code>NCLOB</code>, <code>NVARCHAR</code>, <code>LONGNVARCHAR</code>, 
  6.  *  <code>REF</code>, <code>ROWID</code>, <code>SQLXML</code> 
  7.  * or  <code>STRUCT</code> data type and the JDBC driver does not support 
  8.  * this data type 
  9.  * @see Types  
  10.  */  
  11. void registerOutParameter(int parameterIndex, int sqlType)  
  12. ows SQLException;  

   当我们使用registerOutParameter方法设置输出参数类型的时候,需要注意对于某一些类型是不能够

        进行设置的如上中所以提到的类型都会引发SQLFeatureNotSupportedException异常,对于能够支持

        的类型可以查看java.sql.Types和oracle.jdbc.OracleTypes

 

如下源码:

Java代码  收藏代码
  1. /* 
  2.  * java.sql.SQLException: 不允许的操作: Ordinal binding and Named binding cannot be 
  3.  * combined! at 
  4.  * oracle.jdbc.driver.DatabaseError.throwSqlException(DatabaseError.java:112) at 
  5.  * oracle.jdbc.driver.DatabaseError.throwSqlException(DatabaseError.java:146) at 
  6.  * oracle 
  7.  * .jdbc.driver.OracleCallableStatement.execute(OracleCallableStatement.java 
  8.  * :4219) at 
  9.  * org.viancent.call.procedure.CallProcedure.main(CallProcedure.java:36) 
  10.  */  

  当我们在给过程设置参数信息的时候,不能够同时使用下标和名称来指定对应参数的。

二、具体的Java代码实现

Java代码  收藏代码
  1. package org.viancent.call.procedure;  
  2.   
  3. import java.sql.CallableStatement;  
  4. import java.sql.Connection;  
  5. import java.sql.DriverManager;  
  6. import java.sql.ResultSet;  
  7. import java.sql.SQLException;  
  8. import java.sql.Types;  
  9. import com.sun.corba.se.spi.orbutil.fsm.Guard.Result;  
  10. import oracle.jdbc.OracleTypes;  
  11.   
  12. /** 
  13.  *  
  14.  * @author PerfectPlans 
  15.  * @date 2012-7-7 
  16.  *  
  17.  */  
  18. @SuppressWarnings("unused")  
  19. public class CallProcedure {  
  20.     private static Connection conn = null// 数据库连接对象  
  21.     private static CallableStatement cs = null;// 存储过程执行对象  
  22.     private static ResultSet rs = null;// 结果集对象  
  23.     //静态处理块  
  24.     static {  
  25.         try {  
  26.             // 利用java反射技术获取对应驱动类  
  27.             Class.forName("oracle.jdbc.driver.OracleDriver");  
  28.             // 获取连接对象  
  29.             conn = DriverManager.getConnection(  
  30.                     "jdbc:oracle:thin:@0.0.0.0:1521:orcl""scott""tiger");  
  31.         } catch (Exception e) {  
  32.             // TODO Auto-generated catch block  
  33.             e.printStackTrace();  
  34.         }  
  35.     }  
  36.   
  37.     /** 
  38.      *  
  39.      *  @Discription 执行有参数,无返回值的存储过程 
  40.      *  @return         void 
  41.      *  @param conn 
  42.      *  @throws Exception 
  43.      */  
  44.     /* 对应的存储过程语句 
  45.     --有参数无返回值 
  46.     create or replace procedure updateName(byNo in number,useName in varchar2) 
  47.     as 
  48.     begin 
  49.            update emp e set e.ename = useName where e.empno = byNo; 
  50.     end; 
  51.     */  
  52.     public void callProcedureY(Connection conn) throws Exception  
  53.     {  
  54.         //指定调用的存储过程  
  55.         cs = conn.prepareCall("{call updateName(?,?)}");  
  56.         cs.setInt(17499);//设置存储过程对应的输入参数  
  57.         cs.setString(2"www");//对应下标从1 开始  
  58.         //执行存储过程调用  
  59.         cs.execute();  
  60.     }  
  61.   
  62.     /** 
  63.      *  
  64.      *  @Discription 执行无参数,无返回值的存储过程 
  65.      *  @return         void 
  66.      *  @param conn 
  67.      * @throws Exception  
  68.      */  
  69.     /*对应的存储过程语句 
  70.     --无参数 
  71.     create or replace procedure insertLine 
  72.     as 
  73.     begin 
  74.           insert into emp values(7333,'ALLEN','SAL',7698,to_date('2011/11/11','yyyy-MM-dd'),1600,300,30); 
  75.     end; 
  76.     */  
  77.     public void callProcedure(Connection conn) throws Exception  
  78.     {  
  79.         //指定调用的存储过程  
  80.         cs = conn.prepareCall("{call insertLine}");  
  81.         //执行存储过程的调用  
  82.         cs.execute();  
  83.     }  
  84.       
  85.     /** 
  86.      *  
  87.      *  @Discription 执行有参数,有返回值的存储过程 
  88.      *  @return         void 
  89.      *  @param conn 
  90.      * @throws Exception  
  91.      */  
  92.     /*对应的存储过程语句 
  93.      --有参数,有返回值 
  94.     create or replace procedure deleteLine(byNo in number,getCount out number) 
  95.     as 
  96.     begin 
  97.            delete from emp e where e.empno = byNo; 
  98.            select count(*) into getCount from emp e; 
  99.     end; 
  100.      */  
  101.     public void callProcedureYY(Connection conn) throws Exception  
  102.     {  
  103.         //指定调用的存储过程  
  104.         cs = conn.prepareCall("{call deleteLine(?,?)}");  
  105.         //设置参数  
  106.         cs.setInt(17839);  
  107.         //这里需要配置OUT的参数新型  
  108.         cs.registerOutParameter(2, OracleTypes.NUMBER);  
  109.         //执行调用  
  110.         cs.execute();  
  111.         //输入返回值  
  112.         System.out.println(cs.getString(2));  
  113.     }  
  114.       
  115.     /** 
  116.      *  
  117.      *  @Discription 执行有参数,返回集合的存储过程 
  118.      *  @return         void 
  119.      *  @param conn 
  120.      * @throws Exception  
  121.      */  
  122.     /*对应的存储过程语句 
  123.      --有参数返回一个列表,使用package 
  124.         create or replace package someUtils 
  125.         as 
  126.                type cur_ref is ref cursor; 
  127.                procedure selectRows(cur_ref out someUtils.cur_ref); 
  128.           end someUtils; 
  129.            
  130.         create or replace package body someUtils 
  131.         as  
  132.                procedure selectRows(cur_ref out someUtils.cur_ref) 
  133.                  as 
  134.                    begin 
  135.                          open cur_ref for select * from emp e; 
  136.                    end selectRows; 
  137.         end someUtils; 
  138.      */  
  139.     public void callProcedureYYL(Connection conn) throws Exception  
  140.     {  
  141.         //执行调用的存储过程  
  142.         cs = conn.prepareCall("{call someUtils.selectRows(?)}");  
  143.         //设置返回参数  
  144.         cs.registerOutParameter(1, OracleTypes.CURSOR);  
  145.         //执行调用  
  146.         cs.execute();  
  147.         // 获取结果集 结果集是一个Object类型,需要进行强制转换 rs = (ResultSet)  
  148.         rs = (ResultSet) cs.getObject(1);  
  149.         //输出返回值  
  150.         while(rs.next())  
  151.         {  
  152.             System.out.println(rs.getInt(1)+"\t"+rs.getString(2));  
  153.         }  
  154.     }  
  155.       
  156.     /** 
  157.      *  
  158.      *  @Discription 执行有参数的函数 
  159.      *  @return         void 
  160.      *  @param conn 
  161.      *  @throws Exception  
  162.      */  
  163.     /*对应的存储过程语句 
  164.      --创建函数,有参数 
  165.     create or replace function useOther(byNo in number) 
  166.     return String 
  167.     as  
  168.         returnValue char(10); 
  169.            begin 
  170.               select count(*) into returnValue from emp e where e.empno > byNo; 
  171.               return returnValue; 
  172.            end; 
  173.      */  
  174.     public void callProcedureFY(Connection conn) throws Exception  
  175.     {  
  176.         //指定调用的函数  
  177.         cs = conn.prepareCall("{? = call useOther(?)}");  
  178.         //配置OUT参数信息  
  179.         cs.registerOutParameter(1, OracleTypes.CHAR);  
  180.         //配置输入参数  
  181.         cs.setInt(21111);  
  182.         //执行过程调用  
  183.         cs.execute();  
  184.         //输入返回值  
  185.         System.out.println(cs.getString(1));  
  186.     }  
  187.       
  188.     /** 
  189.      *  
  190.      *  @Discription 执行相应关闭操作 
  191.      *  @return         void 
  192.      *  @param conn 
  193.      *  @param rs 
  194.      */  
  195.     public void closeConn(Connection conn,ResultSet rs)  
  196.     {  
  197.         if (rs != null) {  
  198.             try {  
  199.                 rs.close();  
  200.             } catch (SQLException e) {  
  201.                 // TODO Auto-generated catch block  
  202.                 e.printStackTrace();  
  203.             }  
  204.         }  
  205.         if (conn != null) {  
  206.             try {  
  207.                 conn.close();  
  208.             } catch (SQLException e) {  
  209.                 // TODO Auto-generated catch block  
  210.                 e.printStackTrace();  
  211.             }  
  212.         }  
  213.     }  
  214.       
  215.       
  216.     public static void main(String[] args) {  
  217.         CallProcedure cp = new CallProcedure();  
  218.         try {  
  219.             //开启事务管理  
  220.             conn.setAutoCommit(true);  
  221.             cp.callProcedure(conn);  
  222.             cp.callProcedureY(conn);  
  223.             cp.callProcedureFY(conn);  
  224.             cp.callProcedureYY(conn);  
  225.             cp.callProcedureYYL(conn);  
  226.             conn.commit();  
  227.         } catch (Exception e) {  
  228.             e.printStackTrace();  
  229.             try {  
  230.                 conn.rollback();  
  231.             } catch (Exception e1) {  
  232.                 // TODO Auto-generated catch block  
  233.                 e1.printStackTrace();  
  234.             }  
  235.             // TODO: handle exception  
  236.         }finally  
  237.         {  
  238.             cp.closeConn(conn, rs);  
  239.         }  
  240.     }  
  241. }  
 

 

 
分享到:
评论

相关推荐

    jdbc连接oracle,执行存储过程,带数据库存储过程

    在给出的“简单的存储过程.txt”文件中,可能包含了一个示例存储过程的定义和如何通过JDBC调用它的Java代码。例如,一个存储过程可能用于插入数据: ```sql CREATE OR REPLACE PROCEDURE insert_user ( p_username...

    Spring JdbcTemplate调用Oracle存储过程实现CRUD

    我们将首先编写 Oracle 存储过程,然后编写 Java 代码使用 Spring JdbcTemplate 调用这些存储过程。 Oracle 存储过程 首先,我们编写了两个 Oracle 存储过程:`P_EMP_SELECT` 和 `P_EMP_ADD`。 `P_EMP_SELECT` ...

    java中调用oracle的存储过程和函数

    在Java应用程序中调用Oracle数据库中的存储过程或函数是一项常见的任务。这不仅能够提高代码的执行效率,还可以有效地管理事务处理,确保数据的一致性和完整性。本文将详细介绍如何在Java环境中通过`...

    通过JDBC连接Oracle数据库的十大技巧

    选择合适的驱动程序、关闭自动提交、使用PreparedStatement对象、批量处理、调用存储过程以及优化连接池等策略,都是提高Java应用程序与Oracle数据库交互性能的有效手段。同时,定期对系统进行性能监控和调优,是...

    java调用oracle存储过程或者函数

    在Java编程中,调用Oracle数据库的存储过程和函数是常见的任务,这通常涉及到JDBC(Java Database Connectivity)API的使用。以下将详细介绍这个过程,包括必要的步骤、使用的类和方法,以及可能遇到的问题和解决...

    java调用oracle存储过程返回结果集,Record,cursor参照.pdf

    3. Java调用Oracle存储过程:Java程序可以通过JDBC来调用Oracle存储过程,获取结果集。 4. Type类型:Type类型是Oracle中的一种数据类型,用于定义复杂数据结构。 5. PACKAGE和PROCEDURE:PACKAGE和PROCEDURE是...

    Java连接Oracle数据库的各种方法

    Java连接Oracle数据库主要依赖于两种方法:JDBC和SQLJ。这两种方法都是Oracle8i及其后续版本中为Java开发者提供的数据库交互方式。 JDBC(Java Database Connectivity)是一种标准的Java API,它允许Java应用程序...

    通过JDBC连接oracle数据库的十大技巧

    ### 通过JDBC连接Oracle数据库的十大技巧 #### 1. 使用Thin驱动程序 在Java客户端软件开发过程中,Oracle提供了多种驱动程序供开发者选择。其中,OCI(Oracle Call Interface)驱动程序通过Java本地接口(JNI)与...

    JDBC实现Oracle数据库的增删改查

    针对Oracle数据库,JDBC提供了特殊的功能,如使用Oracle的CallableStatement执行PL/SQL存储过程。以下是一些示例代码: ```java // 加载Oracle驱动 Class.forName("oracle.jdbc.OracleDriver"); // 建立连接 ...

    java调用Oracle存储过程的代码

    总结,通过Java调用Oracle存储过程,我们需要配置JDBC驱动,建立数据库连接,创建CallableStatement,设置参数,执行存储过程,并处理返回的结果。在这个例子中,我们展示了如何调用一个简单的存储过程并打印返回的...

    Java程序如何调用Oracle中的存储过程

    Java 程序调用 Oracle 中的存储过程 在 Java 程序中调用 Oracle 中的存储过程是非常实用的技术, 它可以帮助开发者将业务逻辑封装在存储过程中,以提高应用程序的性能和安全性。下面将详细介绍如何使 Java 类调用 ...

    Java调用oracle存储过程总结

    在Java编程中,调用Oracle数据库的存储过程是常见的任务,尤其在处理复杂业务逻辑或高效数据操作时。本文将全面总结如何使用Java与Oracle存储过程进行交互。 首先,理解Oracle存储过程的基本概念。存储过程是预编译...

    用JDBC操作Oracle的存储过程返回值

    本篇将深入探讨如何使用JDBC来调用Oracle的存储过程并处理返回值。 首先,了解存储过程的概念。存储过程是预编译的SQL语句集合,它们存储在数据库服务器中,可以接受参数,执行一系列操作,并可能返回结果。在...

    用java调用oracle存储过程

    以上代码展示了如何在Java中调用Oracle数据库的三种类型的存储过程:无返回值的存储过程、有单个返回值的存储过程以及返回列表的存储过程。对于无返回值的存储过程,主要涉及的是参数的输入,通过`execute()`方法...

    java通过jdbc连接oracle数据库.docx

    ### Java通过JDBC连接Oracle数据库知识点详解 #### 一、JDBC简介 Java Database Connectivity (JDBC) 是一种用于执行 SQL 语句的 Java API,它可以为多种关系型数据库提供统一访问,它由一组用 Java 编程语言编写的...

    【技术篇】JDBC连接ORACLE数据库之方法.docx

    对于存储过程的调用,则使用CallableStatement。 6. 数据库连接池: 在实际应用中,为了提高性能和资源利用率,通常会使用数据库连接池,如C3P0、Apache DBCP或HikariCP等,它们能管理和复用数据库连接,避免频繁...

    Java链接Oracle 存储过程 jdbc BLOG

    本文将深入探讨如何使用JDBC(Java Database Connectivity)API来调用Oracle数据库的存储过程。 首先,确保你的项目中已经包含了Oracle JDBC驱动,通常为ojdbc.jar或ojdbc6.jar。这个驱动允许Java应用程序与Oracle...

    java中调用oracle的存储过程

    在Java编程中,调用Oracle数据库的存储过程是常见的任务,尤其在处理复杂业务逻辑或大量数据时。本文将深入探讨如何使用Java来调用Oracle的存储过程,并提供相关源码示例。首先,我们需要了解Java与Oracle数据库交互...

    Java连接Oracle数据库驱动包(JDBC)

    Java连接Oracle数据库的过程中,JDBC(Java Database Connectivity)扮演了至关重要的角色。JDBC是Java平台的一个标准API,它允许Java程序与各种数据库进行交互,包括Oracle。在本压缩包中,提供了Java连接Oracle...

Global site tag (gtag.js) - Google Analytics