mybatics 中调用mysql存储过程

比眉伴天荒 2022-06-07 04:24 249阅读 0赞

说起mybatics 框架，身边的java开发工程师们基本上都是耳熟能详。 mybatics是apache的一个开源项目，前身为ibatics，2010年此项目由apache软件基金会迁移到了google code，mybatics的确是一款十分优秀的开源持久层框架，sql代码隔离封装、自动POJO映射、jdbc 动态sql———— mybatics的好处可以说出一箩筐，然而mybatics还有一个十分优秀的特性却往往被人忽略 ----那就是mybatics还支持存储过程的调用。

不熟悉存储过程的人大都觉得存储过程复杂难懂，认为既然有了dao，那么所有的对数据库操作的逻辑（CRUD）都放到dao层就可以了，存储过程是没有必要的。无论如何，在dao中写java代码总比在数据库中写存储过程要舒服容易的多，又何必多花费时间学习一门新的存储过程语言呢?

的确，对于以下中小型项目而言，基本的增删改查sql操作就足以应付了（再稍微复杂点也就高级查询，也就把dao层改改弄得稍复杂点就行了）。可是做过稍大型点的项目的人（尤其是互联网方面）都知道，大项目尤其是分布式系统的互联网项目对于数据库安全、性能、稳定性都有很高的要求。 当web服务器和数据库服务器分布在不同的机器上，dao层调数据库服务器是需要很大的网络开销，sql语句必须从web服务器发送到数据库服务器再执行。可是存储过程就不同，存储过程的所有sql逻辑到存放在数据库服务器本地且执行效率非常高。而且由于dao层代码是放到本地，存储过程代码是在远程服务器中，故安全性上也比不上存储过程。至于稳定性就更不用谈了。

幸运的是mybatics是完美支持存储过程调用的，这一点让人感到十分欣慰，也无疑更是增加了我对它的喜爱。

对于mysql而言，mysql 5.0以后的版本是支持存储过程的 。

下面我介绍下mybatics中如何调用mysql 存储过程，至于调用oracle 的存储过程也是大同小异的，值得注意的是当程序需要返回List集合数据出来时，Oracle中需要返回游标，而mysql中直接select出去即可 。

1、 mybatics中调用mysql 存储过程返回LIST 列表数据。

根据name （模糊）查询用户信息列表，返回用户列表

UserMapper.xml 中 配置  存储过程调用， 注意  statementType="CALLABLE"  ，select元素配置的ressultType 直接就是User类型。

**\[java\]**  [view plain][]   [copy][view plain]

1.  <select id="queryUserListByLikeName\_SP" parameterType="map" resultType="User" statementType="CALLABLE" >  
2.       \{call queryUserList\_nameSP(  
3.             \#\{name,jdbcType=VARCHAR,mode=IN\}  
4.           )  
5.          \}  
6.  </select>

service 层java代码，调用mapper接口 入参传一个map，返回值是List<User> 类型

**\[java\]**  [view plain][]   [copy][view plain]

1.  **public** Map<String, Object> getUserListNameLike(String name) \{  
2.        **try** \{  
3.           Map<String,Object>  params=AjaxUtil.getMap();  
4.           params.put("name", name);  
5.           List<User> userList =  userMapper.queryUserListByLikeName\_SP(params);  
6.           **if**(userList!=**null**)\{  
7.               Map<String,Object> map= AjaxUtil.messageMap(1, "查询成功");  
8.               map.put("userList", userList);  
9.              **return** map;  
10.          \}  
11.     \} **catch** (Exception e) \{  
12.         logger.error(e);  
13.         **throw** **new** RuntimeException(e);  
14.     \}  
15.     **return** AjaxUtil.messageMap(-1, "查询失败");  
16. \}

mapper 接口 代码，就一个接口声明（通过mybatics动态代理方式产生其实现类）

**\[java\]**  [view plain][]   [copy][view plain]

1.  **public** List<User> queryUserListByLikeName\_SP( Map<String, Object> params);

最后看下，存储过程的代码。（也很简单就一个select 模糊查询）

**\[java\]**  [view plain][]   [copy][view plain]

