【筆記】Mybatis高階查詢（七）--儲存過程呼叫

阿新 • • 發佈：2018-11-01

以下例子展示Mybatis儲存過程呼叫，與普通查詢基本一樣，只是在配置對映時要加上statementType=“CALLABLE”，由於儲存過程方式不支援Mybatis的二級快取，所以要加上useCache=“false”。

在儲存過程中使用引數時，除了配置屬性名外，還需要指定mode引數，可選值為IN、OUT、INOUT三種，入參用IN，出參用OUT，OUT模式必須指定jdbcType。另外在oracle資料庫時，如果入參存在null的也要指定jdbcType。

使用出參方式時，通常情況下會使用javaBean或Map型別接收。這2種方式有很大區別：

當使用JavaBean物件接收出參時，必須保證所有出參在JavaBean中都有對應的屬性。否則會丟擲類似“Could not set property ‘XXXX’”的錯誤。

使用map型別時就不必保證所有出參都有對應的屬性，可使用get(“屬性名”)取出值。

1. 儲存過程select_user_by_id，通過使用者id查詢使用者資訊，無返回值並使用javaBean接收出參

在MYSQL中建立儲存過程select_user_by_id

# 根據使用者編號查詢其它資料
DROP PROCEDURE IF EXISTS ‘select_user_by_id’；
DELIMITER ;;
CREATE PROCEDURE `select_user_by_id`(
		IN userId BIGINT, 
        OUT userName VARCHAR(60), 
        OUT userPassword VARCHAR(60), 
        OUT userEmail VARCHAR(60), 
        OUT userInfo TEXT, 
        OUT headImg BLOB, 
        OUT createTime DATETIME)
BEGIN
# 根據使用者編號查詢其它資料
SELECT user_name, user_password, user_email, user_info, head_img, create_time 
INTO userName, userPassword, userEmail, userInfo, headImg, createTime 
FROM sys_user WHERE id = userId;
END;
DELIMITER ;

在SysUserMapper.xml中新增儲存過程呼叫方法selectUserByIdPro

  <!-- 儲存過程的select_user_by_id呼叫 ，使用javaBean接收出參-->
  <select id="selectUserByIdPro" statementType="CALLABLE" useCache="false">
  	{call select_user_by_id (
  		#{id, mode=IN},
  		#{userName, mode=OUT, jdbcType=VARCHAR},
  		#{userPassword, mode=OUT, jdbcType=VARCHAR},
  		#{userEmail, mode=OUT, jdbcType=VARCHAR},
  		#{userInfo, mode=OUT, jdbcType=VARCHAR},
  		#{headImg, mode=OUT, jdbcType=BLOB, javaType=_byte[]},
  		#{createTime, mode=OUT, jdbcType=TIMESTAMP}
  	)}
  </select>

在SysUserMapper介面中新增儲存過程呼叫方法selectUserByIdPro

	/**
     * 使用儲存過程，根據使用者id查使用者資訊，使用javaBean（SysUser）接收儲存過程出參
     * 因為這個儲存過程沒有返回值（不要與出參搞混），所以返回值型別為void，當然設為
     * SysUser或List<SysUser>都不會報錯，不過永遠返回null
     * @param user
     */
    void selectUserByIdPro(SysUser user);

在UserMaperTest新增selectUserByIdPro測試方法

	@Test
	public void testSelectUserByIdPro() {
		// 獲取SqlSession
		SqlSession sqlSession = openSession();
		try {
			// 獲取SysUserMapper介面
			SysUserMapper userMapper = sqlSession.getMapper(SysUserMapper.class);
			
			// 查詢條件
			SysUser user = new SysUser();
			user.setId(1L);
			
			// 呼叫selectUserByIdPro方法
			userMapper.selectUserByIdPro(user);
			
			// user不為空
			Assert.assertNotNull(user.getUserName());
			
			// 查詢使用者資訊
			System.out.println(user);
		} finally {
			sqlSession.close();
		}
	}

select_user_by_id 執行結果（可以看到儲存過程已呼叫並用戶資訊已查出來）

