`
werwolf
  • 浏览: 93596 次
  • 性别: Icon_minigender_1
  • 来自: 广州
社区版块
存档分类
最新评论

JAVA调用ORACLE的存储过程、函数的返回结果集例子

OracleJavaJDBCSQLF# 
阅读更多

 --函数
create or replace function get_info(e_name varchar2,job in out varchar2) return varchar2 is
  Result varchar2(100);
begin
  select e_name||'-'||job into Result from dual;
  job := '1';
  return(Result);
end get_info;


--调用
DECLARE
  job   varchar2(20);
  dname varchar2(20);
BEGIN
  job := '2';
  dname := get_info('AA', job);
  dbms_output.put_line(dname);
  dbms_output.put_line(job);
END;

 

--（一）.建立一张测试表

--建立表:
CREATE TABLE STOCK_PRICES(
    RIC VARCHAR(6) PRIMARY KEY,
    PRICE NUMBER(7,2),
    UPDATED DATE );
/

--对表插入数据
INSERT INTO stock_prices
SELECT '1110',1.0,SYSDATE FROM DUAL;

INSERT INTO stock_prices
SELECT '1111',2.0,SYSDATE FROM DUAL;


INSERT INTO stock_prices
SELECT '1112',3.0,SYSDATE FROM DUAL;

INSERT INTO stock_prices
SELECT '1113',4.0,SYSDATE FROM DUAL;

--检查数据是否插入
SELECT * FROM stock_prices


--（二）.建立一个返回游标
CREATE OR REPLACE PACKAGE ZZH_TEST.PKG_PUB_UTILS IS
    --动态游标
    TYPE REFCURSOR IS REF CURSOR;
 
END PKG_PUB_UTILS;
/


--（三）.创建一个测试用的存储过程
CREATE OR REPLACE PROCEDURE ZZH_TEST.P_GET_PRICE(AN_O_RET_CODE         OUT NUMBER,
                                                 AC_O_RET_MSG          OUT VARCHAR2,
                                                 CUR_RET               OUT PKG_PUB_UTILS.REFCURSOR,
                                                 AN_I_PRICE IN NUMBER
                                                 ) IS
BEGIN
    AN_O_RET_CODE := 0;
    AC_O_RET_MSG  := '操作成功';
 
    OPEN CUR_RET FOR
        SELECT * FROM STOCK_PRICES WHERE PRICE<AN_I_PRICE;
EXCEPTION
    WHEN OTHERS THEN
        AN_O_RET_CODE := -1;
        AC_O_RET_MSG  := '错误代码:' || SQLCODE || CHR(13) || '错误信息:' || SQLERRM;
   
END P_GET_PRICE;


--（四）.创建一个测试用的函数:
CREATE OR REPLACE FUNCTION ZZH_TEST.F_GET_PRICE(v_price IN NUMBER)
    RETURN PKG_PUB_UTILS.REFCURSOR
AS
    stock_cursor PKG_PUB_UTILS.REFCURSOR;
BEGIN
    OPEN stock_cursor FOR
    SELECT ric,price,updated FROM stock_prices WHERE price < v_price;

    RETURN stock_cursor;
END;


--(五).开发JAVA调用存储过程返回结果集的例子：JDBCoracle10G_INVOKEPROCEDURE
--(六).开发JAVA调用函数返回结果集的例子：JDBCoracle10G_INVOKEFUNCTION


-----------------------------------------------------------------------------------------------------------------------------------

--=======================================================================

-----------------------------------------------------------------------------------------------------------------------------------

--2份JAVA源代码:

   -- (五).开发JAVA调用存储过程返回结果集的例子：JDBCoracle10G_INVOKEPROCEDURE

import java.sql.*;
import oracle.jdbc.OracleCallableStatement;
import oracle.jdbc.OracleTypes;
 /* 本例是通过调用oracle的存储过程来返回结果集:
  * oracle 9i、10G 的jdbc由1个jar包组成：classes12.zip
  */
 public class JDBCoracle10G_INVOKEPROCEDURE {
  Connection conn = null;
  Statement statement = null;
  ResultSet rs = null;
  CallableStatement stmt = null;
 
    
  String driver;
  String url;
  String user;
  String pwd;
  String sql;
  String  in_price ; 
  public  JDBCoracle10G_INVOKEPROCEDURE()
  {  
   driver = "oracle.jdbc.driver.OracleDriver";;
   url = "jdbc:oracle:thin:@10.168.1.193:1521:orcl";
   //oracle 用户
   user = "ZZH_TEST";
   //oracle 密码  
   pwd = "ZZH_TEST";

   init();

   //mysid：必须为要连接机器的sid名称，否则会包以下错：
   //     java.sql.SQLException: Io 异常: Connection refused(DESCRIPTION=(TMP=)(VSNNUM=169870080)(ERR=12505)(ERROR_STACK=(ERROR=(CODE=12505)(EMFI=4))))
   //参考连接方式:
   //   Class.forName( "oracle.jdbc.driver.OracleDriver" );
   //   cn = DriverManager.getConnection( "jdbc:oracle:thin:@MyDbComputerNameOrIP:1521:ORCL", sUsr, sPwd );  
  
  }
 
  public void init()
  {

   System.out.println("oracle jdbc test");
  
   try{
      Class.forName(driver);
      System.out.println("driver is ok");
     
      conn = DriverManager.getConnection(url,user,pwd);
      System.out.println("conection is ok");
     
      statement = conn.createStatement();
         // conn.setAutoCommit(false);
     
      //输入参数
       in_price="3.0";
      
       //调用函数
       stmt = conn.prepareCall( "call P_GET_PRICE(?,?,?,?)");
       stmt.registerOutParameter(1, java.sql.Types.FLOAT);
       stmt.registerOutParameter(2, java.sql.Types.CHAR);
       stmt.registerOutParameter(3, oracle.jdbc.OracleTypes.CURSOR);
       stmt.setString(4, in_price);
       stmt.executeUpdate();
       int retCode = stmt.getInt(1);
       String retMsg = stmt.getString(2);
       if (retCode == -1) { //如果出错时，返回错误信息
       System.out.println("报错！");
       } else {
       //取的结果集的方式一：
           rs = ((OracleCallableStatement)stmt).getCursor(3);
        //取的结果集的方式二：
             //  rs = (ResultSet) stmt.getObject(3);

        String ric ;
     String price ;
     String updated ;
        //对结果进行输出
     while(rs.next()){
      ric = rs.getString(1);
      price = rs.getString(2);
      updated = rs.getString(3);     
            
      System.out.println("ric:"+ric+";-- price:"+price+"; --"+updated+"; ");
     }
       }
           
    }
       catch(Exception e)
    {
     e.printStackTrace();
    }
          finally{
           System.out.println("close ");
       }      
  }
 
  public static void main(String args [])//自己替换［］
  {
   new JDBCoracle10G_INVOKEPROCEDURE();
  }
  }

--=======================================================================

--源代码：

--(六).开发JAVA调用函数返回结果集的例子：JDBCoracle10G_INVOKEFUNCTION

    import java.sql.*;
import oracle.jdbc.OracleCallableStatement;
import oracle.jdbc.OracleTypes;
 /*
 /* 本例是通过调用oracle的函数来返回结果集:
  * oracle 9i、10G 的jdbc由1个jar包组成：classes12.zip 
  */
 public class JDBCoracle10G_INVOKEFUNCTION {
  Connection conn = null;
  Statement statement = null;
  ResultSet rs = null;
  CallableStatement stmt = null;
      
  String driver;
  String url;
  String user;
  String pwd;
  String sql;
  String  in_price ; 
  public  JDBCoracle10G_INVOKEFUNCTION()
  {
   driver = "oracle.jdbc.driver.OracleDriver";;
   url = "jdbc:oracle:thin:@10.168.1.193:1521:orcl";
   //oracle 用户
   user = "ZZH_TEST";
   //oracle 密码  
   pwd = "ZZH_TEST";
  
   init();
  
   //mysid：必须为要连接机器的sid名称，否则会包以下错：
   //     java.sql.SQLException: Io 异常: Connection refused(DESCRIPTION=(TMP=)(VSNNUM=169870080)(ERR=12505)(ERROR_STACK=(ERROR=(CODE=12505)(EMFI=4))))
   //参考连接方式:
   //   Class.forName( "oracle.jdbc.driver.OracleDriver" );
   //   cn = DriverManager.getConnection( "jdbc:oracle:thin:@MyDbComputerNameOrIP:1521:ORCL", sUsr, sPwd );  
  }
 
  public void init()
  {
   System.out.println("oracle jdbc test");
  
   try{
      Class.forName(driver);
      System.out.println("driver is ok");
      
      conn = DriverManager.getConnection(url,user,pwd);
      System.out.println("conection is ok");
     
      statement = conn.createStatement();
       //conn.setAutoCommit(false);
     
      //输入参数     
       in_price="5.0";
      
       //调用函数
       stmt = conn.prepareCall("{? = call F_GET_PRICE(?)}");
      // stmt.registerOutParameter(1, java.sql.Types.FLOAT);
      // stmt.registerOutParameter(2, java.sql.Types.CHAR);
       stmt.registerOutParameter(1, oracle.jdbc.OracleTypes.CURSOR);
       stmt.setString(2, in_price);
       stmt.executeUpdate();
       //取的结果集的方式一：
            rs = ((OracleCallableStatement)stmt).getCursor(1);
       //取的结果集的方式二：
          //  rs = (ResultSet) stmt.getObject(1);
         String ric ;
     String price ;
     String updated ;

     while(rs.next()){
      ric = rs.getString(1);
      price = rs.getString(2);
      updated = rs.getString(3);                
         System.out.println("ric:"+ric+";-- price:"+price+"; --"+updated+"; ");
     }
   
    }
       catch(Exception e)
    {
     e.printStackTrace();
    }
          finally{
           System.out.println("close ");
       }      
  }
 
  public static void main(String args [])//自己替换［］
  {
   new JDBCoracle10G_INVOKEFUNCTION();
  }
  }


转载出处：http://blog.csdn.net/outget1/archive/2009/05/12/4171306.aspx

分享到：
| 人物
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    oracle的存储过程如何返回结果集

    ### Oracle存储过程返回结果集详解 #### 一、概述 在Oracle数据库中，存储过程是一种重要的编程组件，它能够执行一系列SQL语句并处理复杂的业务逻辑。存储过程的一个常见应用场景是返回结果集（Record Set），这有...

    Java调用Oracle的过程和函数

    ### Java调用Oracle的过程和函数 在现代软件开发过程中，Java与Oracle数据库的结合非常常见。为了更好地管理和处理数据，通常需要在Java程序中调用Oracle数据库中的存储过程或函数。本文将详细介绍如何通过Java来...

    java调用存储过程（含out参数）

    System.out.println("存储过程返回的OUT参数值：" + outValue); cs.close(); conn.close(); } catch (Exception e) { e.printStackTrace(); } } } ``` 在这个例子中，`my_procedure`是存储过程名，`123`是...

    CallableStatement调用Oracle存储过程返回结果集(ResultSet).docx

    总结，CallableStatement在Java中用于调用Oracle存储过程，无论是无返回值、有返回值还是返回结果集，都可以通过设置参数、注册`OUT`参数、处理结果集来实现。在实际开发中，注意数据库连接的管理以及异常的处理，...

    利用游标返回结果集的的例子（Oracle 存储过程）.doc

    在Java编程中，我们可以使用JDBC（Java Database Connectivity）来调用这些Oracle存储过程。在提供的Java代码示例中，我们首先加载Oracle的JDBC驱动，然后建立到数据库的连接。这里使用了`CallableStatement`来执行...

    java调用存储过程返回数组

    总结来说，Java调用存储过程并处理返回数组，需要理解存储过程的定义，正确使用`CallableStatement`或其子类如`OracleCallableStatement`，以及处理Oracle特定数据类型的方法。通过这些技巧，我们可以有效地在Java...

    hibernate 调用oracle函数

    4. **定义Hibernate Native SQL查询**：由于Hibernate默认不支持调用存储过程或函数，我们需要使用`@NamedNativeQuery`或`@SqlResultSetMapping`注解来定义一个原生SQL查询，用于调用Oracle函数。例如： ```java @...

    java调用存储过程

    #### 五、使用Java调用存储过程返回游标 最后，我们来看看如何使用Java调用返回游标的存储过程。以下是一个PostgreSQL存储过程`list_early_deaths`的例子，它返回一个游标，其中包含了所有在60岁之前去世的诗人列表...

    java 函数 存储过程

    例如，一个Java应用程序可能会调用数据库的存储过程来执行复杂的查询，然后在函数中处理返回的数据。这样做可以充分利用两者的优势：Java函数处理业务逻辑和数据解析，而存储过程专注于高效地处理数据库操作。 通过...

    java oracle数据库过程实现jsp分页

    以下是一个使用JDBC调用Oracle存储过程的示例： ```java CallableStatement cs = connection.prepareCall("{call page_pkg.get_paged_data(?,?,?)}"); cs.setInt(1, pageNum); // 设置页码 cs.setInt(2, pageSize);...

    oracle存储过程学习经典[语法+实例+调用

    Oracle存储过程可以包含SQL语句、PL/SQL块、Java语句，其最显著的优点是代码可复用性高，维护成本低。在Oracle数据库中，创建存储过程必须具备CREATE PROCEDURE系统权限，若存储过程可供其他schema的用户使用，还...

    java中存储过程的调用

    如果存储过程返回结果集，可以通过`CallableStatement`的`getResultSet`方法获取。此外，对于输出参数，可以使用`registerOutParameter`方法进行注册，并通过`getInt`、`getString`等方法获取其值。 #### 函数调用 ...

    java存储过程函数案例.ppt

    Java存储过程和函数是数据库操作中的重要组成部分，它们在Java应用程序与数据库交互时起到关键作用。存储过程是在数据库中预编译的SQL语句集合，而函数则返回一个值。这两种技术都允许开发者封装复杂的逻辑，提高...

    oracle 数据库 plsql 存储过程

    - **使用Java调用**：通过Java API可以调用Oracle存储过程。 - **无返回值的存储过程**：直接使用`CallableStatement`执行。 - **有返回值的存储过程**：使用`CallableStatement`的`registerOutParameter`方法注册...

    JAVA调用存储过程详解[定义].pdf

    Java调用存储过程是软件开发中常见的数据库操作技术，特别是在处理复杂业务逻辑和优化性能时。存储过程是预先编译并存储在数据库系统中的程序，可以在数据库服务器端直接执行，减少了网络通信的延迟，提高了效率。本...

    汉字转全拼或首字母Oracle存储过程

    "汉字转全拼或首字母Oracle存储过程"就是这样一个工具，它能够帮助我们高效地完成汉字到拼音的转化。 首先，我们需要了解汉字转全拼的基本原理。汉字的全拼是基于汉语拼音，每一个汉字都有对应的拼音表示。在计算机...

    Oracle对JSON处理函数Jar包

    在Oracle数据库中使用Java存储过程，可以调用这些类的方法来处理JSON数据。要使用JSONJar包，你需要将其加载到Oracle数据库的Java全局区域（Java Global Area, JGA）中，并确保数据库服务器有权访问和执行其中的类。...

    Oracle存储过程及调用

    Oracle存储过程是数据库管理系统中的一种重要特性，它允许开发者封装一系列的SQL语句和PL/SQL代码，以实现更复杂的业务逻辑。Oracle的存储过程有多种语法形式，根据不同的需求，可以创建没有参数、带有输入参数或者...

Magicbox
Global site tag (gtag.js) - Google Analytics