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

核心提示： 其实它是默认实现了上面JDBC通用流程中对ResuleSet到Map的封装，而对于Oracle,我们就必须自己动手实现对输出参数中ResultSet的回调:public class SpringStoredProcedureextends StoredProcedure {public A

其实它是默认实现了上面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);
}
}

下面我们看一下调用过程:

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存储过程的调用。