[ex.mybatis.rbac.mapper.SysUserMapper.selectUserByIdPro] - ==>  Preparing: {call select_user_by_id ( ?, ?, ?, ?, ?, ?, ? )} 
[ex.mybatis.rbac.mapper.SysUserMapper.selectUserByIdPro] - ==> Parameters: 1(Long)
SysUser [id=1, userName=admin, userPassword=123456, [email protected], createTime=2018-10-01 18:27:36.0, userInfo=管理員, headImg=null]

2. 上一儲存過程select_user_by_id有返回值的寫法

在MYSQL中建立儲存過程select_user_by_id_1

CREATE PROCEDURE `select_user_by_id_1`(IN userId BIGINT)
BEGIN
# 根據使用者編號查詢其它資料
SELECT * FROM sys_user WHERE id = userId;
END;

在SysUserMapper.xml中新增儲存過程呼叫方法selectUserByIdPro1

  <!-- 儲存過程的呼叫 ，有返回值的用法，返回值使用resultMap指定 -->
  <select id="selectUserByIdPro1" statementType="CALLABLE" useCache="false" resultMap="userMap">
  	{call select_user_by_id_1 (#{id, mode=IN})}
  </select>

在SysUserMapper介面中新增儲存過程呼叫方法selectUserByIdPro1

    /**
     * 使用儲存過程，根據編號查使用者資訊
     * @param id
     */
    SysUser selectUserByIdPro1(Long id);

在UserMaperTest新增selectUserByIdPro1測試方法

	@Test
	public void testSelectUserByIdPro1() {
		// 獲取SqlSession
		SqlSession sqlSession = openSession();
		try {
			// 獲取SysUserMapper介面
			SysUserMapper userMapper = sqlSession.getMapper(SysUserMapper.class);
			
			// 呼叫selectUserByIdPro1方法
			SysUser user = userMapper.selectUserByIdPro1(1L);
			
			// user不為空
			Assert.assertNotNull(user.getUserName());
			
			// 查詢使用者資訊
			System.out.println(user);
		} finally {
			sqlSession.close();
		}
	}

select_user_by_id_1 執行結果（可以看到儲存過程已呼叫並用戶資訊已查出來）

[ex.mybatis.rbac.mapper.SysUserMapper.selectUserByIdPro1] - ==>  Preparing: {call select_user_by_id_1 (?)} 
[ex.mybatis.rbac.mapper.SysUserMapper.selectUserByIdPro1] - ==> Parameters: 1(Long)
[ex.mybatis.rbac.mapper.SysUserMapper.selectUserByIdPro1] - <==    Columns: id, user_name, user_password, user_email, user_info, head_img, create_time
[ex.mybatis.rbac.mapper.SysUserMapper.selectUserByIdPro1] - <==        Row: 1, admin, 123456, [email protected], <<BLOB>>, <<BLOB>>, 2018-10-01 18:27:36.0
[ex.mybatis.rbac.mapper.SysUserMapper.selectUserByIdPro1] - <==      Total: 1
[ex.mybatis.rbac.mapper.SysUserMapper.selectUserByIdPro1] - <==    Updates: 0
SysUser [id=1, userName=admin, userPassword=123456, [email protected], createTime=Mon Oct 01 18:27:36 CST 2018, userInfo=管理員, headImg=null]

3. 儲存過程select_user_page，根據使用者名稱和分頁引數進行查詢，返回總數和分頁資料,使用Map接收出參。有返回值

在MYSQL中建立儲存過程select_user_page

CREATE PROCEDURE `select_user_page`(
		IN userName VARCHAR(60),
        IN _offset BIGINT,
		IN _limit BIGINT,
        OUT total BIGINT)
BEGIN
# 查詢總數
SELECT COUNT(*) INTO total FROM sys_user
where user_name LIKE CONCAT('%',userName,'%');

# 分頁查詢資料
SELECT * FROM sys_user where user_name LIKE CONCAT('%',userName,'%') LIMIT _offset, _limit;
END;

在SysUserMapper.xml中新增儲存過程呼叫方法selectUserPage

  <!-- 儲存過程的呼叫，返回值使用resultMap指定，使用map接收出參-->
  <select id="selectUserPage" statementType="CALLABLE" useCache="false" resultMap="userMap">
  	{call select_user_page (
  		#{userName, mode=IN},
  		#{offset, mode=IN},
  		#{limit, mode=IN},
  		#{total, mode=OUT, jdbcType=BIGINT}
  	)}
  </select>

在SysUserMapper介面中新增儲存過程呼叫方法selectUserPage

    /**
     * 使用儲存過程分頁查詢，根據編號查使用者資訊
     * @param params
     */
    List<SysUser> selectUserPage(Map<String, Object> params);

在UserMaperTest新增selectUserPage測試方法

	@Test
	public void testSelectUserPage() {
		// 獲取SqlSession
		SqlSession sqlSession = openSession();
		try {
			// 獲取SysUserMapper介面
			SysUserMapper userMapper = sqlSession.getMapper(SysUserMapper.class);
			
			// 查詢條件
			Map<String, Object> params = new HashMap<>();
			params.put("userName", "test");
			params.put("offset", 0);
			params.put("limit", 10);
			
			// 呼叫selectUserPage方法
			List<SysUser> users = userMapper.selectUserPage(params);
			
			// user不為空
			Assert.assertNotNull(params.get("total"));
			
			// 查詢使用者資訊
			System.out.println(params);
			
			System.out.println(users);
		} finally {
			sqlSession.close();
		}
	}

select_user_page執行結果

[ex.mybatis.rbac.mapper.SysUserMapper.selectUserPage] - ==>  Preparing: {call select_user_page ( ?, ?, ?, ? )} 
[ex.mybatis.rbac.mapper.SysUserMapper.selectUserPage] - ==> Parameters: test(String), 0(Integer), 10(Integer)
[ex.mybatis.rbac.mapper.SysUserMapper.selectUserPage] - <==    Columns: id, user_name, user_password, user_email, user_info, head_img, create_time
[ex.mybatis.rbac.mapper.SysUserMapper.selectUserPage] - <==        Row: 1001, test, 123456, [email protected], <<BLOB>>, <<BLOB>>, 2018-10-02 17:17:11.0
[ex.mybatis.rbac.mapper.SysUserMapper.selectUserPage] - <==      Total: 1
[ex.mybatis.rbac.mapper.SysUserMapper.selectUserPage] - <==    Updates: 0
{total=1, offset=0, limit=10, userName=test}
[SysUser [id=1001, userName=test, userPassword=123456, [email protected], createTime=Tue Oct 02 17:17:11 CST 2018, userInfo=測試使用者, headImg=null]]

4. 儲存過程insert_user_and_roles，儲存使用者資訊和角色關聯資訊

在MYSQL中建立儲存過程insert_user_and_roles

CREATE PROCEDURE `insert_user_and_roles`(
		OUT userId BIGINT,
        OUT createTime DATETIME,
        IN userName VARCHAR(60), 
        IN userPassword VARCHAR(60), 
        IN userEmail VARCHAR(60), 
        IN userInfo TEXT, 
        IN headImg BLOB,
		IN roleIds VARCHAR(200))
BEGIN
# 設定建立時間
SET createTime = NOW();

# 插入資料
INSERT INTO sys_user (user_name, user_password, user_email, user_info, head_img, create_time) 
VALUES (userName, userPassword, userEmail, userInfo, headImg, createTime);

# 獲取自增主鍵
SELECT LAST_INSERT_ID() INTO userId;

# 儲存使用者和角色關係資訊
SET roleIds = CONCAT(',',roleIds,',');
INSERT INTO sys_user_role (user_id, role_id) 
SELECT userId, id from sys_role where INSTR(roleIds,CONCAT(',',id,',')) > 0;

END;

在SysUserMapper.xml中新增儲存過程呼叫方法insertUserAndRoles

  <!-- 儲存過程的呼叫 ，儲存使用者資訊和角色關聯資訊-->
  <insert id="insertUserAndRoles" statementType="CALLABLE">
  	{call insert_user_and_roles (
  		#{user.id, mode=OUT, jdbcType=BIGINT},
  		#{user.createTime, mode=OUT, jdbcType=TIMESTAMP},
  		#{user.userName, mode=IN},
  		#{user.userPassword, mode=IN},
  		#{user.userEmail, mode=IN},
  		#{user.userInfo, mode=IN},
  		#{user.headImg, mode=IN, jdbcType=BLOB},
  		#{roleIds, mode=IN}
  	)}
  </insert>

在SysUserMapper介面中新增儲存過程呼叫方法insertUserAndRoles

    /**
     * 使用儲存過程插入資料，並獲取主鍵
     * @param user
     * @param roleIds
     * @return
     */
    int insertUserAndRoles(@Param("user") SysUser user, @Param("roleIds") String roleIds);

在UserMaperTest新增insertUserAndRoles測試方法

	@Test
	public void testInsertUserAndRoles() {
		// 獲取SqlSession
		SqlSession sqlSession = openSession();
		try {
			// 獲取SysUserMapper介面
			SysUserMapper userMapper = sqlSession.getMapper(SysUserMapper.class);
			
			// 使用者資訊
			SysUser user = new SysUser();
			user.setUserName("test3");
			user.setUserPassword("myccl210");
			user.setUserEmail("[email protected]");
			user.setUserInfo("測試儲存過程插入方法");
			user.setHeadImg(new byte[]{1,2,3});
			user.setCreateTime(new Date());
			
			// 呼叫insertUserAndRoles方法
			int row = userMapper.insertUserAndRoles(user, "1,2");
			
			// row 不為空
			Assert.assertNotNull(row);
		} finally {
			sqlSession.commit();
			sqlSession.close();
		}
	}

insert_user_and_roles 執行結果

[ex.mybatis.rbac.mapper.SysUserMapper.insertUserAndRoles] - ==>  Preparing: {call insert_user_and_roles ( ?, ?, ?, ?, ?, ?, ?, ? )} 
[ex.mybatis.rbac.mapper.SysUserMapper.insertUserAndRoles] - ==> Parameters: test3(String), myccl210(String), [email protected](String), 測試儲存過程插入方法(String), [email protected](ByteArrayInputStream), 1,2(String)
[ex.mybatis.rbac.mapper.SysUserMapper.insertUserAndRoles] - <==    Updates: 2

insert_user_and_roles 執行結果，資料庫結果
使用者資訊：

使用者角色資訊：

5. 儲存過程delete_user_by_id，刪除使用者資訊和角色關聯資訊

在MYSQL中建立儲存過程delete_user_by_id

CREATE PROCEDURE `delete_user_by_id`(IN userId BIGINT)
BEGIN
DELETE FROM sys_user_role WHERE user_id = userId;
DELETE FROM sys_user where id = userId;
END;

在SysUserMapper.xml中新增儲存過程呼叫方法deleteUserById

  <!-- 儲存過程的呼叫 ，刪除使用者資訊和角色關聯資訊 -->
  <delete id="deleteUserById" statementType="CALLABLE">
  	{call delete_user_by_id (#{id, mode=IN})}
  </delete>

在SysUserMapper介面中新增儲存過程呼叫方法deleteUserById

    /**
     * 使用儲存過程刪除資料
     * @param id
     * @return
     */
    int deleteUserById(Long id);

在UserMaperTest新增deleteUserById測試方法

	@Test
	public void testDeleteUserById() {
		// 獲取SqlSession
		SqlSession sqlSession = openSession();
		try {
			// 獲取SysUserMapper介面
			SysUserMapper userMapper = sqlSession.getMapper(SysUserMapper.class);
			
			// 呼叫deleteUserById方法
			int row = userMapper.deleteUserById(1034L);
			
			System.out.println(row);
		} finally {
			sqlSession.commit();
			sqlSession.close();
		}
	}

delete_user_by_id執行結果（查資料庫發現剛才插入的1034資料給刪除了）

[ex.mybatis.rbac.mapper.SysUserMapper.deleteUserById] - ==>  Preparing: {call delete_user_by_id (?)} 
[ex.mybatis.rbac.mapper.SysUserMapper.deleteUserById] - ==> Parameters: 1034(Long)
[ex.mybatis.rbac.mapper.SysUserMapper.deleteUserById] - <==    Updates: 1

【筆記】Mybatis高階查詢（七）--儲存過程呼叫

以下例子展示Mybatis儲存過程呼叫，與普通查詢基本一樣，只是在配置對映時要加上statementType=“CALLABLE”，由於儲存過程方式不支援Mybatis的二級快取，所以要加上useCache=“false”。在儲存過程中使用引數時，除了配置屬性名外，還需要指定

【筆記】Mybatis高階查詢（八）--列舉處理器的使用

在sys_role中有一個欄位enabled，只有2個可選值，0-禁用，1-啟用。在SysRole中使用了Integer enabled來定義，這種情況下必須手動校驗enabled的值是否符合要求，在只有2個值的時候處理比較容易，但當值很多的時候，處理就比較麻煩。這時候就要使用Myb

【筆記】Mybatis高階查詢（六）--鑑別器discrimiator的使用

<discrimiator>鑑別器標籤用來處理不同資料型別執行不同操作的。與java的switch語句相似。有以下屬性： column：該屬性用於設定要進行鑑別比較值的列。 javaType：該屬性用於指定列的資料型別，保證使用相同的java

【筆記】Mybatis高階查詢（小結）--巢狀查詢及延遲載入

<association>與<collection>標籤一對一、一對多，多對多查詢時用到的屬性 property：對應實體類中的屬性名，必填項。 javaType：屬性對應的型別。 resultMap：可以直接使用現有

【筆記】Mybatis高階查詢（五）--使用resultMap的<collection>進行巢狀查詢及延遲載入

下面例子通過<collection>實現一個通過使用者編號查詢使用者下面的角色及許可權的需求，支援延遲載入。下面以自下而上的過程來實現這樣的巢狀查詢功能。並且這個自下而上的過程中每一個方法都是獨立可用的方法。上層的結果都以下層方法為基礎。所有物件都設定為延遲載入。

【筆記】Mybatis高階查詢（四）--使用resultMap的<collection>標籤實現一對多和多對多查詢

<collection>集合的巢狀結果對映就是指通過一次SQL查詢將所有的結果查詢出來，然後對映到不同的物件中。在一對多的關係中，主表一條資料會對應關聯表的多條資料。因此一般查詢時會查詢出多條結果，按照一對多的資料對映時，最終的結果數會小於等於查詢的總記錄數。

【筆記】Mybatis高階查詢（三）--使用<association>標籤實現巢狀查詢及延遲載入

<association>標籤實現巢狀查詢，需要用到以下屬性： select：另一個對映查詢的ID，Mybatis會額外執行這個查詢獲取巢狀物件的結果。 column：列名或別名，將主查詢中列的結果作為巢狀查詢的引數，配置方式如column=

【筆記】Mybatis高階查詢（九）--Mybatis程式碼生成器的使用

Mybatis Generator，簡稱MBG，是Mybatis開發團隊提供的一個很強大的程式碼生成器，可以生成資料庫表對應的實體類、Mapper介面類、Mapper XML檔案和Example物件等。這些程式碼檔案幾乎包含了全部的單表操作方法。使用MBG可

【筆記】Mybatis高階查詢--使用自動對映處理一對一關係

假設在RBAC許可權系統中，一個使用者只能有一個角色，那麼就是一對一關係了。一對一對映因為不需要考慮是否存在重複資料，用起來簡單，所以可以直接使用Mybatis的自動對映。以下例子為使用自動對映實現在查詢使用者資訊的同時獲取使用者的角色資訊。在SysU

【筆記】Mybatis高階查詢--使用resultMap配置一對一對映

1. 使用resultMap配置一對一對映除了使用Mybatis的自動對映處理一對一巢狀外，還可以在XML對映檔案中配置結果對映。以下例子是用resultMap配置來處理上一節一對一對映的。在SysUserMapper.xml中增加以下res

【閱讀筆記】JavaScript 高階程式設計（四）

基本型別和引用型別的值 ECMAScript 變數可能包含兩種不同資料型別的值：基本型別值和引用型別值。基本型別值是指簡單的資料段，而引用型別值指那些可能由多個值構成的物件。 JavaScript 的基本資料型別都是按值訪問的，因為可以操作儲存在

【筆記】ThreadPoolExecutor原始碼閱讀（三）

執行緒數量的維護執行緒池的大小有兩個重要的引數，一個是corePoolSize（核心執行緒池大小），另一個是maximumPoolSize（最大執行緒大小）。執行緒池主要根據這兩個引數對執行緒池中執行緒的數量進行維護。需要注意的是，執行緒池建立之初是沒有任何可用執行緒的。只有在有任務到達後，才開始建立

【OpenGL】Shader例項分析（七）- 雪花飄落效果

研究了一個雪花飄落效果，感覺挺不錯的，分享給大家，效果如下：程式碼如下： Shader "shadertoy/Flakes" { // https://www.shadertoy.com/view/4d2Xzc Properties{ iMouse ("Mo

【20171014】python_語言設計（7）面向過程程式設計

1.鉛球拋擲位置實時更新 from math import pi,sin,cos,radians def main(): angle = eval(input("Enter the launch angle (in degrees):")) vel = eval

輕鬆搞定RabbitMQ（七）——遠端過程呼叫RPC

翻譯：http://www.rabbitmq.com/tutorials/tutorial-six-java.html在第二篇博文中，我們已經瞭解到瞭如何使用工作佇列來向多個消費者分散耗時任務。但是付過我們需要在遠端電腦上執行一個方法然後等待結果，該怎麼辦？這是不同的需求。

Python自動化開發課堂筆記【Day06】 - Python進階（類）

擴展性程序 lex 類名人物優點 ini 參數 self. 類與對象面向過程的程序設計：　　優點：極大的降低了程序的復雜度　　缺點：一套流水線或者流程就是用來解決一個問題，生產汽水的流水線無法生產汽車，即使能，也是得大改，改一個組件，牽一發而動全身面向對象的程序設計

【安全牛學習筆記】手動漏洞挖掘（二）

security+ 漏洞信息安全手動漏洞挖掘身份認證常用弱口令/基於字典的密碼破爆破鎖定賬號信息收集手機號密碼錯誤提示信息密碼嗅探手動漏洞挖掘會話sessionID Xss / cookie importer Sess

【安全牛學習筆記】手動漏洞挖掘（四）

信息安全 security+ 漏洞手動漏洞挖掘本地文件包含lfi 查看文件代碼執行 <?php echo shell_exec($_GET['cmd']);?> Apache access.log遠程文件包含rfi 出現

【安全牛學習筆記】手動漏洞挖掘（三）

信息安全 security+ 漏洞挖掘手動漏洞挖掘Directory travarsal / File include(有區別/沒區別) 目錄權限限制不嚴 / 文件包含/etc/php5/cgi/php.ini allow_url_include = on應用程序功能操作文件，限制不

Python開發【筆記】：抓包（實時分隔）

抓包進行linux系統抓包，並且定時分隔防止檔案太大 #!/usr/bin/env python # -*- coding:utf-8 -*- import os import sys import logging import threading import time imp

【筆記】Mybatis高階查詢（七）--儲存過程呼叫

以下例子展示Mybatis儲存過程呼叫，與普通查詢基本一樣，只是在配置對映時要加上statementType=“CALLABLE”，由於儲存過程方式不支援Mybatis的二級快取，所以要加上useCache=“false”。

在儲存過程中使用引數時，除了配置屬性名外，還需要指定mode引數，可選值為IN、OUT、INOUT三種，入參用IN，出參用OUT，OUT模式必須指定jdbcType。另外在oracle資料庫時，如果入參存在null的也要指定jdbcType。

使用出參方式時，通常情況下會使用javaBean或Map型別接收。這2種方式有很大區別：

當使用JavaBean物件接收出參時，必須保證所有出參在JavaBean中都有對應的屬性。否則會丟擲類似“Could not set property ‘XXXX’”的錯誤。

使用map型別時就不必保證所有出參都有對應的屬性，可使用get(“屬性名”)取出值。

1. 儲存過程select_user_by_id，通過使用者id查詢使用者資訊，無返回值並使用javaBean接收出參

2. 上一儲存過程select_user_by_id有返回值的寫法

3. 儲存過程select_user_page，根據使用者名稱和分頁引數進行查詢，返回總數和分頁資料,使用Map接收出參。有返回值

4. 儲存過程insert_user_and_roles，儲存使用者資訊和角色關聯資訊

5. 儲存過程delete_user_by_id，刪除使用者資訊和角色關聯資訊

相關推薦