Spring JdbcTemplate 调用存储过程

遇到调用存储过程的业务，以前有用过,但不是用Spring的 JdbcTemplate去做的，这次是在一个已经有的SpringMVC框架的项目下写处理存储过程的。

参考网络中的方法，在实际操作中遇到两个问题：

1 存储过程的参数问题，原本以为只要传对应的入参就可以，即每个入参占用一个？，在报错后检查发现，出参也要占用一个？；

2连接数据库，这个是开始没有注意，但很快就发现了。

完成这个存储过程调用的代码

int param2Value = (Integer ) jdbcTemplate.execute(new CallableStatementCreator()
        {
            public CallableStatement createCallableStatement(Connection con) throws SQLException
            {
                String storedProc = sql;// 调用的sql
                CallableStatement cs = con.prepareCall(storedProc);
                cs.setString(1, obj[0] + "");
                cs.setInt(2, Integer.parseInt(obj[1] + ""));
                cs.setString(3, obj[2] + "");
                cs.setString(4, obj[3] + "");
                cs.setString(5, obj[4] + "");
                cs.setInt(6, Integer.parseInt(obj[5] + ""));
                cs.setLong(7, Long.parseLong(obj[6] + "") );
                // 注册输出参数的类型
                cs.registerOutParameter(8, OracleTypes.NUMBER);
                return cs;
            }
        }, new CallableStatementCallback()
        {
            public Object doInCallableStatement(CallableStatement cs) throws SQLException, DataAccessException
            {
                cs.execute();
                return cs.getInt(8);// 获取输出参数的值
            }
        });
      return param2Value;
      }
      catch (Exception e)
      {
          e.printStackTrace();
          return -1;
      }

trycatch 非必须的。

其中 jdbcTemplate要设置其获取oracle数据库的连接，也就是读取配置。

private JdbcTemplate jdbcTemplate;

    /**
     * 设置数据源
     * @param dataSource       数据源对象
     * @return void             无返回对象
     * @author 邹建松 2014-07-14
     */
    @Resource(name="baseDataSource")
    public void setJdbcTemplate(DataSource dataSource) {
        this.jdbcTemplate = new JdbcTemplate(dataSource);
    }

baseDataSource 是配置文件xml里的

以上是有返回参数，即是有出参数的。

没有出参的如下

public void test(){
        try
        {
            this.jdbcTemplate.execute("call p_create_student_test('123')");
        }
        catch (Exception e)
        {
            e.printStackTrace();
        }

          }

还有一种情况就是有结果集的，这种我还没有用过，参考网络的

public void test() {
List resultList = (List) jdbcTemplate.execute(
new CallableStatementCreator() {
public CallableStatement createCallableStatement(Connection con) throws SQLException {
String storedProc = "{call sp_list_table(?,?)}";// 调用的sql
CallableStatement cs = con.prepareCall(storedProc);
cs.setString(1, "p1");// 设置输入参数的值
cs.registerOutParameter(2, OracleTypes.CURSOR);// 注册输出参数的类型
return cs;
}
}, new CallableStatementCallback() {
public Object doInCallableStatement(CallableStatement cs) throws SQLException,DataAccessException {
List resultsMap = new ArrayList();
cs.execute();
ResultSet rs = (ResultSet) cs.getObject(2);// 获取游标一行的值
while (rs.next()) {// 转换每行的返回值到Map中
Map rowMap = new HashMap();
rowMap.put("id", rs.getString("id"));
rowMap.put("name", rs.getString("name"));
resultsMap.add(rowMap);
}
rs.close();
return resultsMap;
}
});
for (int i = 0; i < resultList.size(); i++) {
Map rowMap = (Map) resultList.get(i);
String id = rowMap.get("id").toString();
String name = rowMap.get("name").toString();
System.out.println("id=" + id + ";name=" + name);
}
}

还有就是用别的方法调用存储过程，如

public void updateStudentIncludeType(User bean) {
       Connection con = getConnection();
       CallableStatement csmt = null;
       Student student = (Student) bean.getDetails();
       try {
           /*
           * v_student_id in number,--学生ID v_student_name in varchar,--学生姓名
           * v_sex in number,--性别 v_student_no in number,--学号 v_duty in
           * varchar,--职务 v_phonenumber in varchar,--联系电话 v_school_org_id in
           * number,--组织ID v_school_org in number,--组织 v_card_id in
           * varchar,--考勤卡号
           */
           csmt = con.prepareCall("{CALL P_MODIFY_STUDENT_AND_TYPE(?,?,?,?,?,?,?,?,?,?,?)}");
           csmt.setLong(1, student.getUserId());
           csmt.setString(2, student.getStudentName());
           csmt.setLong(3, student.getSex());
           csmt.setString(4, student.getStudentNo());
           csmt.setString(5, student.getDuty());
           csmt.setString(6, student.getLinkDn());
           csmt.setLong(7, student.getOrgId());
           csmt.setLong(8, Long.parseLong(student.getSchool_id()));
           csmt.setString(9, student.getCard());
           csmt.setInt(10, student.getStudentType());
           csmt.registerOutParameter(11, Types.INTEGER);
           csmt.executeUpdate();
           if (csmt.getInt(11) == 1) {
               throw new DaoException("修改学生信息失败!");
           }
           if (csmt.getInt(11) == 2) {
               throw new DaoException("考勤卡号重复，请重输!");
           }
           if (csmt.getInt(11) == 3) {
               throw new DaoException("学生学号重复，请重输!");
           }
       } catch (SQLException e) {
           throw new DaoException("系统维护中，请稍后再试！", e);
       } finally {
           JdbcUtils.closeStatement(csmt);
           closeConnectionIfNecessary(con);
       }

   }

用到jar包

巴特西

Spring JdbcTemplate 调用存储过程

最新文章

热门文章