遇到调用存储过程的业务,以前有用过,但不是用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里的

Spring JdbcTemplate 调用存储过程-LMLPHP

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

没有出参的如下

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

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

  1. public void test() {
  2. List resultList = (List) jdbcTemplate.execute(
  3. new CallableStatementCreator() {
  4. public CallableStatement createCallableStatement(Connection con) throws SQLException {
  5. String storedProc = "{call sp_list_table(?,?)}";// 调用的sql
  6. CallableStatement cs = con.prepareCall(storedProc);
  7. cs.setString(1, "p1");// 设置输入参数的值
  8. cs.registerOutParameter(2, OracleTypes.CURSOR);// 注册输出参数的类型
  9. return cs;
  10. }
  11. }, new CallableStatementCallback() {
  12. public Object doInCallableStatement(CallableStatement cs) throws SQLException,DataAccessException {
  13. List resultsMap = new ArrayList();
  14. cs.execute();
  15. ResultSet rs = (ResultSet) cs.getObject(2);// 获取游标一行的值
  16. while (rs.next()) {// 转换每行的返回值到Map中
  17. Map rowMap = new HashMap();
  18. rowMap.put("id", rs.getString("id"));
  19. rowMap.put("name", rs.getString("name"));
  20. resultsMap.add(rowMap);
  21. }
  22. rs.close();
  23. return resultsMap;
  24. }
  25. });
  26. for (int i = 0; i < resultList.size(); i++) {
  27. Map rowMap = (Map) resultList.get(i);
  28. String id = rowMap.get("id").toString();
  29. String name = rowMap.get("name").toString();
  30. System.out.println("id=" + id + ";name=" + name);
  31. }
  32. }

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

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

04-30 23:15