1.  DELIMITER $$  
2.    
3.  USE \`easyuidemo\`$$  
4.    
5.  DROP PROCEDURE IF EXISTS \`queryUserList\_nameSP\`$$  
6.    
7.  CREATE DEFINER=\`root\`@\`localhost\` PROCEDURE \`queryUserList\_nameSP\`(IN in\_name VARCHAR(50))  
8.  BEGIN  
9.      SELECT  \* FROM t\_user t WHERE t.name  LIKE   CONCAT('%',in\_name,'%') ;  
10.     END$$  
11.   
12. DELIMITER ;

2、   mybatics中调用mysql 存储过程添加用户。

页面表单ajax上传的用户信息，通过存储过程完成用户添加。要求添加成功时，存储过程中要返回rc（reponseCode结果码）、msg（结果消息）、userId（新添加的用户id）

UserMapper.xml 中的配置。

值得注意的是，这里的存储过程配置既可以配置为select节点元素，也可以配置为其它insert、update、delete元素，且无须配置resultType 或resultMap，如果是select元素，请一定要设置userCache=“false”  。入参我这里设置为了map。（这里的map其实就是java.util.Map， mybatics中内置了许多java中类型到jdbc类型的别名映射，比如java中int对应为jdbc中integer，而map就是java.util.Map的在mybatics中的别名 ），大家可能会注意我这入参并没有用User  这个bean对象，用bean来传字段属性岂不是更合乎情理吗？ 这个稍候再跟大家解释下。。。

**\[java\]**  [view plain][]   [copy][view plain]

1.  <select id="addUser\_SP" parameterType="map" statementType="CALLABLE" useCache="false">  
2.       \{call addUser\_SP(  
3.              \#\{name,jdbcType=VARCHAR,mode=IN\},  
4.              \#\{age,jdbcType=INTEGER,mode=IN\},  
5.              \#\{email,jdbcType=VARCHAR,mode=IN\},  
6.              \#\{address,jdbcType=VARCHAR,mode=IN\},  
7.              \#\{phone,jdbcType=VARCHAR,mode=IN\},  
8.              \#\{rc,jdbcType=VARCHAR,mode=OUT\},  
9.              \#\{msg,jdbcType=VARCHAR,mode=OUT\},  
10.             \#\{userId,jdbcType=VARCHAR,mode=OUT\}  
11.           )  
12.          \}  
13.     </select>

service 层java代码。

大家一定在奇怪这句代码  userMapper.addUser\_SP(params); 这前面并没有用变量接收方法的返回值，其实这个方法是没有返回值的，即使你定义了要返回某个值（如Map<String,Object>）,你会发现无论你得到的永远是null。所以这里根本就不需要接收返回值。那么调用存储过程返回的out参数到要如何接收呢？细心的你可能已经发现了，没错，就是在入参param中！！调用存储过程成功后，你会发现，存储返回的rc、 msg和userId 三个out参数都被放到了你传入的参数params中————也就是说params会在调用存储成功后多出三个字段值rc、msg、userId。

**\[java\]**  [view plain][]   [copy][view plain]

1.  **public** Map<String, Object> addUser\_SP(User user) \{  
2.      **try** \{  
3.          Map<String,Object>  params=AjaxUtil.getMap();  
4.          params.put("name", user.getName());  
5.          params.put("address", user.getAddress());  
6.          params.put("age", user.getAge());  
7.          params.put("email", user.getEmail());  
8.          params.put("phone", user.getPhone());  
9.         userMapper.addUser\_SP(params);  
10.        Map<String, Object> map=**new** HashMap<String,Object>();  
11.        map.put("rc", params.get("rc"));  
12.        map.put("msg", params.get("msg"));  
13.        map.put("userId", params.get("userId"));  
14.        **return** map;  
15.     \} **catch** (Exception e) \{  
16.         logger.error(e);  
17.         **throw** **new** RuntimeException(e);  
18.     \}  
19. \}

再看下mapper接口方法的定义（没什么好说的就一个接口方法定义）

**\[java\]**  [view plain][]   [copy][view plain]

1.  **public** **void** addUser\_SP(Map<String, Object> params);

最后再看下存储过程代码：

**\[java\]**  [view plain][]   [copy][view plain]

1.  DELIMITER $$  
2.    
3.  USE \`easyuidemo\`$$  
4.    
5.  DROP PROCEDURE IF EXISTS \`addUser\_SP\`$$  
6.    
7.  CREATE DEFINER=\`root\`@\`localhost\` PROCEDURE \`addUser\_SP\`(  
8.    IN in\_name VARCHAR (50),  
9.    IN in\_age INTEGER,  
10.   IN in\_email VARCHAR (50),  
11.   IN in\_address VARCHAR (200),  
12.   IN in\_phone VARCHAR (20),  
13.   OUT rc INTEGER,  
14.   OUT msg VARCHAR (50),  
15.   OUT userId VARCHAR (50)  
16. )  
17. BEGIN  
18.   DECLARE v\_userId VARCHAR (50) DEFAULT ROUND(RAND() \* 9000000\+10000000) ;  
19.   DECLARE v\_ucount INTEGER DEFAULT 0 ;  
20.   SELECT   
21.     COUNT(\*) INTO v\_ucount   
22.   FROM  
23.     t\_user   
24.   WHERE t\_user.\`id\` = v\_userId ;  
25.   IF v\_ucount > 0   
26.   THEN SET rc = - 1 ;  
27.   SET msg = '生成userId重复,插入失败' ;  
28.   SET userId='-00000000';  
29.   ELSE   
30.   INSERT INTO t\_user (id, \`name\`, age, email, address, phone)   
31.   VALUES  
32.     (  
33.       v\_userId,  
34.       in\_name,  
35.       in\_age,  
36.       in\_email,  
37.       in\_address,  
38.       in\_phone  
39.     ) ;  
40.   SET userId = v\_userId ;  
41.   SET rc=1;  
42.   SET msg='添加成功';  
43.  \#commit ;  
44.   END IF ;  
45. END$$  
46.   
47. DELIMITER ;

存储过程本身也没什么好说的，唯一值得大家关注的是：mysql存储过程中最后有commit和没有commit 是有所不同的。

如果存储过程中没有执行commit，那么spring容器一旦发生了事务回滚，存储过程执行的操作也会回滚。如果存储过程执行了commit，那么数据库自身的事务此时已提交，这时即使在spring容器中托管了事务，并且由于其他原因导致service代码中产生异常而自动回滚，但此存储过程是不会回滚，因为数据自身的事务已在存储过程执行完毕前提交了，  也就是说此时spring回滚对存储过程的操作是无效的了。

转载地址：[http://blog.csdn.net/jasnet\_u/article/details/51339718][http_blog.csdn.net_jasnet_u_article_details_51339718]

相关阅读：MyIbatis:存储过程(增,删,改,查)

网    址：[http://liuzidong.iteye.com/blog/1056671][http_liuzidong.iteye.com_blog_1056671]

[view plain]: http://blog.csdn.net/jasnet_u/article/details/51339718#
[http_blog.csdn.net_jasnet_u_article_details_51339718]: http://blog.csdn.net/jasnet_u/article/details/51339718
[http_liuzidong.iteye.com_blog_1056671]: http://liuzidong.iteye.com/blog/1056671

发表评论取消回复

表情：

评论列表（有 0 条评论，249人围观）

还没有评论，来说两句吧...

相关阅读

相关 mySql中调用存储过程

前提：mysql数据库；创建好的存储过程调用方法：直接执行如下语句： call mycunchu; 带参的： call sp_name[(传参)]

素颜马尾好姑娘i/ 2022年12月23日 07:27/ 0 赞/ 196 阅读

相关在java中调用mysql存储过程

在java中调用mysql存储过程 <table> <tbody> <tr> <td> <div> public   cla

以你之姓@/ 2022年09月29日 13:54/ 0 赞/ 211 阅读

相关 [MySQL] 定时器调用存储过程

\创建表 mysql> use nn mysql> drop table if exists test; mysql> create table test(tim

迷南。/ 2022年09月24日 12:17/ 0 赞/ 181 阅读

相关 Mybatis调用MySQL存储过程

1.存储过程的简介我们常用的操作数据库语言SQL语句在执行的时候需要要先编译，然后执行，而存储过程（Stored Procedure）是一组为了完成特定功能的SQL语句

╰半夏微凉°/ 2022年07月03日 23:52/ 0 赞/ 234 阅读

相关 mybatics 中调用mysql存储过程

说起mybatics 框架，身边的java开发工程师们基本上都是耳熟能详。 mybatics是apache的一个开源项目，前身为ibatics，2010年此项目由apache软

比眉伴天荒/ 2022年06月07日 04:24/ 0 赞/ 250 阅读

相关 MyBatis调用Mysql存储过程

<delete id="delUser" parameterType="java.lang.String" state

迷南。/ 2022年05月23日 01:29/ 0 赞/ 210 阅读

相关 mysql 调用存储过程1

基础查询首先创建一张students学生表，增加字段与插入数据如下 ![996472-20170601152410914-1552681450.png][] 创建不带参

布满荆棘的人生/ 2022年04月13日 04:17/ 0 赞/ 277 阅读

相关 Mysql存储过程调用

前言 [博主github][github] [博主个人博客http://blog.healerjean.com][http_blog.healerjean.com

叁歲伎倆/ 2022年03月11日 09:10/ 0 赞/ 371 阅读

相关 MySQL创建、调用存储过程

一、创建存储过程今天我们搞一搞MySQL的存储过程，过程中踩了一些小坑，算是做个总结归纳~ 首先，我们了解一下存储过程的创建语句： CREATE PROCE

本是古典何须时尚/ 2022年03月06日 02:14/ 0 赞/ 374 阅读

相关 mysql 存储过程调用实例

MySQL存储过程带in和out参数 mysql> DELIMITER $$ mysql> USE test $$ Database chan

╰+攻爆jí腚メ/ 2021年06月24日 14:00/ 0 赞/ 487 阅读