`
wuxiao_v
  • 浏览: 45464 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

Spring 调用ORACLE存储过程的结果集

阅读更多
oracle 对于高级特性总是与众不同(我极力讨厌这一点,如果使用它的产品就要对这种产品 
进行特定的编程,这也是我从不看好weblogic之类的平台的原因),大对象存取一要定用它自己 
的LOB对象,所幸我还能通过LONG RAW来代替.以便能使程序不需要特定的编码.但对于存储过程 
(我是说返回结果集的存储过程),我还没有什么方法能用一个通用的程序来处理ORACLE.太多的 
教材或文章在讲存储过程的调用只是不负责任地简单执行一些涵数或无结果返回的存储过程, 
使大多数读者根本不知道到底如何调用存储过程的结果集.而在Spring中,根本就没有真正完全 
地介绍对存储过程的结果集的处理,更别说象oracle这种"特别"的存储过程的结果集处理. 

先来简单看一下我们如何在JDBC中处理存储过程的结果集的通用流程: 

1.获取CallableStatement语句: 

CallableStatement cs = conn.prepareCall("{call spName(?,?,?)}"); 

2.传入输入参数和注册输出参数 

cs.setXXX(index,value);//输入参数 
cs.registerOutParameter(index,type);//输出参数 

3.执行存储过程: 

cs.execute(); 

对于一个存诸过程,如果返回的结果是我们预先知道的,那么可以根据存储过程定义的顺序来进行 
处理(事实上一般不会这样),但对于复杂的多结果集的处理,如何定义一个通用的流程? 

我们先看一下JDBC本身能为我们提供什么? 
一个存储过程执行后返回的是boolean型: 
boolean flag = callableStatement.execute(); 
如果flag为true,那么说明返回了一个结果集(ResultSet)类型,你可以用getResultSet()得到当前行所在 
的结果,而如果返回为flase,说明什么呢? 

如果你不进行处理,什么也不能说明,只能说明当前指针不是ResultSet,有可能是更新计数(updateCount) 
也可能什么也没有反因. 

那么如果当前指针为flase时如何处理?我们应该先getUpdateCount();如果返回-1,既不是结果集,又 
不是更新计数了.说明没的返回了.而如果getUpdateCount()返回0或大于0,则说明当前指针是更新计数( 
0的时候有可能是DDL指令).无论是返回结果集或是更新计数,那么则可能还继续有其它返回.只有在当前 
指指针getResultSet()==null && getUpdateCount() == -1才说明没有再多的返回. 

存储过程的返回和ResultSet类似,每次处理的返回结果相当于是ResultSet的Row,只不过存储过程的Row 
最先在第一行而不是象ResultSet要先next才到第一行,存储过程向下移动一行用getMoreResults(),相 
当于ResultSet的next().同样它返回boolean和上面的flag一样,只是说明当前行是不是ResultSet,如果是 
flase,你还是要判断是不是updateCount,在每一行,都要先同时判断是否为ResultSet还是UpdateCount,如 
果是其中一种则要继续getMoreResults(),当不是ResultSet也不是updateCount时,说明没有返回结果了, 
这时再获取输出参数. 

看明白了吗? 

那我们就根据上面的规则来写一个通用的流程吧: 

首先,我们要确定什么时候没说结果集了: 
if(cs.getResultSet() == null && cs.getUpdateCount() == -1) 
现在我们做一个循环: 
ResultSet rs = null; 
int updateCount = -1; 
flag = cs.execute(); 
do{ 
updateCount = cs.getUpdateCount(); 
if(updateCount != -1){//说明当前行是一个更新计数 
//处理. 
cs.getMoreResults(); 
continue;//已经是更新计数了,处理完成后应该移动到下一行 
//不再判断是否是ResultSet 

rs = cs.getResultSet(); 
if(rs != null){//如果到了这里,说明updateCount == -1 
//处理rs 
cs.getMoreResults(); 
continue; 
//是结果集,处理完成后应该移动到下一行 

//如果到了这里,说明updateCount == -1 && rs == null,什么也没的了 

}while(!(updateCount == -1 && rs == null)); 
cs.getXXX(int);//获取输出参数  


以上是对于通用的存储过程返回的结果集的处理,而oracle,它不能返回结果集,只能在输出参数中 
返回一个cursor,所以通用的流程中你获取不到任何结果: 
package PK_AREA_PUBLIC is  
TYPE serarch_result IS REF CURSOR;  
PROCEDURE area_search(vTarget_in IN VARCHAR2 ,cur_result_out OUT serarch_result) ; 
end PK_AREA_PUBLIC;  

package body PK_AREA_PUBLIC is  
PROCEDURE area_search(vTarget_in IN VARCHAR2 ,cur_result_out OUT serarch_result) 
IS  
sqlstr VARCHAR2(1000);  
BEGIN  
sqlstr:=’select .................................’;  
OPEN cur_result_out FOR sqlstr USING vTarget_in;  
END area_search;  
end PK_AREA_PUBLIC; 

对于上面的例子,存储过程有一个输入参数,一个输出参数,我们要接受输出参数作为结果集处理.所 
以注册的时候应该注册为: 

cs.registerOutParameter(2,oracle.jdbc.OracleTypes.CURSOR);//输出参数 

这样在存储过程执行后,获取输出数造型为ResultSet就可以处理: 

ResultSet rs = (ResultSet)cs.getObject(2); 

如果有多个结果集就用多个输出参数. 


明白了ORACLE的特殊性,我们再看看在spring中如果处理它的存储过程的结果集: 
spring在处理复杂对象的时候,大都采用回调的方法,要求程序员自己实现接口方法.也就是它提供了 
程序运行时的参数,要求你自己对这些参数进行处理.对于JdbcTemplate,它在很多地方提供了ResultSet 
参数供程序员处理.在Spring文档中提供了对于通用流程,也就是从存储过程执行结果中获取结果集的
例程: 

Map out = execute(new HashMap()); 
其实它是默认实现了上面JDBC通用流程中对ResuleSet到Map的封装.而对于Oracle,我们就必须自己手 
实现对输出参数中ResultSet的回调: 
public class SpringStoredProcedure  
extends StoredProcedure {  
public ArrayList<HashMap> set = new ArrayList<HashMap>();  
//声明一个用于接收结果集的数据结构,其中的元素为row,用map存放  

private Map inParam;//输入参数  
private RowMapper rm = new RowMapper(){  
public Object mapRow(ResultSet rs,int rowNum) throws SQLException{  
return null;//不用从存储过程本身获取结果  
}  
};  

private RowMapperResultReader callback = new RowMapperResultReader(rm ){  
public void processRow(ResultSet rs) //回调处理  
throws SQLException{  
int count = rs.getMetaData().getColumnCount();  
String[] header = new String[count];  
for(int i=0;i<count;i++)  
header[i] = rs.getMetaData().getColumnName(i+1);  
while(rs.next()){  
HashMap<String,String> row = new HashMap(count+7);  
for(int i=0;i<count;i++)  
row.put(header[i],rs.getString(i+1));  
set.add(row);  
}  
}  
}; //RowMapperResultReader作为输出参数的回调句柄  
public SpringStoredProcedure(DataSource ds, String SQL) {  
setDataSource(ds);  
setSql(SQL);  
}  

public void setOutParameter(String column,int type){  
declareParameter(new SqlOutParameter(column, type,callback));  
//利用回调句柄注册输出参数  
}  
public void setParameter(String column,int type){  
declareParameter(new SqlParameter(column, type));  
}  

public void SetInParam(Map inParam){  
this.inParam = inParam;  
}  

public Map execute() {  
compile();  
return execute(this.inParam);  
分享到:
评论

相关推荐

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

    使用 Spring JdbcTemplate 调用 Oracle 存储过程实现 CRUD 在本文中,我们将讨论如何使用 Spring JdbcTemplate 调用 Oracle 存储过程来实现 CRUD(Create、Read、Update、Delete)操作。我们将首先编写 Oracle 存储...

    使用Spring的JdbcTemplate调用Oracle的存储过程

    使用Spring的JdbcTemplate调用Oracle的存储过程

    springboot整合mybatis调用oracle存储过程

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

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

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

    Springboot调用Oracle存储过程的几种方式.docx

    在Spring Boot应用中,调用Oracle数据库的存储过程有多种方式。本文主要介绍三种方法,包括使用`entityManagerFactory.unwrap(SessionFactory.class).openSession()`、直接使用`EntityManager`的`...

    spring mybatis 调用oracle存储过程

    通过以上步骤,开发者可以在Spring和MyBatis环境中顺利地调用Oracle存储过程,实现复杂业务逻辑的处理。这不仅可以提高代码的可维护性,还能利用数据库的优势来优化性能。在进行这类操作时,一定要注意参数类型、...

    Spring boot调用Oracle存储过程的两种方式及完整代码

    Spring Boot 调用 Oracle 存储过程的两种方式及完整代码 在本文中,我们将为大家介绍 Spring Boot 调用 Oracle 存储过程的两种方式,并提供完整的代码示例。本文主要解决了在 Spring Boot 项目中调用 Oracle 存储...

    Spring访问传入数组参数的Oracle存储过程

    总的来说,理解如何在Spring中正确地调用Oracle存储过程并传递数组参数是提高应用程序效率和数据库操作灵活性的重要技能。这涉及到了数据库设计、Java编程、Spring框架的使用以及对Oracle特定特性的掌握。通过上述...

    java调用oracle存储过程

    Java调用Oracle存储过程是数据库操作中常见的任务,特别是在需要执行复杂业务逻辑或者批量处理数据时。本篇文章将详细介绍如何通过Java与Oracle数据库交互,调用存储过程,并提供几个简单的实例帮助新手理解。 首先...

    Mybatis传list参数调用oracle存储过程的解决方法

    "Mybatis调用Oracle存储过程传List参数解决方法" Mybatis是当前最流行的持久层框架之一,它提供了强大的数据访问和操作功能。但是,如何将List类型参数传递给Oracle存储过程,实现批量插入数据却是一个棘手的问题,...

    SSM+Oracle 存储过程例子

    本文将详细介绍如何在SSM项目中调用Oracle存储过程,这对于提升应用程序性能和简化复杂操作具有重要意义。 首先,让我们了解一下SSM框架。SSM是由Spring框架、SpringMVC和MyBatis三个组件组成的轻量级Java Web开发...

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

    执行Oracle存储过程主要涉及以下几个关键点: 1. 创建CallableStatement对象:使用Connection对象的`prepareCall()`方法创建CallableStatement实例,例如`CallableStatement cs = conn.prepareCall("{call procedure...

    spring-oracle-stored-proc:SpringBoot Oracle存储过程演示项目

    我们可以通过几种不同的方式调用Oracle存储过程。 使用 使用javax.persistence 。 我们在这种情况下使用了这种方法无论我们选择哪种方式,在使用spring-data时都应该设置一些关键方面/属性(尤其是当我们不让Spring...

    MyBatis调用存储过程

    如果存储过程返回结果集,我们需要在映射文件中定义`&lt;resultMap&gt;`,来描述如何将数据库结果映射到Java对象。每个`&lt;result&gt;`标签代表结果集中的一列,包括`column`(数据库列名)和`property`(Java对象属性名)。 `...

    oracle 触发器实时调用java 中http接口

    在Oracle数据库中,触发器是一种特殊类型的存储过程,它会在特定的数据库操作(如INSERT、UPDATE或DELETE)发生时自动执行。在这个场景中,我们关注的是一个特定的触发器,它在插入数据后被调用,并通过存储过程来...

    ibatis调用存储过程介绍

    在Java开发中,使用iBATIS(现在称为MyBatis)作为持久层框架时,调用数据库的存储过程是一种常见的需求。本文将详细介绍如何使用iBATIS调用存储过程,并提供一个简单的示例来说明其过程。 首先,我们需要在数据库...

Global site tag (gtag.js) - Google Analytics