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(); //新增的用戶對象 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ì),對大家學(xué)習(xí)或工作有一定借鑒價(jià)值,感興趣的同學(xué)可以參考閱讀下2023-05-05springboot2.0+elasticsearch5.5+rabbitmq搭建搜索服務(wù)的坑
這篇文章主要介紹了springboot2.0+elasticsearch5.5+rabbitmq搭建搜索服務(wù)的坑,小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧2018-06-06java中throws與try...catch的區(qū)別點(diǎn)
在本篇文章里小編給大家整理了一篇關(guān)于java中throws與try...catch的區(qū)別點(diǎn)的內(nèi)容,需要的朋友們跟著學(xué)習(xí)下。2020-02-02Maven依賴管理之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-10Java微信公眾平臺(tái)開發(fā)(3) 接收消息的分類及實(shí)體的創(chuàng)建
這篇文章主要為大家詳細(xì)介紹了Java微信公眾平臺(tái)開發(fā)第三步,接收消息的分類及實(shí)體的創(chuàng)建,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2017-04-04Springboot轉(zhuǎn)發(fā)重定向?qū)崿F(xiàn)方式解析
這篇文章主要介紹了springboot轉(zhuǎn)發(fā)重定向?qū)崿F(xiàn)方式解析,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-03-03SpringBoot整合Sa-Token實(shí)現(xiàn)登錄認(rèn)證的示例代碼
本文主要介紹了SpringBoot整合Sa-Token實(shí)現(xiàn)登錄認(rèn)證的示例代碼,文中通過示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2022-01-01