`

java调用oracle存储过程返回多条记录(结果集)

阅读更多

游标,类型,嵌套表,存储包,存储过程

 

--定义TYPE
CREATE OR REPLACE TYPE OrderAttrType AS OBJECT (
    CharacterId               VARCHAR2(60),
    CharacterName             VARCHAR2(60),
    CharacterValue            VARCHAR2(4000),
    CharacteValueName         VARCHAR2(4000),
    OldCharacterValue         VARCHAR2(4000),
    OldCharacteValueName      VARCHAR2(4000)
);

--定义嵌套表
CREATE OR REPLACE TYPE OrderAttrTypeTable IS TABLE OF OrderAttrType;

--定义包
CREATE OR REPLACE PACKAGE HN_PKG_RES IS
    --声明游标映射
    TYPE refcorsor IS REF CURSOR;
    --声明存储过程
    PROCEDURE makeOrderAttrs(p_orderId IN OM_ORDER.ID%TYPE, p_orderAttrList OUT refcorsor);
END HN_PKG_RES;

--实现包体
CREATE OR REPLACE PACKAGE BODY HN_PKG_RES IS
    PROCEDURE makeOrderAttrs(p_orderId IN OM_ORDER.ID%TYPE, p_orderAttrList OUT refcorsor)
    IS
        v_orderAttrList  OrderAttrTypeTable;
        CURSOR c1 IS
            SELECT PPC.CODE            CharacterId,
               PPC.NAME                CharacterName,
               OPR.CHARACTER_VALUE     CharacterValue,
               OPR.CHARACTER_NAME      CharacteValueName,
               OPR.OLD_CHARACTER_VALUE OldCharacterValue,
               OPR.OLD_CHARACTER_NAME  OldCharacteValueName
          FROM OM_GROUP_ORDER_RELA OGR
          JOIN OM_GROUP_ORDER_RELA OGR2 ON OGR.GROUP_SERVICE_ORDER_ID =
                                           OGR2.GROUP_SERVICE_ORDER_ID
          JOIN OM_SERVICE_ORDER OSO ON OSO.ID = OGR.SERVICE_ORDER_ID
          JOIN OM_SERVICE_ORDER OSO2 ON OSO2.ID = OGR2.SERVICE_ORDER_ID
          JOIN OM_INDEP_PROD_ORDER_ATTR OPR ON OSO2.ID = OPR.SERVICE_ORDER_ID
          JOIN PM_PRODUCT_CHARACTER PPC ON OPR.CHARACTER_ID = PPC.ID
         WHERE OGR.SERVICE_ORDER_ID = p_orderId
           AND OGR2.SERVICE_ORDER_ID <> p_orderId
           AND OGR2.MAIN_FLAG = '1'
           AND OSO.INDEP_PROD_ID = 100000
           AND OSO2.INDEP_PROD_ID = 102017
           --AND PPC.CODE = '16275'
           ; --1014501
    BEGIN
        v_orderAttrList := OrderAttrTypeTable();--初始化嵌套表
        --OPEN c1;
        --FETCH c1 BULK COLLECT INTO v_orderAttrList;
        v_orderAttrList.extend;
        v_orderAttrList(v_orderAttrList.count) := OrderAttrType('1','2','3','4','5','6');
        FOR i IN c1 LOOP
            v_orderAttrList.extend;
            v_orderAttrList(v_orderAttrList.count) := OrderAttrType(i.CharacterId,i.CharacterName,
                 i.CharacterValue,i.CharacteValueName,i.OldCharacterValue,i.OldCharacteValueName);
        END LOOP;
        -- 把嵌套表进行类型转换为table
        -- 打开游标并关联查询
        OPEN p_orderAttrList FOR SELECT * FROM TABLE( CAST( v_orderAttrList AS OrderAttrTypeTable ) );
    END;
END HN_PKG_RES;

 

Java代码:  
  

public void callPrTest() {   
     Long orderId = new Long(6019214);
        Connection conn = null;   
        ResultSet rs = null;   
        CallableStatement cs = null;   
        try {   
            conn = this.getConnection();   
            cs = conn.prepareCall("{ call HN_PKG_RES.makeOrderAttrs(?,?) } ");
            cs.setLong(1, orderId.longValue());
            //注册输出类型
       cs.registerOutParameter(2, oracle.jdbc.OracleTypes.CURSOR);   
            cs.execute();
            ResultSet rsResult = (ResultSet) cs.getObject(2);   
            while (rsResult.next()) {   
              System.out.println(new StringBuffer().append(rsResult.getString("CharacterId"))
               .append("\t").append(rsResult.getString("CharacterName"))
               .append("\t").append(rsResult.getString("CharacterValue"))
               .append("\t").append(rsResult.getString("CharacteValueName"))
               .append("\t").append(rsResult.getString("OldCharacterValue"))
               .append("\t").append(rsResult.getString("OldCharacteValueName"))
               );  
            } 
        } catch (SQLException e) {   
            e.printStackTrace();   
        } finally {   
         cleanUp(conn, null, null, rs);
        }   
    }  

 


输出:
1 2 3 4 5 6
10000 计费类型 c 付费 null null
10001 付费方式 2 后付费 null null
20000 销售品 2124 总机服务  null null
16005 产品密码 123123 123123 null null
16275 集团短号长度 4 4 null null
16277 话务员轮询方案 1627701 轮寻 null null
16292 集团类型 1629201 省级 null null

分享到:
评论

相关推荐

    JAVA调用存储过程

    当存储过程返回一个或多个记录集时,需要使用`getResultSet`方法来获取结果集。 1. **建立连接和创建`CallableStatement`**:同上一步骤。 2. **执行存储过程**:使用`execute`方法执行存储过程。 3. **获取结果...

    Java链接Oracle 存储过程 jdbc BLOG

    Oracle的存储过程可以包含多条SQL语句,能够返回复杂的数据结构,如游标(Cursor)、记录集等。在Java中,这些可以通过注册`OUT`参数为`java.sql.ResultSet`类型来处理。 总的来说,Java通过JDBC API调用Oracle存储...

    java中调用oracle

    此外,如果存储过程返回多条记录,可以使用`ResultSet`来处理结果集。同时,注意关闭所有打开的资源,以避免内存泄漏和资源浪费。 在处理Oracle特有的数据类型时,如CLOB、BLOB、NCLOB等,可能需要使用特定的API。...

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

    在Java中调用Oracle存储过程可以通过JDBC API来完成。在调用时,可以根据存储过程是否有返回值来进行区分处理。无返回值的存储过程只需要执行execute命令,而有返回值的存储过程则需要使用CallableStatement对象,并...

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

    #### 四、用Java调用Oracle存储过程 **1. 无返回值的存储过程** - **调用示例**: ```java Connection conn = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:orcl", "scott", "tiger"); ...

    oracle的一个简单存储过程实例

    `说明.txt`文件提供了对这些存储过程的使用指南,可能包括如何通过SQL*Plus或应用程序接口(如Java的JDBC)调用它们,以及如何传递参数、处理返回结果等。在实际应用中,理解这些步骤至关重要,因为它们帮助确保正确...

    Java调用存储过程.doc

    Java调用存储过程是数据库操作中的常见需求,特别是在需要高效执行多条SQL语句或封装复杂业务逻辑时。存储过程是预编译的数据库代码片段,可在数据库服务器上执行,减少了网络通信次数,提升了系统性能。Java通过...

    java调用存储过程实现批量入库.pdf

    在Java中,可以使用JDBC(Java Database Connectivity)API来调用Oracle存储过程。首先,需要加载Oracle的JDBC驱动,并建立数据库连接。然后,创建一个预编译的`CallableStatement`(在本例中是`PreparedStatement`...

    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存储过程学习经典

    - **返回列表**:如果存储过程返回一个结果集,可以使用REF CURSOR类型作为OUT参数,Java中同样使用CallableStatement处理。 在存储过程中实现动态SQL是一种常见的需求,主要分为本地动态SQL和远程动态SQL。本地...

    JDBC与Oracle存储过程

    调用Oracle存储过程通常使用`CallableStatement`。步骤如下: 1. **准备CallableStatement**:通过`Connection.prepareCall()`创建CallableStatement,传入调用存储过程的SQL格式字符串,如`{call package_name....

    Oracle存储过程.pdf

    3. 减轻网络流量:如果某一操作涉及的SQL语句被组织成存储过程,那么客户端只需调用该存储过程,网络中传递的只是调用语句,而不是多条SQL语句,从而减少了网络流量,降低了网络负载。 4. 安全机制的实现:系统管理...

    java中存储过程的使用

    本文通过示例详细介绍了如何在Java中使用Oracle存储过程。首先,我们创建了一个简单的`BOOK`表以及多个不同功能的存储过程。接着,在Java程序中通过`CallableStatement`对象调用了这些存储过程,包括无返回值的存储...

    java调用存储过程实现批量入库.docx

    通过这种方式,Java程序创建一个包含100个元素的二维数组,每个元素代表一条要插入的数据,然后将其转换为Oracle数组类型,并传递给存储过程执行批量插入。 调用存储过程的好处在于,它减少了与数据库的交互次数,...

    java操作Oracle数据库——ARRAY、TABLE类型批量入库

    这两种类型在处理大量数据时尤其有用,因为它们允许一次性提交多条记录,而不是一条一条地执行插入操作。 要使用Java操作Oracle的ARRAY和TABLE类型,我们需要以下步骤: 1. **驱动和连接**:确保你的项目已经引入...

    Hibernate3调用存储过程用法

    如果返回多条记录,可以使用list方法获取结果集。例如: ```java query.addScalar("returnColumn", Hibernate.INTEGER); List&lt;Integer&gt; result = query.list(); ``` 4. **调用存储过程** 执行SQLQuery对象的...

    java操作Oracle

    通过调用`addBatch()`和`executeBatch()`,你可以一次性处理多条SQL,极大地减少了网络往返和数据库处理时间。 总结起来,优化Java操作Oracle数据库的关键在于选择合适的驱动、精细控制事务、根据场景选择`...

    Oracle 官方 JDBC Demo JAVA

    Oracle JDBC驱动程序还提供了Oracle数据库特有的功能,如PL/SQL存储过程调用、游标操作、BLOB/CLOB类型处理等。`samples`中可能包含这些高级特性的使用示例。 8. **日志和安全性**: `ojdbc.policy`文件可能涉及...

Global site tag (gtag.js) - Google Analytics