`
liubin2010
  • 浏览: 309040 次
  • 性别: Icon_minigender_1
  • 来自: 西安
社区版块
存档分类
最新评论

Java程序中调用Oracle存储过程

阅读更多
一:无返回值的存储过程

存储过程为:

CREATE   OR   REPLACE   PROCEDURE   TESTA(PARA1   IN   VARCHAR2,PARA2   IN   VARCHAR2)     AS

BEGIN 

      INSERT   INTO   HYQ.B_ID   (I_ID,I_NAME)   VALUES   (PARA1,   PARA2);

END   TESTA;

然后呢,在java里调用时就用下面的代码:

view plaincopy to clipboardprint?

    package   com.hyq.src;  
     
         
     
    import   java.sql.*;  
     
    import   java.sql.ResultSet;  
     
         
     
    public   class   TestProcedureOne   {  
     
          public   TestProcedureOne()   {  
     
          }  
     
          public   static   void   main(String[]   args   ){  
     
                String   driver   =    "oracle.jdbc.driver.OracleDriver ";  
     
                String   strUrl   =    "jdbc:oracle:thin:@127.0.0.1:1521:   hyq    ";  
     
                Statement   stmt   =   null;  
     
                ResultSet   rs   =   null;  
     
                Connection   conn   =   null;  
     
                CallableStatement   cstmt   =   null;  
     
         
     
                try   {  
     
                      Class.forName(driver);  
     
                      conn   =      DriverManager.getConnection(strUrl,    "   hyq    ",    "   hyq    ");  
     
                      CallableStatement   proc   =   null;  
     
                      proc   =   conn.prepareCall( "{   call   HYQ.TESTA(?,?)   } ");  
     
                      proc.setString(1,    "100 ");  
     
                      proc.setString(2,    "TestOne ");  
     
                      proc.execute();  
     
                }  
     
                catch   (SQLException   ex2)   {  
     
                      ex2.printStackTrace();  
     
                }  
     
                catch   (Exception   ex2)   {  
     
                      ex2.printStackTrace();  
     
                }  
     
                finally{  
     
                      try   {  
     
                            if(rs   !=   null){  
     
                                  rs.close();  
     
                                  if(stmt!=null){  
     
                                        stmt.close();  
     
                                  }  
     
                                  if(conn!=null){  
     
                                        conn.close();  
     
                                  }  
     
                            }  
     
                      }  
     
                      catch   (SQLException   ex1)   {  
     
                      }  
     
                }  
     
          }  
     
    }  
     
    当然了,这就先要求要建张表TESTTB,里面两个字段(I_ID,I_NAME)。  
     
    二:有返回值的存储过程(非列表)  
     
    存储过程为:  
     
    CREATE   OR   REPLACE   PROCEDURE   TESTB(PARA1   IN   VARCHAR2,PARA2   OUT   VARCHAR2)      AS  
     
    BEGIN     
     
             SELECT   INTO   PARA2   FROM   TESTTB   WHERE   I_ID=   PARA1;     
     
    END   TESTB; 



在java里调用时就用下面的代码:

view plaincopy to clipboardprint?

    package   com.hyq.src;  
     
         
     
    public   class   TestProcedureTWO   {  
     
          public   TestProcedureTWO()   {  
     
          }  
     
          public   static   void   main(String[]   args   ){  
     
                String   driver   =    "oracle.jdbc.driver.OracleDriver ";  
     
                String   strUrl   =    "jdbc:oracle:thin:@127.0.0.1:1521:hyq ";  
     
                Statement   stmt   =   null;  
     
                ResultSet   rs   =   null;  
     
                Connection   conn   =   null;  
     
                try   {  
     
                      Class.forName(driver);  
     
                      conn   =      DriverManager.getConnection(strUrl,    "   hyq    ",    "   hyq    ");  
     
                      CallableStatement   proc   =   null;  
     
                      proc   =   conn.prepareCall( "{   call   HYQ.TESTB(?,?)   } ");  
     
                      proc.setString(1,    "100 ");  
     
                      proc.registerOutParameter(2,   Types.VARCHAR);  
     
                      proc.execute();  
     
                      String   testPrint   =   proc.getString(2);  
     
                      System.out.println( "=testPrint=is= "+testPrint);  
     
                }  
     
                catch   (SQLException   ex2)   {  
     
                      ex2.printStackTrace();  
     
                }  
     
                catch   (Exception   ex2)   {  
     
                      ex2.printStackTrace();  
     
                }  
     
                finally{  
     
                      try   {  
     
                            if(rs   !=   null){  
     
                                  rs.close();  
     
                                  if(stmt!=null){  
     
                                        stmt.close();  
     
                                  }  
     
                                  if(conn!=null){  
     
                                        conn.close();  
     
                                  }  
     
                            }  
     
                      }  
     
                      catch   (SQLException   ex1)   {  
     
                      }  
     
                }  
     
          }  
     
    }  
     
         
     
    }  



注意,这里的proc.getString(2)中的数值2并非任意的,而是和存储过程中的out列对应的,如果out是在第一个位置,那就是proc.getString(1),如果是第三个位置,就是proc.getString(3),当然也可以同时有多个返回值,那就是再多加几个out参数了。

三:返回列表

由于oracle存储过程没有返回值,它的所有返回值都是通过out参数来替代的,列表同样也不例外,但由于是集合,所以不能用一般的参数,必须要用pagkage了.所以要分两部分,

1,     建一个程序包。如下:

CREATE   OR   REPLACE   PACKAGE   TESTPACKAGE     AS

  TYPE   Test_CURSOR   IS   REF   CURSOR;

end   TESTPACKAGE;

2,建立存储过程,存储过程为:

CREATE   OR   REPLACE   PROCEDURE   TESTC(p_CURSOR   out   TESTPACKAGE.Test_CURSOR)   IS 

BEGIN

        OPEN   p_CURSOR   FOR   SELECT   *   FROM   HYQ.TESTTB;

END   TESTC;

可以看到,它是把游标(可以理解为一个指针),作为一个out   参数来返回值的。

在java里调用时就用下面的代码:

view plaincopy to clipboardprint?

    package   com.hyq.src;  
     
    import   java.sql.*;  
     
    import   java.io.OutputStream;  
     
    import   java.io.Writer;  
     
    import   java.sql.PreparedStatement;  
     
    import   java.sql.ResultSet;  
     
    import   oracle.jdbc.driver.*;  
     
         
     
         
     
    public   class   TestProcedureTHREE   {  
     
          public   TestProcedureTHREE()   {  
     
          }  
     
          public   static   void   main(String[]   args   ){  
     
                String   driver   =    "oracle.jdbc.driver.OracleDriver ";  
     
                String   strUrl   =    "jdbc:oracle:thin:@127.0.0.1:1521:hyq ";  
     
                Statement   stmt   =   null;  
     
                ResultSet   rs   =   null;  
     
                Connection   conn   =   null;  
     
         
     
                try   {  
     
                      Class.forName(driver);  
     
                      conn   =      DriverManager.getConnection(strUrl,    "hyq ",    "hyq ");  
     
         
     
                      CallableStatement   proc   =   null;  
     
                      proc   =   conn.prepareCall( "{   call   hyq.testc(?)   } ");  
     
                      proc.registerOutParameter(1,oracle.jdbc.OracleTypes.CURSOR);  
     
                      proc.execute();  
     
                      rs   =   (ResultSet)proc.getObject(1);  
     
         
     
                      while(rs.next())  
     
                      {  
     
                                  System.out.println( " <tr>  <td>  "   +   rs.getString(1)   +    " </td>  <td>  "+rs.getString(2)+ " </td>  </tr>  ");  
     
                      }  
     
                }  
     
                catch   (SQLException   ex2)   {  
     
                      ex2.printStackTrace();  
     
                }  
     
                catch   (Exception   ex2)   {  
     
                      ex2.printStackTrace();  
     
                }  
     
                finally{  
     
                      try   {  
     
                            if(rs   !=   null){  
     
                                  rs.close();  
     
                                  if(stmt!=null){  
     
                                        stmt.close();  
     
                                  }  
     
                                  if(conn!=null){  
     
                                        conn.close();  
     
                                  }  
     
                            }  
     
                      }  
     
                      catch   (SQLException   ex1)   {  
     
                      }  
     
                }  
     
          }  
     
    } 



在这里要注意,在执行前一定要先把oracle的驱动包放到class路径里,否则会报错的。
2-----------------------------------------
hibernate3 调用oracle存储过程的方法
原创  hibernate3 调用oracle存储过程的方法 收藏

配置文件:

<hibernate-mapping>
    <class name="vo.SshPost" table="ssh_post" >
     <!-- <cache usage="read-write"/>-->
        <id name="postId" type="java.lang.String">
            <column name="post_id" />
            <generator class="native" />
        </id>
      
        <property name="postName" type="java.lang.String">
            <column name="post_name" length="20" />
        </property>
        <property name="postNo" type="java.lang.String">
            <column name="post_no" length="20" />
        </property>
        <filter name="myfilter" condition=":myfilterParam = post_name"/>
     
    </class>

<sql-query callable="true" name="selectAllUsers">
<return class="vo.SshPost">
     <return-property name="postId" column="POST_ID"/>
     <return-property name="postName" column="POST_NAME"/>
     <return-property name="postNo" column="POST_NO"/>
</return>
{ call P_TEST(?,:VPOSTNO) }
     </sql-query>


</hibernate-mapping> 

存储过程:

CREATE OR REPLACE PACKAGE TESTPACKAGE  AS

TYPE Test_CURSOR IS REF CURSOR;

end TESTPACKAGE;

CREATE OR REPLACE PROCEDURE P_TEST(P_CURSOR OUT TESTPACKAGE.TEST_CURSOR,
                                   VPOSTNO  IN VARCHAR2) IS

BEGIN
  OPEN P_CURSOR FOR
    SELECT * FROM SSH_POST WHERE POST_NO = VPOSTNO;

END P_TEST;

如果不用PACKAGE  则可以使用

CREATE OR REPLACE PROCEDURE P_TEST(P_CURSOR OUT SYS_REFCURSOR,
                                   VPOSTNO  IN VARCHAR2) IS

程序调用:

Session session = sessionFactory.openSession();
  Query query = session.getNamedQuery("selectAllUsers");
  List list = query.setParameter("VPOSTNO", "99")

.list();
  System.out.println(list.size());

但是有个很郁闷的问题就是:

当 { call P_TEST(?,:VPOSTNO) } 改为 { call P_TEST(?,?) } 时

程序使用query.setParameter(1, "99")

系统居然报错:

java.lang.ArrayStoreException
at java.lang.System.arraycopy(Native Method)
at java.util.Arrays.copyOf(Unknown Source)
at java.util.ArrayList.toArray(Unknown Source)
at org.hibernate.util.ArrayHelper.toTypeArray(ArrayHelper.java:75)
at org.hibernate.impl.AbstractQueryImpl.typeArray(AbstractQueryImpl.java:831)
at org.hibernate.impl.AbstractQueryImpl.getQueryParameters(AbstractQueryImpl.java:839)
at org.hibernate.impl.SQLQueryImpl.getQueryParameters(SQLQueryImpl.java:194)
at org.hibernate.impl.SQLQueryImpl.list(SQLQueryImpl.java:152)

奇怪的hibernate
3---------------
JDBC(或Hibernate)调用Oracle存储过程
1、存储过程

包头:

create or replace package uwf.TOOLS is

  -- Author  : lwq
  -- Created : 2008-3-18 lwq 11:59:35
  -- Purpose :
  -- Public type declarations
  function PROCESSDEFINITIONS_OF_USER(userID in long)return SYS_REFCURSOR;
end TOOLS;

包体:

create or replace package body uwf.TOOLS as
function PROCESSDEFINITIONS_OF_USER(userID in long)
return SYS_REFCURSOR
as
definitions_ SYS_REFCURSOR;
begin
      OPEN definitions_ FOR
      select ID_,NAME_
      from uwf.jbpm_processdefinition;
      return definitions_;
end PROCESSDEFINITIONS_OF_USER;
end TOOLS;

2、JDBC调用存储过程

try {
  Connection conn =XXXXX.connection();
  CallableStatement cstmt = conn.prepareCall("{?= call uwf.TOOLS.PROCESSDEFINITIONS_OF_USER(?)}");
  cstmt.setLong(2, userID);
  cstmt.registerOutParameter(1,oracle.jdbc.OracleTypes.CURSOR);
  cstmt.execute();
     ResultSet rs = (ResultSet)cstmt.getObject(1);
       while(rs.next()){
         System.out.println("id : " + rs.getLong("ID_"));
         System.out.println("name : " + rs.getString("NAME_"));
       }// end while
  } catch (SQLException sqlException) {
   sqlException.printStackTrace();
  }

3、Hibernate调用存储过程

  List retList=null;
  Query query= XXXXXX.getSession().getNamedQuery("getProcessDefinitionsByUser");
  query.setLong(0, userID);
  retList = query.list();

  Iterator it =retList.iterator();
  while(it.hasNext())
  {
   Object[] pdObject = (Object[])it.next();
   //流程定义主键
   Long pdId=((BigDecimal)pdObject[0]).longValue();
   //流程定义名字
   String pdName=pdObject[1].toString();
    。。。。。。。。
  }

在hbm文件里要配置

  <sql-query name="getProcessDefinitionsByUser" callable="true">
   {?=call uwf.TOOLS.PROCESSDEFINITIONS_OF_USER(?)}
  </sql-query>
分享到:
评论

相关推荐

    JAVA调用ORACLE存储过程通用类

    ### JAVA调用ORACLE存储过程通用类 #### 概述 在Java开发中,经常会遇到需要与数据库交互的情况,特别是当涉及到复杂的业务逻辑时,利用数据库的存储过程可以有效地提高程序性能并简化代码结构。本篇文章将详细...

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

    Java调用Oracle存储过程返回结果集(Record)是指在Java程序中通过调用Oracle存储过程来获取记录集的结果。下面将详细介绍相关知识点。 创建Type 在Oracle中,需要创建两个Type类型:`myScalarType`和`myTableType...

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

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

    Java调用oracle存储过程通过游标返回临时表

    本篇文章将深入探讨如何使用Java调用Oracle存储过程,并通过游标获取存储过程中返回的临时表数据。 首先,Oracle存储过程是一种在数据库端执行的预编译SQL语句和PL/SQL代码集合。它可以接收参数、执行业务逻辑并...

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

    以上就是Java调用Oracle存储过程或函数的主要知识点,实践中要根据具体情况进行适当的调整和优化。在处理过程中,参考Oracle的JDBC文档和官方示例,以及Java API文档,将有助于理解和解决问题。

    ibatis调用oracle存储过程分页

    ibatis调用oracle存储过程分页

    springboot mybatis 动态调用oracle存储过程,通过存储过程名称,就能动态调用存储过程、java动态调用or

    能不能写个动态的业务,只输入存储过程名称,自动获取存储过程参数,并且参数的数据从前台传递过来...只根据输入不同的存储过程名称、参数内容,自动调用不同的存储过程。 已经使用在多个项目中 全开源项目 请放心下载

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

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

    java调用Oracle存储过程的代码

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

    hibernate query调用oracle存储过程

    以下是一个简单的示例,展示了如何调用一个不带参数的Oracle存储过程: ```java Session session = sessionFactory.openSession(); Transaction transaction = session.beginTransaction(); session....

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

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

    JAVA调用ORACLE存储过程小结[文].pdf

    Java调用Oracle存储过程是数据库操作中的常见任务,特别是在企业级应用开发中。本文将对这一主题进行深入探讨,以帮助开发者理解如何有效地在Java中调用Oracle存储过程。 首先,我们来看一个无返回值的存储过程的...

    用java调用oracle存储过程

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

    springboot整合mybatis调用oracle存储过程

    本文将深入探讨如何在Spring Boot项目中整合MyBatis,实现调用Oracle存储过程并处理游标返回的数据。 首先,我们需要在Spring Boot项目中引入相关的依赖。在`pom.xml`文件中添加Oracle JDBC驱动(ojdbc66-oracle...

    Java调用Oracle存储过程

    本文主要探讨如何在Java中调用Oracle存储过程,以及如何通过Java创建Oracle存储过程。 首先,我们来看如何在Java中调用不带输出参数的Oracle存储过程。在给定的例子中,有一个名为`pro1`的存储过程,它接受一个整数...

    Java调用oracle存储过程总结

    通过这些步骤,你可以成功地从Java应用程序中调用Oracle存储过程。确保正确配置JDBC驱动,理解存储过程的参数类型,并熟悉JDBC API,这样就能高效地实现数据交互了。在开发过程中,可以参考Oracle的官方文档以及各种...

    JAVA调用ORACLE存储过程

    ### JAVA调用ORACLE存储过程知识点详解 #### 一、背景与概述 在现代软件开发过程中,集成多种技术栈是常态。特别是在企业级应用中,Java 和 Oracle 数据库的组合非常常见。通过 Java 调用 Oracle 存储过程不仅能够...

    java调用oracle存储过程入门实例 增删改查

    在这个入门实例中,我们将重点探讨如何通过Java调用Oracle的存储过程来实现这些基本操作,并结合使用DOM4J解析XML配置文件来管理数据库连接。 首先,存储过程是Oracle数据库中预编译的SQL语句集合,它可以封装复杂...

    java调用Oracle存储过程

    在Java编程中,调用Oracle数据库的存储过程是常见的任务,尤其在处理复杂业务逻辑或数据操作时。本文将深入探讨如何使用Java与...记住,实践是最好的老师,尝试编写一个简单的Java程序来调用Oracle存储过程,加深理解。

Global site tag (gtag.js) - Google Analytics