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