JDBC公共操作方法(四):【查询】、【增、删、改】和【调用存储过程】的公共方法 03
?
/** * @Title: callProcedure * @Description: 执行存储过程的公共方法 * @param sql * : 调用存储过程的语句 * @param params * : 条件 * @return * @author * @date 2011-12-29 */public String[] callProcedure(String sql, String[][] params) {String[] result = null;if (null == sql || "".equals(sql.trim())) {LOG.error("The sql is null, return.");return result;}// 获取数据库连接Connection connection = JDBCUtil.getInstance().getConnection();if (null == connection) {LOG.error("The database connction is null, return.");return result;}CallableStatement cs = null;int len = params == null ? 0 : params.length;int[] index = new int[len];try {cs = connection.prepareCall(sql);int position = 0;// 设置入参/出参for (int i = 0; i < len; i++) {if ("IN".equalsIgnoreCase(params[i][0])) {cs.setString(i + 1, params[i][1]);} else if ("OUT".equalsIgnoreCase(params[i][0])) {cs.registerOutParameter(i + 1,Integer.valueOf(params[i][1]));index[position] = i + 1;position++;}}cs.execute();result = new String[position];// 处理返回值for (int i = 0; i < index.length; i++) {if (0 != index[i]) {result[i] = String.valueOf(cs.getObject(index[i]));}}} catch (SQLException e) {LOG.error("JDBCCore:=>callProcedure : SQLException!", e);} catch (Exception e) {LOG.error("JDBCCore:=>callProcedure : Exception!", e);} finally {JDBCUtil.close(connection, null, cs);}return result;}}