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

52em37750r

以上是对于通用的存储过程返回的结果集的处理,而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 = 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,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));
　　}

　　总之,上面的方法虽然解决了Spring中对Oracle存储过程的调用,但我极力不推荐这程复杂的处理。