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

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);//获取输出参数

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;

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);

}

}

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));

}