Mybatis Interceptor 攔截器的實(shí)現(xiàn)
Mybatis采用責(zé)任鏈模式，通過動(dòng)態(tài)代理組織多個(gè)攔截器（插件），通過這些攔截器可以改變Mybatis的默認(rèn)行為（諸如SQL重寫之類的），由于插件會(huì)深入到Mybatis的核心，因此在編寫自己的插件前最好了解下它的原理，以便寫出安全高效的插件。
攔截器（Interceptor）在 Mybatis 中被當(dāng)做插件（plugin）對(duì)待，官方文檔提供了 Executor，ParameterHandler，ResultSetHandler，StatementHandler 共4種，并且提示“這些類中方法的細(xì)節(jié)可以通過查看每個(gè)方法的簽名來發(fā)現(xiàn)，或者直接查看 MyBatis 發(fā)行包中的源代碼”。
攔截器的使用場景主要是更新數(shù)據(jù)庫的通用字段，分庫分表，加解密等的處理。
1. Interceptor
攔截器均需要實(shí)現(xiàn)該 org.apache.ibatis.plugin.Interceptor 接口。
2. Intercepts 攔截器
@Intercepts({
@Signature(type = Executor.class, method = "update", args = {MappedStatement.class, Object.class})
})
攔截器的使用需要查看每一個(gè)type所提供的方法參數(shù)。
Signature 對(duì)應(yīng) Invocation 構(gòu)造器，type 為 Invocation.Object，method 為 Invocation.Method，args 為 Invocation.Object[]。
method 對(duì)應(yīng)的 update 包括了最常用的 insert/update/delete 三種操作，因此 update 本身無法直接判斷sql為何種執(zhí)行過程。
args 包含了其余所有的操作信息, 按數(shù)組進(jìn)行存儲(chǔ), 不同的攔截方式有不同的參數(shù)順序, 具體看type接口的方法簽名, 然后根據(jù)簽名解析。
3. Object 對(duì)象類型
args 參數(shù)列表中，Object.class 是特殊的對(duì)象類型。如果有數(shù)據(jù)庫統(tǒng)一的實(shí)體 Entity 類，即包含表公共字段，比如創(chuàng)建、更新操作對(duì)象和時(shí)間的基類等，在編寫代碼時(shí)盡量依據(jù)該對(duì)象來操作，會(huì)簡單很多。該對(duì)象的判斷使用
Object parameter = invocation.getArgs()[1];
if (parameter instanceof BaseEntity) {
BaseEntity entity = (BaseEntity) parameter;
}
即可，根據(jù)語句執(zhí)行類型選擇對(duì)應(yīng)字段的賦值。
如果參數(shù)不是實(shí)體，而且具體的參數(shù)，那么 Mybatis 也做了一些處理，比如 @Param("name") String name 類型的參數(shù)，會(huì)被包裝成 Map 接口的實(shí)現(xiàn)來處理，即使是原始的 Map 也是如此。使用
Object parameter = invocation.getArgs()[1];
if (parameter instanceof Map) {
Map map = (Map) parameter;
}
即可，對(duì)具體統(tǒng)一的參數(shù)進(jìn)行賦值。
4. SqlCommandType 命令類型
Executor 提供的方法中，update 包含了 新增，修改和刪除類型，無法直接區(qū)分，需要借助 MappedStatement 類的屬性 SqlCommandType 來進(jìn)行判斷，該類包含了所有的操作類型
public enum SqlCommandType {
UNKNOWN, INSERT, UPDATE, DELETE, SELECT, FLUSH;
}
畢竟新增和修改的場景，有些參數(shù)是有區(qū)別的，比如創(chuàng)建時(shí)間和更新時(shí)間，update 時(shí)是無需兼顧創(chuàng)建時(shí)間字段的。
MappedStatement ms = (MappedStatement) invocation.getArgs()[0]; SqlCommandType commandType = ms.getSqlCommandType();
5. 實(shí)例
自己編寫的小項(xiàng)目中，需要統(tǒng)一給數(shù)據(jù)庫字段屬性賦值：
public class BaseEntity {
private int id;
private int creator;
private int updater;
private Long createTime;
private Long updateTime;
}
dao 操作使用了實(shí)體和參數(shù)的方式，個(gè)人建議還是統(tǒng)一使用實(shí)體比較簡單，易讀。
使用實(shí)體：
int add(BookEntity entity);
使用參數(shù)：
完整的例子：
package com.github.zhgxun.talk.common.plugin;
import com.github.zhgxun.talk.common.util.DateUtil;
import com.github.zhgxun.talk.common.util.UserUtil;
import com.github.zhgxun.talk.entity.BaseEntity;
import com.github.zhgxun.talk.entity.UserEntity;
import lombok.extern.slf4j.Slf4j;
import org.apache.ibatis.executor.Executor;
import org.apache.ibatis.mapping.MappedStatement;
import org.apache.ibatis.mapping.SqlCommandType;
import org.apache.ibatis.plugin.Interceptor;
import org.apache.ibatis.plugin.Intercepts;
import org.apache.ibatis.plugin.Invocation;
import org.apache.ibatis.plugin.Plugin;
import org.apache.ibatis.plugin.Signature;
import org.springframework.stereotype.Component;
import java.util.Map;
import java.util.Properties;
/**
* 全局?jǐn)r截?cái)?shù)據(jù)庫創(chuàng)建和更新
* <p>
* Signature 對(duì)應(yīng) Invocation 構(gòu)造器, type 為 Invocation.Object, method 為 Invocation.Method, args 為 Invocation.Object[]
* method 對(duì)應(yīng)的 update 包括了最常用的 insert/update/delete 三種操作, 因此 update 本身無法直接判斷sql為何種執(zhí)行過程
* args 包含了其余多有的操作信息, 按數(shù)組進(jìn)行存儲(chǔ), 不同的攔截方式有不同的參數(shù)順序, 具體看type接口的方法簽名, 然后根據(jù)簽名解析, 參見官網(wǎng)
*
* @link http://www.mybatis.org/mybatis-3/zh/configuration.html#plugins 插件
* <p>
* MappedStatement 包括了SQL具體操作類型, 需要通過該類型判斷當(dāng)前sql執(zhí)行過程
*/
@Component
@Intercepts({
@Signature(type = Executor.class, method = "update", args = {MappedStatement.class, Object.class})
})
@Slf4j
public class NormalPlugin implements Interceptor {
@Override
@SuppressWarnings("unchecked")
public Object intercept(Invocation invocation) throws Throwable {
// 根據(jù)簽名指定的args順序獲取具體的實(shí)現(xiàn)類
// 1. 獲取MappedStatement實(shí)例, 并獲取當(dāng)前SQL命令類型
MappedStatement ms = (MappedStatement) invocation.getArgs()[0];
SqlCommandType commandType = ms.getSqlCommandType();
// 2. 獲取當(dāng)前正在被操作的類, 有可能是Java Bean, 也可能是普通的操作對(duì)象, 比如普通的參數(shù)傳遞
// 普通參數(shù), 即是 @Param 包裝或者原始 Map 對(duì)象, 普通參數(shù)會(huì)被 Mybatis 包裝成 Map 對(duì)象
// 即是 org.apache.ibatis.binding.MapperMethod$ParamMap
Object parameter = invocation.getArgs()[1];
// 獲取攔截器指定的方法類型, 通常需要攔截 update
String methodName = invocation.getMethod().getName();
log.info("NormalPlugin, methodName; {}, commandType: {}", methodName, commandType);
// 3. 獲取當(dāng)前用戶信息
UserEntity userEntity = UserUtil.getCurrentUser();
// 默認(rèn)測試參數(shù)值
int creator = 2, updater = 3;
if (parameter instanceof BaseEntity) {
// 4. 實(shí)體類
BaseEntity entity = (BaseEntity) parameter;
if (userEntity != null) {
creator = entity.getCreator();
updater = entity.getUpdater();
}
if (methodName.equals("update")) {
if (commandType.equals(SqlCommandType.INSERT)) {
entity.setCreator(creator);
entity.setUpdater(updater);
entity.setCreateTime(DateUtil.getTimeStamp());
entity.setUpdateTime(DateUtil.getTimeStamp());
} else if (commandType.equals(SqlCommandType.UPDATE)) {
entity.setUpdater(updater);
entity.setUpdateTime(DateUtil.getTimeStamp());
}
}
} else if (parameter instanceof Map) {
// 5. @Param 等包裝類
// 更新時(shí)指定某些字段的最新數(shù)據(jù)值
if (commandType.equals(SqlCommandType.UPDATE)) {
// 遍歷參數(shù)類型, 檢查目標(biāo)參數(shù)值是否存在對(duì)象中, 該方式需要應(yīng)用編寫有一些統(tǒng)一的規(guī)范
// 否則均統(tǒng)一為實(shí)體對(duì)象, 就免去該重復(fù)操作
Map map = (Map) parameter;
if (map.containsKey("creator")) {
map.put("creator", creator);
}
if (map.containsKey("updateTime")) {
map.put("updateTime", DateUtil.getTimeStamp());
}
}
}
// 6. 均不是需要被攔截的類型, 不做操作
return invocation.proceed();
}
@Override
public Object plugin(Object target) {
return Plugin.wrap(target, this);
}
@Override
public void setProperties(Properties properties) {
}
}
6. 感受
其它幾種類型，后面在看，尤其是分頁。
在編寫代碼的過程中，有時(shí)候還是需要先知道對(duì)象的類型，比如 Object.class 跟 Interface 一樣，很多時(shí)候僅僅代表一種數(shù)據(jù)類型，需要明確知道后再進(jìn)行操作。
@Param 標(biāo)識(shí)的參數(shù)其實(shí)會(huì)被 Mybatis 封裝成 org.apache.ibatis.binding.MapperMethod$ParamMap 類型，一開始我就是使用
for (Field field:parameter.getClass().getDeclaredFields()) {
}
的方式獲取，以為這些都是對(duì)象的屬性，通過反射獲取并修改即可，實(shí)際上發(fā)現(xiàn)對(duì)象不存在這些屬性，但是打印出的信息中，明確有這些字段的，網(wǎng)上參考一些信息后，才知道這是一個(gè) Map 類型，問題才迎刃而解。
以上就是本文的全部內(nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
這篇文章主要介紹了Java連接ftp服務(wù)器實(shí)例代碼 的相關(guān)資料,需要的朋友可以參考下2015-12-12
Java利用ElasticSearch實(shí)現(xiàn)自動(dòng)補(bǔ)全功能
這篇文章主要為大家詳細(xì)介紹了Java如何利用ElasticSearch實(shí)現(xiàn)跟谷歌和百度類似的下拉補(bǔ)全提示功能，文中的示例代碼講解詳細(xì)，需要的可以參考一下2023-08-08
java arrayList遍歷的四種方法及Java中ArrayList類的用法
arraylist是動(dòng)態(tài)數(shù)組，它具有三個(gè)好處分別是:動(dòng)態(tài)的增加和減少元素 、實(shí)現(xiàn)了ICollection和IList接口、靈活的設(shè)置數(shù)組的大小，本文給大家介紹java arraylist遍歷及Java arraylist 用法，感興趣的朋友一起學(xué)習(xí)吧2015-11-11
Java中DataInputStream和DataOutputStream的使用方法
這篇文章主要介紹了Java中DataInputStream和DataOutputStream的使用方法，通過創(chuàng)建對(duì)象展開具體的內(nèi)容介紹，需要的小伙伴可以參考一下2022-05-05
解決啟用 Spring-Cloud-OpenFeign 配置可刷新項(xiàng)目無法啟動(dòng)的問題
這篇文章主要介紹了解決啟用 Spring-Cloud-OpenFeign 配置可刷新項(xiàng)目無法啟動(dòng)的問題,本文重點(diǎn)給大家介紹Spring-Cloud-OpenFeign的原理及問題解決方法，需要的朋友可以參考下2021-10-10
Java 8實(shí)現(xiàn)圖片BASE64編解碼
Java 8終于有了標(biāo)準(zhǔn)的方法來處理base64的編解碼。Java一直缺少BASE64編碼API，以至于通常在項(xiàng)目開發(fā)中會(huì)選用第三方的API實(shí)現(xiàn)。但是，Java 8實(shí)現(xiàn)了BASE64編解碼API，它包含到j(luò)ava.util包。下面這篇文章我會(huì)對(duì)Java 8的BASE64編解碼做一個(gè)詳細(xì)的介紹。2016-10-10
Java詳細(xì)分析sleep和wait方法有哪些區(qū)別
這篇文章主要介紹了Java中wait與sleep的講解(wait有參及無參區(qū)別),通過代碼介紹了wait()?與wait(?long?timeout?)?區(qū)別，wait(0)?與?sleep(0)區(qū)別，需要的朋友可以參考下2022-04-04
下面小編就為大家?guī)硪黄猨ava排序算法之_選擇排序(實(shí)例講解)。小編覺得挺不錯(cuò)的，現(xiàn)在就分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧2017-09-09
Java實(shí)現(xiàn)高并發(fā)秒殺的幾種方式
高并發(fā)場景在現(xiàn)場的日常工作中很常見，本文主要介紹了Java實(shí)現(xiàn)高并發(fā)秒殺的幾種方式，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2023-05-05
這篇文章主要介紹了Idea中Jdk和Language level的指定方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2025-04-04