JDBC从入门到放弃-04:JDBC的callableStatement

Bertha 。 2022-05-10 01:28 208阅读 0赞

# JDBC从入门到放弃 #

# 04-JDBC的callableStatement #

第一节我们看到JDBC支持的数据库操作除了statement和preparedSatement以外还支持callableStatement。上面两节讲解了statement和preparedStatement的内容，这节我们继续讲解callableStatement的内容，也就是所谓的存储过程。

## 什么是存储过程 ##

SQL中的存储过程类似于java中的函数（方法）。

存储过程：预先编辑好SQL语句的集合，这个集合完成了某项具体的功能集合，我需要这个功能的时候，只要调用这个过程就好了！（一般大型的企业项目才会用到，中小型的项目不会使用到，这里作为了解即可）

## 创建语法 ##

create procedure 存储过程的名字(参数列表)

begin

存储过程体(SQL语句的集合);

end

注意:

1.  参数列表包含三个部分:参数模式 参数名 参数类型

(比如: in s\_name varchar(20) )

参数模式:

in : 该参数可以作为输入,需要调用方传入值来给存储过程

out : 该参数可以作为输出,该参数可以作为返回值给调用方

inout : 该参数既可以做输入,也可以作为输出

1.  如果存储体只要一句SQL语句,begin和end可以省略,存储体里的slq语句结尾处必须加分号,避免数据库误判为存储过程的结束标记,所以需要我们自定义命令的结尾符号:
2.  delimiter 结尾标记 比如:delimiter $

## 存储过程的调用: ##

call 存储过程名(参数列表);

### 无参数存储过程 ###

*  delimiter $
 *  create procedure proc()

begin

insert into user(name,age,birthday) values ('小三',18,'2000-01-01');

insert into user(name,age,birthday) values ('小四',17,'1999-01-01');

insert into user(name,age,birthday) values ('小五',16,'1998-01-01');

insert into user(name,age,birthday) values ('小六',15,'1997-01-01');

*  调用:call proc ()

测试：

输入如下命令

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:414.8pt;"> delimiter $ create procedure proc() begin insert into user(name,age,birthday) values ('小三',18,'2000-01-01'); insert into user(name,age,birthday) values ('小四',17,'1999-01-01'); insert into user(name,age,birthday) values ('小五',16,'1998-01-01'); insert into user(name,age,birthday) values ('小六',15,'1997-01-01'); end $ </td> 
 </tr> 
 </tbody> 
</table>

![70][]

可以看到存储过程已经建立ok

![70 1][]

使用存储过程

![70 2][]

结果正确

![70 3][]

### 带in参数模式的存储过程 ###

案例:通过用户姓名查询对应的年龄和姓名

delimiter $

create procedure proc2(in in\_name varchar(255))

begin

select u.name, u.age from user u

where u.name=in\_name;

end $

![70 4][]

调用:call proc2('张三') 结果为

![70 5][]

### 带out参数模式的存储过程 ###

简单示例

create procedure getnamebyid(in in\_id int,out return\_name char(255))

Select name into return\_name from user where \_id =in\_id;

使用和结果

delimiter $

call getnamebyid(5,@name)$

select @name $

![70 6][]

带Iinout参数模式的存储过程

delimiter $

create procedure proc3(inout a int , inout b int)

begin

set a=a\*2;

set b=b\*2;

end $

调用:

delimiter $

set @a=10$

set @b=20$

call myp5(@a,@b)$

select @a,@b $

![70 7][]

附

删除存储过程:

drop procedure 存储过程名;

## JDBC使用存储过程 ##

我们已经在SQL中创建和使用了存储过程，现在我们尝试在JDBC中的使用。也就是callableStatement的使用。

其使用方式和preparedStatement类似。

1.  无参存储过程

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:414.8pt;"> &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; /** &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* 测试存储过程(无参数) &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;&nbsp; delimiter $ &nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;&nbsp; create procedure proc() &nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;&nbsp; begin &nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;&nbsp; insert into user(name,age,birthday) values ('小三',18,'2000-01-01'); &nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;&nbsp; insert into user(name,age,birthday) values ('小四',17,'1999-01-01'); &nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;&nbsp; insert into user(name,age,birthday) values ('小五',16,'1998-01-01'); &nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;&nbsp; insert into user(name,age,birthday) values ('小六',15,'1997-01-01'); &nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;&nbsp; end $ &nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;&nbsp; call proc() &nbsp;&nbsp;&nbsp;&nbsp; @Test &nbsp;&nbsp;&nbsp;&nbsp; public void testStoredProcedure1() { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Connection con = null; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; CallableStatement cs = null; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ResultSet rs = null; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; con = DBUtils.getConnection(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; cs = con.prepareCall("{call proc()}"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; rs = cs.executeQuery(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } catch (Exception e) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // TODO: handle exception &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } finally { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; DBUtils.close(con, cs, rs); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp; } </td> 
 </tr> 
 </tbody> 
</table>

结果，已经插入正确

![70 8][]

1.  In存储过程

