首页 诗词 字典 板报 句子 名言 友答 励志 学校 网站地图
当前位置: 首页 > 教程频道 > 数据库 > SQL Server >

java 调用通用存储过程(Sqlserver) oracle以后补下

2013-03-26 
java 调用通用存储过程(Sqlserver) oracle以后补上我这个是将调用存储过程的方式进行统一封装,将调用存储

java 调用通用存储过程(Sqlserver) oracle以后补上

我这个是将调用存储过程的方式进行统一封装,将调用存储过程的方法统一起来调用。

package com.wfy.system.dao;import java.sql.CallableStatement;import java.sql.Connection;import java.sql.ResultSet;import java.sql.SQLException;import java.sql.Types;import java.text.DateFormat;import java.text.SimpleDateFormat;import java.util.ArrayList;import java.util.HashMap;import java.util.List;import java.util.Map;import org.springframework.dao.DataAccessException;import org.springframework.jdbc.core.ConnectionCallback;import org.springframework.jdbc.core.JdbcTemplate;import com.wfy.util.JDOM;/*** * 存储过程通过此类调用* * @author 金鑫* */public class DynamicDataProcedureExecuteDAO {private Map getSqlServerData(JdbcTemplate jdbcTemplate, final List<?> procedureList){   Map returnMap = (Map) jdbcTemplate.execute(new ConnectionCallback(){    public Map doInConnection(Connection conn) throws SQLException,      DataAccessException {     /**     * 由于sqlserver跟oracle 的调用方式有所不同,所以需要分开调用,但是我对oracle存储过程不熟悉,所以没有写,以后会补上的。     * 我的通用方式是将传入数据进行封装,再将传出数据封装为map返回给用户     *      * List.get(0) 中存放的是 存储过程的名称     *      * 从list.get(1)开始存放的是相应参数,参数以map类型存放     *      * map.put("name","")//传入传出的参数名字     * map.put("value","")//传入的参数值,传出为null     * map.put("type","input/output/outtable");//传入 传出 输出的结果集     * map.put("dataType",type);//传入传出的数据类型。     *      * 返回的时候将type类型为output的封装为map返回前台。     *      * */         //生成存储过程调用字符串     String callStr = "{call ";     callStr += procedureList.get(0).toString()+"(";     for (int i = 1; i < procedureList.size(); i++) {      if(!((Map)procedureList.get(i)).get("type").toString().equals("outtable"))      callStr += "?,";     }     if(procedureList.size()>1){      callStr = callStr.substring(0,callStr.length()-1);     }     callStr += ")}";         System.out.println("callStr:"+callStr);         CallableStatement cstmt = conn.prepareCall(callStr);         for (int j = 1; j < procedureList.size(); j++) {      Map<String, String> map = (Map<String, String>)procedureList.get(j);      if(map.get("type").equals("input")){       //说明此函数是传入函数       if(map.get("dataType").toUpperCase().equals("STRING")){        cstmt.setString(j, map.get("value"));       }else if(map.get("dataType").toUpperCase().equals("INT")){        try {         cstmt.setInt(j, Integer.parseInt(map.get("value").toString()));         } catch (Exception e) {         throw new SQLException(map.get("value") + " INT 数据类型转换错误");        }       }else if(map.get("dataType").toUpperCase().equals("DECIMAL")){        try {         cstmt.setDouble(j, Double.parseDouble(map.get("value").toString()));        } catch (Exception e) {         throw new SQLException(map.get("value") + " DECIMAL 数据类型转换错误");        }       }else if(map.get("dataType").toUpperCase().equals("DATE")){        try{         DateFormat formatter1= new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");         cstmt.setDate(j, new java.sql.Date(formatter1.parse(map.get("value").toString()).getTime()));        }catch(Exception e1){         try{          DateFormat formatter2= new SimpleDateFormat("yyyy-MM-dd");          cstmt.setDate(j, new java.sql.Date(formatter2.parse(map.get("value").toString()).getTime()));         }catch(Exception e2){          throw new SQLException(map.get("value") + " DATE 数据类型转换错误");         }        }       }      }else if(map.get("type").equals("output")){       //说明此函数是返回函数       if(map.get("dataType").toUpperCase().equals("STRING")){        cstmt.registerOutParameter(j, Types.CHAR);       }else if(map.get("dataType").toUpperCase().equals("INT")){        cstmt.registerOutParameter(j, Types.INTEGER);       }else if(map.get("dataType").toUpperCase().equals("DECIMAL")){        cstmt.registerOutParameter(j, Types.DECIMAL);       }else if(map.get("dataType").toUpperCase().equals("DATE")){        cstmt.registerOutParameter(j, Types.DATE);       }      }     }     //返回的map     Map<String, Object> returnMap = new HashMap<String, Object>();     cstmt.execute();         int k = 1;     while(cstmt.getMoreResults()){      ResultSet rs = cstmt.getResultSet();      List ls = new ArrayList();      while(rs.next()){       Map vc = new HashMap();       for(int i=1;i<rs.getMetaData().getColumnCount()+1;i++){        vc.put(rs.getMetaData().getColumnName(i), rs.getObject(i));       }       ls.add(vc);      }      for (; k < procedureList.size(); k++) {       Map mp = (Map)procedureList.get(k);       if(mp.get("type").equals("outtable")){        returnMap.put(mp.get("name").toString(), ls);        k++;        break;       }      }     }         for (int j = 1; j < procedureList.size(); j++) {      Map<String, String> map = (Map<String, String>)procedureList.get(j);      if(map.get("type").equals("output")){       //说明此函数是返回函数       if(map.get("dataType").toUpperCase().equals("STRING")){        returnMap.put(map.get("name").toString(), cstmt.getString(j));       }else if(map.get("dataType").toUpperCase().equals("INT")){        returnMap.put(map.get("name").toString(), cstmt.getInt(j));       }else if(map.get("dataType").toUpperCase().equals("DECIMAL")){        returnMap.put(map.get("name").toString(), cstmt.getDouble(j));       }else if(map.get("dataType").toUpperCase().equals("DATE")){        returnMap.put(map.get("name").toString(), cstmt.getDate(j));       }      }     }         cstmt.close();         return returnMap;    }   });   return returnMap;}}

?


我的异常网推荐解决方案:oracle存储过程,http://www.myexception.cn/oracle-develop/177537.html

热点排行