MyBatis如何調(diào)用存儲(chǔ)過程與存儲(chǔ)函數(shù)
1、MyBatis調(diào)用存儲(chǔ)過程
MyBatis支持使用存儲(chǔ)過程的配置。當(dāng)使用存儲(chǔ)過程時(shí),需要設(shè)置一個(gè)參數(shù)“mode”,其值有IN(輸入?yún)?shù))、OUT(輸出參數(shù))和INOUT(輸入/輸出參數(shù))。
MyBatis定義存儲(chǔ)過程如下:
<!-- 存儲(chǔ)過程 -->
<select id="selectSomeThing" statementType="CALLABLE" parameterType="hashmap" resultType="com.pjb.mybatis.po.User">
{CALL PROC_FOR_INPUT(#{information,mode=IN,jdbcType=VARCHAR})}
</select>
【示例】創(chuàng)建存儲(chǔ)過程,實(shí)現(xiàn)分頁查詢用戶列表,并返回?cái)?shù)據(jù)總數(shù)和總頁數(shù),通過MyBatis調(diào)用該存儲(chǔ)過程。
(1)在MySQL數(shù)據(jù)庫中創(chuàng)建用戶信息表(tb_user)。
-- 創(chuàng)建“用戶信息”數(shù)據(jù)表 CREATE TABLE IF NOT EXISTS tb_user ( id INT AUTO_INCREMENT PRIMARY KEY COMMENT '用戶編號(hào)', user_name VARCHAR(50) NOT NULL COMMENT '用戶姓名', sex CHAR(2) DEFAULT '男' COMMENT '性別' ) COMMENT = '用戶信息表';
(2)創(chuàng)建存儲(chǔ)過程,實(shí)現(xiàn)分頁查詢用戶列表,并返回?cái)?shù)據(jù)總數(shù)和總頁數(shù)。
-- 將結(jié)束標(biāo)志符更改為$$ DELIMITER $$ /* -- 存儲(chǔ)過程:分頁查詢用戶列表,并返回?cái)?shù)據(jù)總數(shù)和總頁數(shù) -- 輸入?yún)?shù):page_index:當(dāng)前頁碼 -- 輸入?yún)?shù):page_size:分頁大小 -- 輸出參數(shù):total_count:數(shù)據(jù)總數(shù) -- 輸出參數(shù):total_page:總頁數(shù) */ 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; -- 計(jì)算數(shù)據(jù)總數(shù) SELECT COUNT(1) INTO total_count FROM tb_user; -- 計(jì)算總頁數(shù) SET total_page = FLOOR((total_count + page_size - 1) / page_size); END$$ -- 將結(jié)束標(biāo)志符更改回分號(hào) DELIMITER ;
(3)創(chuàng)建用戶信息持久化類(User.java)。
package com.pjb.mybatis.po;
/**
* 用戶信息的持久化類
* @author pan_junbiao
**/
public class User
{
private int id; //用戶編號(hào)
private String userName; //用戶姓名
private String sex; //性別
//省略getter與setter方法...
}
(4)編寫SQL映射配置。
<!-- 存儲(chǔ)過程:分頁查詢用戶列表,并返回?cái)?shù)據(jù)總數(shù)和總頁數(shù) -->
<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)編寫執(zhí)行方法。
/**
* 使用MyBatis調(diào)用存儲(chǔ)過程:分頁查詢用戶列表,并返回?cái)?shù)據(jù)總數(shù)和總頁數(shù)
* @author pan_junbiao
*/
@Test
public void procSearchUser()
{
DataConnection dataConnection = new DataConnection();
SqlSession sqlSession = dataConnection.getSqlSession();
//封裝查詢參數(shù)
Map params = new HashMap();
params.put("page_index",2); //輸入?yún)?shù):當(dāng)前頁碼
params.put("page_size",10); //輸入?yún)?shù):分頁大小
params.put("total_count",0); //輸出參數(shù):數(shù)據(jù)總數(shù)
params.put("total_page",0); //輸出參數(shù):總頁數(shù)
//調(diào)用存儲(chǔ)過程
List<User> userList = sqlSession.selectList("test.proc_search_user",params);
System.out.println("查詢第"+ params.get("page_index") +"頁的數(shù)據(jù),每頁共"+params.get("page_size")+"條數(shù)據(jù)");
//遍歷用戶列表
for (User user : userList)
{
System.out.println("編號(hào):" + user.getId() +" 姓名:" + user.getUserName() + " 性別:" + user.getSex());
}
//獲取輸出參數(shù)
System.out.println("數(shù)據(jù)總數(shù):" + params.get("total_count"));
System.out.println("總頁數(shù):" + params.get("total_page"));
sqlSession.close();
}
執(zhí)行結(jié)果:

【示例】創(chuàng)建存儲(chǔ)過程,實(shí)現(xiàn)新增用戶信息,并返回自增主鍵,通過MyBatis調(diào)用該存儲(chǔ)過程。
(1)創(chuàng)建存儲(chǔ)過程。
-- 將結(jié)束標(biāo)志符更改為$$ DELIMITER $$ /* -- 存儲(chǔ)過程:新增用戶信息,返回自增主鍵 -- 輸入?yún)?shù):user_name:用戶姓名 -- 輸入?yún)?shù):sex:性別 -- 輸出參數(shù):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$$ -- 將結(jié)束標(biāo)志符更改回分號(hào) DELIMITER ;
(2)編寫SQL映射配置。
<!-- 存儲(chǔ)過程:新增用戶信息,返回自增主鍵 -->
<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)編寫執(zhí)行方法。
/**
* 使用MyBatis調(diào)用存儲(chǔ)過程:新增用戶信息,返回自增主鍵
* @author pan_junbiao
*/
@Test
public void procAddUser()
{
DataConnection dataConnection = new DataConnection();
SqlSession sqlSession = dataConnection.getSqlSession();
//新增的用戶對(duì)象
User user = new User();
user.setUserName("pan_junbiao的博客");
user.setSex("男");
//調(diào)用存儲(chǔ)過程執(zhí)行新增
int reuslt = sqlSession.insert("test.proc_add_user",user);
sqlSession.commit();
//打印結(jié)果
System.out.println("執(zhí)行結(jié)果:"+reuslt);
System.out.println("自增主鍵:"+user.getId());
sqlSession.close();
}
執(zhí)行結(jié)果:

其實(shí),新增數(shù)據(jù)后,獲取自增主鍵是可以使用MyBatis提供的<selectKey>標(biāo)簽,SQL映射配置如下:
<!-- 存儲(chǔ)過程:新增用戶信息,返回自增主鍵 -->
<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>
但上述示例是為了能讓該存儲(chǔ)過程擁有一個(gè)返回的參數(shù)。
2、MyBatis調(diào)用存儲(chǔ)函數(shù)
【示例】創(chuàng)建存儲(chǔ)函數(shù),根據(jù)用戶編號(hào),獲取用戶名稱,通過MyBatis調(diào)用該存儲(chǔ)函數(shù)。
(1)創(chuàng)建存儲(chǔ)函數(shù),根據(jù)用戶編號(hào),獲取用戶名稱。
-- 將結(jié)束標(biāo)志符更改為$$ DELIMITER $$ /* -- 存儲(chǔ)函數(shù):根據(jù)用戶編號(hào),獲取用戶名稱 -- 輸入?yún)?shù):in_id:用戶編號(hào) -- 返回結(jié)果:用戶名稱 */ 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; -- 返回結(jié)果 RETURN out_name; END$$ -- 將結(jié)束標(biāo)志符更改回分號(hào) DELIMITER ;
(2)編寫SQL映射配置。
<!-- 存儲(chǔ)函數(shù):根據(jù)用戶編號(hào),獲取用戶名稱 -->
<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)編寫執(zhí)行方法。
/**
* 使用MyBatis調(diào)用存儲(chǔ)函數(shù):根據(jù)用戶編號(hào),獲取用戶名稱
* @author pan_junbiao
*/
@Test
public void funcGetUserName()
{
DataConnection dataConnection = new DataConnection();
SqlSession sqlSession = dataConnection.getSqlSession();
//封裝參數(shù)
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();
}
執(zhí)行結(jié)果:

以上為個(gè)人經(jīng)驗(yàn),希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。
相關(guān)文章
SpringBoot實(shí)現(xiàn)統(tǒng)一功能處理的教程詳解
這篇文章主要為大家詳細(xì)介紹了SpringBoot如何實(shí)現(xiàn)統(tǒng)一功能處理,文中的示例代碼講解詳細(xì),對(duì)大家學(xué)習(xí)或工作有一定借鑒價(jià)值,感興趣的同學(xué)可以參考閱讀下2023-05-05
springboot2.0+elasticsearch5.5+rabbitmq搭建搜索服務(wù)的坑
這篇文章主要介紹了springboot2.0+elasticsearch5.5+rabbitmq搭建搜索服務(wù)的坑,小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧2018-06-06
java中throws與try...catch的區(qū)別點(diǎn)
在本篇文章里小編給大家整理了一篇關(guān)于java中throws與try...catch的區(qū)別點(diǎn)的內(nèi)容,需要的朋友們跟著學(xué)習(xí)下。2020-02-02
Maven依賴管理之parent與dependencyManagement深入分析
首先我們來說說parent標(biāo)簽,其實(shí)這個(gè)不難解釋,就是父的意思,pom也有繼承的。比方說我現(xiàn)在有A,B,C,A是B,C的父級(jí)?,F(xiàn)在就是有一個(gè)情況B,C其實(shí)有很多jar都是共同的,其實(shí)是可以放在父項(xiàng)目里面,這樣,讓B,C都繼承A就方便管理了2022-10-10
Java微信公眾平臺(tái)開發(fā)(3) 接收消息的分類及實(shí)體的創(chuàng)建
這篇文章主要為大家詳細(xì)介紹了Java微信公眾平臺(tái)開發(fā)第三步,接收消息的分類及實(shí)體的創(chuàng)建,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2017-04-04
Springboot轉(zhuǎn)發(fā)重定向?qū)崿F(xiàn)方式解析
這篇文章主要介紹了springboot轉(zhuǎn)發(fā)重定向?qū)崿F(xiàn)方式解析,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-03-03
SpringBoot整合Sa-Token實(shí)現(xiàn)登錄認(rèn)證的示例代碼
本文主要介紹了SpringBoot整合Sa-Token實(shí)現(xiàn)登錄認(rèn)證的示例代碼,文中通過示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2022-01-01

