阅读 294

MyBatis如何调用存储过程与存储函数

这篇文章主要介绍了MyBatis如何调用存储过程与存储函数，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教

目录

  • 1、MyBatis调用存储过程

  • 2、MyBatis调用存储函数

1、MyBatis调用存储过程

MyBatis支持使用存储过程的配置。当使用存储过程时，需要设置一个参数“mode”，其值有IN（输入参数）、OUT（输出参数）和INOUT（输入/输出参数）。

MyBatis定义存储过程如下：

1
2
3
4
<!-- 存储过程 -->
<select id="selectSomeThing" statementType="CALLABLE" parameterType="hashmap" resultType="com.pjb.mybatis.po.User">
    {CALL PROC_FOR_INPUT(#{information,mode=IN,jdbcType=VARCHAR})}
</select>

【示例】创建存储过程，实现分页查询用户列表，并返回数据总数和总页数，通过MyBatis调用该存储过程。

（1）在MySQL数据库中创建用户信息表（tb_user）。

1
2
3
4
5
6
7
-- 创建“用户信息”数据表
CREATE TABLE IF NOT EXISTS tb_user
(
    id INT AUTO_INCREMENT PRIMARY KEY COMMENT '用户编号',
    user_name VARCHAR(50) NOT NULL COMMENT '用户姓名',
    sex CHAR(2) DEFAULT '男' COMMENT '性别'
) COMMENT = '用户信息表';

（2）创建存储过程，实现分页查询用户列表，并返回数据总数和总页数。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
-- 将结束标志符更改为$$
DELIMITER $$
  
/*
  -- 存储过程：分页查询用户列表，并返回数据总数和总页数
  -- 输入参数：page_index：当前页码
  -- 输入参数：page_size：分页大小
  -- 输出参数：total_count：数据总数
  -- 输出参数：total_page：总页数
*/
CREATE PROCEDURE proc_search_user(IN page_index INT,IN page_size INT, OUT total_count INT, OUT total_page INT)
BEGIN
    DECLARE begin_no INT;
    SET begin_no = (page_index-1)*page_size;
  
    -- 分页查询列表
    SELECT * FROM tb_user
    WHERE id >= (
        SELECT id FROM tb_user
        ORDER BY id ASC
        LIMIT begin_no,1
    )
    ORDER BY id ASC
    LIMIT page_size;
  
    -- 计算数据总数
    SELECT COUNT(1) INTO total_count FROM tb_user;
  
    -- 计算总页数
    SET total_page = FLOOR((total_count + page_size - 1) / page_size);
END$$
  
-- 将结束标志符更改回分号
DELIMITER ;

（3）创建用户信息持久化类（User.java）。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
package com.pjb.mybatis.po;
  
/**
 * 用户信息的持久化类
 * @author pan_junbiao
 **/
public class User
{
    private int id; //用户编号
    private String userName; //用户姓名
    private String sex; //性别
  
    //省略getter与setter方法...
}

（4）编写SQL映射配置。

1
2
3
4
5
6
7
<!-- 存储过程：分页查询用户列表，并返回数据总数和总页数 -->
<select id="proc_search_user" statementType="CALLABLE" parameterType="hashmap" resultType="com.pjb.mybatis.po.User">
    {CALL proc_search_user(#{page_index,mode=IN,jdbcType=INTEGER},
      #{page_size,mode=IN,jdbcType=INTEGER},
      #{total_count,mode=OUT,jdbcType=INTEGER},
      #{total_page,mode=OUT,jdbcType=INTEGER})}
</select>

（5）编写执行方法。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
/**
 * 使用MyBatis调用存储过程：分页查询用户列表，并返回数据总数和总页数
 * @author pan_junbiao
 */
@Test
public void procSearchUser()
{
    DataConnection dataConnection = new DataConnection();
    SqlSession sqlSession = dataConnection.getSqlSession();
    //封装查询参数
    Map params = new HashMap();
    params.put("page_index",2);  //输入参数：当前页码
    params.put("page_size",10);  //输入参数：分页大小
    params.put("total_count",0); //输出参数：数据总数
    params.put("total_page",0);  //输出参数：总页数
    //调用存储过程
    List<User> userList = sqlSession.selectList("test.proc_search_user",params);
    System.out.println("查询第"+ params.get("page_index") +"页的数据，每页共"+params.get("page_size")+"条数据");
    //遍历用户列表
    for (User user : userList)
    {
        System.out.println("编号：" + user.getId() +" 姓名：" + user.getUserName() + " 性别：" + user.getSex());
    }
    //获取输出参数
    System.out.println("数据总数：" + params.get("total_count"));
    System.out.println("总页数：" + params.get("total_page"));
    sqlSession.close();
}

执行结果：

【示例】创建存储过程，实现新增用户信息，并返回自增主键，通过MyBatis调用该存储过程。

（1）创建存储过程。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
-- 将结束标志符更改为$$
DELIMITER $$
  
/*
  -- 存储过程：新增用户信息，返回自增主键
  -- 输入参数：user_name：用户姓名
  -- 输入参数：sex：性别
  -- 输出参数：user_id：自增主键
*/
CREATE PROCEDURE proc_add_user(IN user_name VARCHAR(50),IN sex CHAR(2), OUT user_id INT)
BEGIN
    -- 新增用户
    INSERT INTO tb_user(user_name,sex) VALUE (user_name,sex);
     
    -- 获取自增主键
    SELECT LAST_INSERT_ID() INTO user_id;
END$$
  
-- 将结束标志符更改回分号
DELIMITER ;


（2）编写SQL映射配置。

1
2
3
4
5
6
<!-- 存储过程：新增用户信息，返回自增主键 -->
<insert id="proc_add_user" statementType="CALLABLE" parameterType="com.pjb.mybatis.po.User">
  {CALL proc_add_user(#{userName,mode=IN,jdbcType=VARCHAR},
    #{sex,mode=IN,jdbcType=CHAR},
    #{id,mode=OUT,jdbcType=INTEGER})}
</insert>

（3）编写执行方法。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
/**
 * 使用MyBatis调用存储过程：新增用户信息，返回自增主键
 * @author pan_junbiao
 */
@Test
public void procAddUser()
{
    DataConnection dataConnection = new DataConnection();
    SqlSession sqlSession = dataConnection.getSqlSession();
    //新增的用户对象
    User user = new User();
    user.setUserName("pan_junbiao的博客");
    user.setSex("男");
    //调用存储过程执行新增
    int reuslt = sqlSession.insert("test.proc_add_user",user);
    sqlSession.commit();
    //打印结果
    System.out.println("执行结果："+reuslt);
    System.out.println("自增主键："+user.getId());
    sqlSession.close();
}

执行结果：

其实，新增数据后，获取自增主键是可以使用MyBatis提供的<selectKey>标签，SQL映射配置如下：

1
2
3
4
5
6
7
8
<!-- 存储过程：新增用户信息，返回自增主键 -->
<insert id="proc_add_user" statementType="CALLABLE" parameterType="com.pjb.mybatis.po.User">
  <selectKey keyProperty="id" order="AFTER" resultType="java.lang.Integer">
      SELECT LAST_INSERT_ID()
  </selectKey>
  {CALL proc_add_user(#{userName,mode=IN,jdbcType=VARCHAR},
    #{sex,mode=IN,jdbcType=CHAR})}
</insert>

但上述示例是为了能让该存储过程拥有一个返回的参数。

2、MyBatis调用存储函数

【示例】创建存储函数，根据用户编号，获取用户名称，通过MyBatis调用该存储函数。

（1）创建存储函数，根据用户编号，获取用户名称。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
-- 将结束标志符更改为$$
DELIMITER $$
  
/*
  -- 存储函数：根据用户编号，获取用户名称
  -- 输入参数：in_id：用户编号
  -- 返回结果：用户名称
*/
CREATE FUNCTION func_get_user_name(in_id INT)
RETURNS VARCHAR(50)
BEGIN
    -- 定义返回变量
    DECLARE out_name VARCHAR(50);
  
    -- 查询用户信息，获取用户名称
    SELECT user_name INTO out_name FROM tb_user WHERE id = in_id;
  
    -- 返回结果
    RETURN out_name;
END$$
  
-- 将结束标志符更改回分号
DELIMITER ;

（2）编写SQL映射配置。

1
2
3
4
<!-- 存储函数：根据用户编号，获取用户名称 -->
<select id="func_get_user_name" statementType="CALLABLE" parameterType="hashMap" >
    {#{userName,mode=OUT,jdbcType=VARCHAR} = CALL func_get_user_name(#{userId,mode=IN,jdbcType=INTEGER})}
</select>

（3）编写执行方法。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
/**
 * 使用MyBatis调用存储函数：根据用户编号，获取用户名称
 * @author pan_junbiao
 */
@Test
public void funcGetUserName()
{
    DataConnection dataConnection = new DataConnection();
    SqlSession sqlSession = dataConnection.getSqlSession();
    //封装参数
    Map userMap = new HashMap();
    userMap.put("userName","");
    userMap.put("userId",8);
    sqlSession.selectOne("test.func_get_user_name",userMap);
    System.out.println("用户名称：" + userMap.get("userName"));
    sqlSession.close();
}

执行结果：

以上为个人经验，希望能给大家一个参考

原文链接：https://blog.csdn.net/pan_junbiao/article/details/103575982


文章分类
代码人生
文章标签
mybatis
过程
函数
版权声明：本站是系统测试站点，无实际运营。本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 XXXXXXo@163.com 举报，一经查实，本站将立刻删除。
相关推荐