MySQL---当Java遇上MySQL④---存储过程

存储过程

SQL语句需要先编译然后执行，而存储过程（Stored Procedure）是一组为了完成特定功能的SQL语句集，经编译后存储在数据库中，用户通过指定存储过程的名字并给定参数（如果该存储过程带有参数）来调用执行它。

表结构见

MySQL---当Java遇上MySQL②

演示调用空参存储过程

准备

在MySQL下存储过程的创建和使用：

• 创建存储过程

DELIMITER $$
CREATE PROCEDURE p1()
BEGIN INSERT INTO tb_user(username,PASSWORD) VALUES('张飞','pwd777');SELECT * FROM tb_user;
END $$
DELIMITER ;

• 调用存储过程

CALL p1();

Java中调用空参存储过程

	@Testpublic void demo1() throws Exception {Connection con = ConnUtil.getConnection();String sql = "call p1()";CallableStatement cst = con.prepareCall(sql);//因为存储过程中有查询语句，所以调用executeQuery()相对较好ResultSet resultSet = cst.executeQuery();while( resultSet.next() ) {int id = resultSet.getInt("id");String username = resultSet.getString("username");String password = resultSet.getString("password");System.out.println("id:"+id+",username:"+username+",password:"+password);}con.close();}

演示调用带参的存储过程

准备

/*创建带参存储过程*/
DELIMITER $$
CREATE PROCEDURE p2(IN Uname VARCHAR(10),IN pwd VARCHAR(10))
BEGIN INSERT INTO tb_user(username,PASSWORD) VALUES(Uname,pwd);SELECT * FROM tb_user;
END $$
DELIMITER ;/*调用带参数存储过程*/
CALL p2('关羽','sss666');

Java中调用带参的存储过程

	@Testpublic void demo2() throws Exception {Connection con = ConnUtil.getConnection();String sql = "call p2(?,?)";CallableStatement cst = con.prepareCall(sql);//补充完整SQL语句cst.setString(1, "赵云");cst.setString(2, "zy111");//因为存储过程中有查询语句，所以调用executeQuery()相对较好ResultSet resultSet = cst.executeQuery();while( resultSet.next() ) {int id = resultSet.getInt("id");String username = resultSet.getString("username");String password = resultSet.getString("password");System.out.println("id:"+id+",username:"+username+",password:"+password);}con.close();}

演示调用带参带返回值的存储过程

准备

/*创建带参带返回值的存储过程*/
DELIMITER $$
CREATE PROCEDURE p3(IN Uname VARCHAR(10),IN pwd VARCHAR(10),OUT num INT)
BEGIN INSERT INTO tb_user(username,PASSWORD) VALUES(Uname,pwd);SELECT * FROM tb_user;SELECT COUNT(*) INTO num FROM tb_user;
END $$
DELIMITER ;/*调用带参带返回值的存储过程*/
CALL p3('马超','mc666',@abc);/*读取返回值*/
SELECT @abc;

Java调用带参带返回值的存储过程

	@Testpublic void demo3() throws Exception {Connection con = ConnUtil.getConnection();//注意1！！！String sql = "call p3(?,?,?)"; //最后一个用于存放返回值CallableStatement cst = con.prepareCall(sql);//补充完整SQL语句cst.setString(1, "赵云");cst.setString(2, "zy111");//注意2！！！//注册一个返回参数类型cst.registerOutParameter(3, Types.INTEGER);//因为存储过程中有查询语句，所以调用executeQuery()相对较好ResultSet resultSet = cst.executeQuery();while( resultSet.next() ) {int id = resultSet.getInt("id");String username = resultSet.getString("username");String password = resultSet.getString("password");System.out.println("id:"+id+",username:"+username+",password:"+password);}//注意3！！！//通过 cst获取存储过程的返回值，不是通过resultSet！！！int count = cst.getInt(3); System.out.println("总共："+count);con.close();}

源码

源码链接