学步园

private class ExcuteProcedure extends StoredProcedure{<br /> private static final String SQL ="p_out";//pro_get为存储过程的名字<br /> public ExcuteProcedure(){<br /> this.setDataSource(getDataSource());//已经配置了dataSource<br /> setSql(SQL);//<br /> declareParameter(new SqlParameter("in_id",Types.INTEGER));//in_id为输入参数<br /> declareParameter(new SqlOutParameter("out_num",Types.INTEGER));//为输出参数<br /> compile();//编译<br /> }<br /> public int execute(int userId){<br /> Map map = new HashMap();<br /> map.put("in_id", userId);<br /> Map outMap = execute(map);//执行<br /> return (Integer) outMap.get("out_num");</p> <p> }<br /> }<br /> public int executPro(int userId){<br /> return new ExcuteProcedure().execute(userId);<br /> }

public void testExecutPro() throws Exception {<br /> /*<br /> * mysql> delimiter //<br /> mysql> create procedure p_out(in in_id int,out out_num int)<br /> -> begin<br /> -> select userId from tb_user where userId = in_id;<br /> -> end<br /> -> delimiter ;<br /> Query OK, 0 rows affected (0.03 sec)</p> <p> */<br /> ApplicationContext ctx = new ClassPathXmlApplicationContext("app*.xml");<br /> FormJdbcDao3 dao = (FormJdbcDao3) ctx.getBean("formDao3");<br /> int userId = 17;<br /> System.out.println(dao.executPro(userId));</p> <p> }