<table style="margin-left:21pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:414.8pt;"> &nbsp;&nbsp;&nbsp; /** &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* 测试存储过程(有参数) &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp; // delimiter $ &nbsp;&nbsp;&nbsp;&nbsp; // create procedure proc2(in in_name varchar(255)) &nbsp;&nbsp;&nbsp;&nbsp; // begin &nbsp;&nbsp;&nbsp;&nbsp; // select u.name, u.age from user u &nbsp;&nbsp;&nbsp;&nbsp; // where u.name=in_name; &nbsp;&nbsp;&nbsp;&nbsp; // end $ &nbsp;&nbsp;&nbsp;&nbsp; // call proc2('张三') &nbsp;&nbsp;&nbsp;&nbsp; @Test &nbsp;&nbsp;&nbsp;&nbsp; public void testStoredProcedure2() { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Connection con = null; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; CallableStatement cs = null; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ResultSet rs = null; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; con = DBUtils.getConnection(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; cs = con.prepareCall("{call proc2(?)}"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; cs.setString(1, "张三"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; rs = cs.executeQuery(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; while (rs.next()) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String name = rs.getString("name"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; int age= rs.getInt("age"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("name = "+ name + " age = " + age); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } catch (Exception e) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // TODO: handle exception &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } finally { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; DBUtils.close(con, cs, rs); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp; } </td> 
 </tr> 
 </tbody> 
</table>

为了测试循环，我们再往数据库中增加一条张三的记录：

数据库记录现在为：

![70 9][]

测试运行结果为，结果正确

![70 10][]

1.  In和out存储过程

<table style="margin-left:21pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:414.8pt;"> &nbsp;&nbsp;&nbsp;&nbsp; /** &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;* 测试存储过程(有参数和有返回值) &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;*/ &nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;&nbsp; create procedure getnamebyid(in in_id int,out return_name char(255)) &nbsp;&nbsp;&nbsp;&nbsp; //&nbsp;&nbsp; Select name into return_name from user where _id =in_id; &nbsp;&nbsp;&nbsp;&nbsp; @Test &nbsp;&nbsp;&nbsp;&nbsp; public void testStoredProcedure3() { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Connection con = null; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; CallableStatement cs = null; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ResultSet rs = null; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; con = DBUtils.getConnection(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; cs = con.prepareCall("{call getnamebyid(?,?)}"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; cs.setInt(1, 5);//索引为1，数据库中的id为5 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //输出参数的话需要注册 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; cs.registerOutParameter(2, Types.CHAR); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //注册后需要更新 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; cs.execute(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String returnName = cs.getString("return_name");//cs.getString(2); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; cs.executeQuery(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("return_name = "+ returnName&nbsp; ); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } catch (Exception e) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // TODO: handle exception &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } finally { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; DBUtils.close(con, cs, rs); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp; } </td> 
 </tr> 
 </tbody> 
</table>

执行结果正确

![70 11][]

至此，关于JDBC的数据库操作相关类已讲解完毕。

附：用到的sql查询过程的SQL语句如下：

delimiter $

create procedure proc()

begin

insert into user(name,age,birthday) values ('小三',18,'2000-01-01');

insert into user(name,age,birthday) values ('小四',17,'1999-01-01');

insert into user(name,age,birthday) values ('小五',16,'1998-01-01');

insert into user(name,age,birthday) values ('小六',15,'1997-01-01');

end $

call proc()

delimiter $

create procedure proc2(in in\_name varchar(255))

begin

select u.name, u.age from user u

where u.name=in\_name;

end $

call proc2('张三')

create procedure getnamebyid(in in\_id int,out return\_name varchar(255)) Select name into return\_name from user where \_id =in\_id;

delimiter $

call getnamebyid(5,@name)$

select @name $

delimiter $

create procedure proc3(inout a int , inout b int)

begin

set a=a\*2;

set b=b\*2;

end $

delimiter $

set @a=10$

set @b=20$

call proc3(@a,@b)$

select @a,@b $

[70]: /images/20220510/910c1d231e21447ebff9a928307310c9.png
[70 1]: /images/20220510/db70b2ce6f9744acb490260c0937b525.png
[70 2]: /images/20220510/c6dc800c132f40c98d7a79ecf95e6f17.png
[70 3]: /images/20220510/5d9bb98141f24304bdb8ecaaae698a35.png
[70 4]: /images/20220510/1b9166f539964ef78632c630f4cfba0f.png
[70 5]: /images/20220510/ddff8f460ab94cf7bfbf01a1207cb201.png
[70 6]: /images/20220510/916376675e3044bd9a82cdb2a4ebd759.png
[70 7]: /images/20220510/336280b46c5b4a91bb8c62f929e8421f.png
[70 8]: /images/20220510/b96f211a661440d3b72eec527603e917.png
[70 9]: /images/20220510/0b8ae7a29bb3468da632beac6fc416e1.png
[70 10]: /images/20220510/95fda7b8ad37406187d008d319b4e269.png
[70 11]: /images/20220510/2ff401847130468e97ce94c70743c2c3.png