- 浏览: 417976 次
- 性别:
- 来自: 广州
文章分类
最新评论
-
xiaomuxingren:
你好,请问update-alternatives --inst ...
JDK8安装及jenkins安装 -
wahahachuang8:
我觉得这种东西自己开发太麻烦了,就别自己捣鼓了,找个第三方,方 ...
HTML5 WebSocket -
晨曦的朝阳:
刚好有需求,学习一下!
MySql主从配置 -
mfkvfn:
这是恶意的商业竞争呀
解决 android 微信5.0及后续版本无法打开电话号码的问题 -
fwyhf:
require('./monitor/module_liste ...
NodeJS Server 进程自动重启
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 set = new ArrayList(); //声明一个用于接收结果集的数据结构,其中的元素为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 header[i] = rs.getMetaData().getColumnName(i+1); while(rs.next()){ HashMap row = new HashMap(count+7); for(int i=0;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); } }
下面我们看一下调用过程:
DriverManagerDataSource ds = .......;
SpringStoredProcedure sp = new SpringStoredProcedure(ds,"PK_AREA_PUBLIC.area_search");
//注册参数类型,输入参数和输出参数同时注册,否则不能正确编译存储过程
sp.setParameter("vTarget_in",java.sql.Types.VARCHAR);
sp.setOutParameter("cur_result_out",oracle.jdbc.OracleTypes.CURSOR);
sp.compile();
//传入输入参数值
Map in = new HashMap();
in.put("vTarget_in","一个内容");
sp.SetInParam(in);
//执行存储过程
sp.execute();
Map m = sp.set.get(0);//ReultSet的第一条记录
//set定义为SpringStoredProcedure的属性用于接收回调时的数据
//如果有多个输出参数,应该在每个输出参数的回调方法中生成该输出
//参数对应的ArrayList,然后加到一个成员变量的数据结构中.
Iterator i = m.keySet().iterator();
while(i.hasNext()){
String key = i.next().toString();
System.out.println(key + "=>" + m.get(key));
}
发表评论
-
MySql悲观锁和乐观锁的基础理解
2016-08-12 15:51 816mysql悲观锁和乐观锁的理解 1、悲观锁 悲观锁顾名思意, ... -
MySql主从配置
2016-06-15 16:18 830今天发现Mysql的主从数据库没有同步 先上Master库 ... -
Oracle常用命令
2010-12-25 11:24 1102本篇为oracle的一些常用命令的收集,对于玩命令的玩家是一件 ... -
Oracle学习集锦
2010-11-15 21:36 1324Oracle的基本语句 Oracle 数据库中的服务项: ... -
cmd命令提示行连接mysql乱码的解决
2010-06-09 20:31 3521下面的介绍是设置为gb2312的,而实际上很多 ... -
mysql alter 语句用法,添加、修改、删除字段等
2009-06-06 23:51 1067//主键 alter table tabelname ... -
ubuntu9.0.4 mysql乱码解决办法
2009-06-05 11:14 1334操作系统环境: ubuntu9.0.4、MySql5.1 ... -
SQL语句应用大全
2009-05-13 17:14 1902SQL与ACCESS、EXCEL的导入导出 ... -
SQL简单常用语句
2009-05-13 17:14 1073(1) 数据记录筛选: sql=&quo ... -
存储过程和用户自定义函数的区别
2009-05-13 17:13 1896存储过程 : 存储过程可以使得对数据 ... -
在SQL Server2000中处理半个汉字的问题
2009-05-13 17:13 1468问:由于从其它数据库中导入的数据存在半个汉字的问题,所以希望能 ... -
MySQL导入导出
2009-05-13 17:12 1120mysql -q -s -e "se ... -
mysql用户及权限管理
2009-05-13 17:11 2330首先要声明一下:一般情况下,修改 MySQL 密码,授权,是 ... -
mysql学习笔记
2009-05-13 17:11 9981.登录 MySQL(和PHP搭 ... -
mysql常用授权
2009-05-13 17:10 981GRANT 语句的语法如下: GRANT privi ... -
sql server 2000存储过程例子
2009-05-13 17:09 3187/****** Object: Stored Procedu ... -
sql通用存储过程
2009-05-13 17:09 1500建立一个 Web 应用,分页浏览功能必不可少。这个问题是数 ... -
mysql查看表结构命令
2009-05-13 17:08 9226mysql查看表结构命令,如下:--查看表结构信息(本人相看, ... -
limit动态参数问题
2009-05-13 17:07 1462先说两句体外话:好久没在CSDN的blog写东西了,一个原因是 ... -
mysql存储过程经典语句(非常的常用)
2009-05-13 17:07 1497存储过程: create procedure p() be ...
相关推荐
jdbc连接oracle,执行存储过程,带数据库存储过程,代码是详细的源码,读取配置文件,连接jdbc,执行存储过程。
JDBC调用oracle存储过程
Spring JdbcTemplate调用Oracle存储过程输出游标结果集实现增删改查
用JDBC操作Oracle的存储过程返回值
本例是我工作中的一些实操例子,亦是我工作日志,记录在此,既可作为我自己的总结,也可以此分享给同行借鉴。...2.创建oracle存储过程脚本 3.JDBC调用存储过程语句 4.创建Groovy脚本 5.xml入参示例 6.json出参示例
Java链接Oracle 存储过程 jdbc BLOG 例子 例子例子,步骤,详细
JDBC存储过程的调用
java调用oracle存储过程入门实例 增删改查 使用dom4j读取数据库的配置文件(xml) jdbc中connection的管理 使用threadlocal
OSWorkflow基于JDBC(oracle)存储实现的表结构OSWorkflow基于JDBC(oracle)存储实现的表结构
最简洁的代码,包含详细注释,全部测试通过,综合打包。 JDBC和ODBC连接Oracle数据库,连接txt/Access/Excel等文件,CallabelStatement存储过程调用等。
在如何在oracle数据库中建存储过程,以及如何在jdbc中调用存储过程,供初学者学习使用!
JDBC连接Oracle 11g及Mysql5,涉及传参,反射,读取属性文件,预处理,(预处理)批处理,带参数的存储过程,事务处理,可滚动的结果集,可更新的结果集
使用Oracle数据库实现了jdbc调用存储过程进行增加数据、删除数据、修改数据、查询全部数据、查询单个数据
针对java调用存储过程写的通用封装,oracle,mssql测试通过,附带测试脚本.以前写过一个,感觉不是很好,这个周末就重写了一个,大家多多提意见,是eclipse工程直接跑junit就行了,所有的东西都在里面.除了存储过程也可以...
NULL 博文链接:https://vernonchen163.iteye.com/blog/1902788
本文档演示如何从 Java 存储过程将 JDBC ResultSet 作为 REF CURSOR 返回。JDBC ResultSet 是一个表示数据库的数据表,通常通过执行查询数据库的语句产生该表。REF CURSOR 是 PL/SQL 中相应的类型。Java 存储过程的...
在Oracle数据库存储超大文件时、以流的方式分段读取和保存,避免内存溢出。本工具类提供两个方法: 1、读取文件保存到Oracle数据库Blob字段(支持超大文件) 2、从数据库中读出大字段到文件中(分块读取)
SQL PL/SQL 存储过程 游标 连接池 查询 函数
代码如下:import java.sql.CallableStatement;import java.sql.Connection;...public class TestPage { public TestPage() { } public static void main(String[] args) { String driver = “oracle.jdbc.driver