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>