MyBatis高級(jí)特性能夠幫助我們更加靈活地操作數(shù)據(jù)庫(kù),包括動(dòng)態(tài)SQL、緩存機(jī)制、插件機(jī)制、自定義類(lèi)型轉(zhuǎn)換等。學(xué)習(xí)這些特性可以讓我們更好地利用Mybatis,提高數(shù)據(jù)操作的效率和質(zhì)量。
未來(lái)的道路由自己抉擇,事業(yè)的高度由自己決定。
動(dòng)態(tài)SQL
動(dòng)態(tài)SQL中,Mybatis提供了多種標(biāo)簽來(lái)幫助我們構(gòu)建動(dòng)態(tài)的SQL語(yǔ)句,其中包括:
- <if>:用于條件判斷,可以動(dòng)態(tài)添加WHERE語(yǔ)句的查詢(xún)條件。
- <where>:動(dòng)態(tài)生成WHERE語(yǔ)句,可以過(guò)濾掉不需要的條件。
- <set>:動(dòng)態(tài)生成UPDATE語(yǔ)句,可以更新需要修改的字段。
- <choose>:類(lèi)似于JAVA中的switch語(yǔ)句,可以根據(jù)不同的條件生成不同的SQL語(yǔ)句。
- <foreach>:用于循環(huán)遍歷集合,可以將集合中的元素作為SQL語(yǔ)句的參數(shù)進(jìn)行批量操作。
示例:
<update id="updateByPrimaryKeySelective" parameterType="com.youlai.mybatis.domain.SysUser">
update sys_user
<set>
<if test="username != null">
username = #{username,jdbcType=VARCHAR},
</if>
<if test="nickname != null">
nickname = #{nickname,jdbcType=VARCHAR},
</if>
<if test="gender != null">
gender = #{gender,jdbcType=TINYINT},
</if>
<if test="password != null">
password = #{password,jdbcType=VARCHAR},
</if>
<if test="deptId != null">
dept_id = #{deptId,jdbcType=INTEGER},
</if>
<if test="avatar != null">
avatar = #{avatar,jdbcType=VARCHAR},
</if>
<if test="mobile != null">
mobile = #{mobile,jdbcType=VARCHAR},
</if>
<if test="status != null">
status = #{status,jdbcType=TINYINT},
</if>
<if test="email != null">
email = #{email,jdbcType=VARCHAR},
</if>
<if test="deleted != null">
deleted = #{deleted,jdbcType=TINYINT},
</if>
<if test="createTime != null">
create_time = #{createTime,jdbcType=TIMESTAMP},
</if>
<if test="updateTime != null">
update_time = #{updateTime,jdbcType=TIMESTAMP},
</if>
</set>
where id = #{id,jdbcType=INTEGER}
</update>
動(dòng)態(tài)SQL的優(yōu)化技巧:
- 盡量使用<where>標(biāo)簽生成WHERE語(yǔ)句,可以避免出現(xiàn)多余的AND或OR關(guān)鍵字。
- 使用<foreach>標(biāo)簽批量操作時(shí),盡量使用batch模式,而不是簡(jiǎn)單的循環(huán)逐一執(zhí)行。
- 對(duì)于常用的動(dòng)態(tài)SQL語(yǔ)句,可以使用Mybatis提供的緩存機(jī)制進(jìn)行優(yōu)化。
- 盡量避免在動(dòng)態(tài)SQL中使用select *語(yǔ)句,而是明確指定需要查詢(xún)的字段。
- 在動(dòng)態(tài)SQL中盡量使用預(yù)編譯語(yǔ)句,可以提高SQL語(yǔ)句的執(zhí)行效率。
讓自己不斷進(jìn)步,讓職業(yè)越來(lái)越優(yōu)秀。
緩存機(jī)制
- 一級(jí)緩存和二級(jí)緩存的區(qū)別
- 一級(jí)緩存是Mybatis默認(rèn)開(kāi)啟的緩存,它是在同一個(gè)SqlSession內(nèi)部共享的緩存,它可以通過(guò)查詢(xún)語(yǔ)句的唯一標(biāo)識(shí)符(id)和查詢(xún)參數(shù)作為key進(jìn)行緩存,可以有效地避免重復(fù)查詢(xún)。一級(jí)緩存的生命周期與SqlSession相同,當(dāng)SqlSession關(guān)閉時(shí),它的緩存也會(huì)被清空。
- 二級(jí)緩存是Mybatis的全局緩存,它可以被多個(gè)SqlSession共享,適用于需要跨SqlSession共享數(shù)據(jù)的場(chǎng)景。它的存儲(chǔ)方式是將數(shù)據(jù)放在一個(gè)HashMap中,key是查詢(xún)語(yǔ)句的唯一標(biāo)識(shí)符和查詢(xún)參數(shù)的組合,value是查詢(xún)到的結(jié)果。二級(jí)緩存的生命周期與整個(gè)應(yīng)用程序相同,它可以在應(yīng)用程序的多個(gè)SqlSession之間共享查詢(xún)結(jié)果,但也由于這個(gè)原因,它的數(shù)據(jù)一旦被修改,就需要手動(dòng)刷新緩存,否則會(huì)導(dǎo)致數(shù)據(jù)的不一致。
- 緩存的配置和使用方式
配置方式:
mybatis:
configuration:
cache-enabled: true #開(kāi)啟二級(jí)緩存(默認(rèn)開(kāi)啟)
local-cache-scope: statement #關(guān)閉一級(jí)緩存(默認(rèn)開(kāi)啟)
# local-cache-scope: session #開(kāi)啟一級(jí)緩存(默認(rèn)開(kāi)啟)
使用方式:
<mApper namespace="com.youlai.mybatis.mapper.SysUserMapper">
<cache type="com.youlai.mybatis.service.MyCustomCache"/
</mapper>
自定義緩存實(shí)現(xiàn),這里采用本地存儲(chǔ),分布式建議用redis
@Component
@Slf4j
public class MyCustomCache implements Cache, Serializable {
private String id;
private Map<Object, Object> cache = new ConcurrentHashMap<>();
public MyCustomCache() {
}
public MyCustomCache(String id) {
this.id = id;
}
@Override
public String getId() {
log.info("獲取緩存標(biāo)識(shí):{}",id);
return id;
}
@Override
public void putObject(Object key, Object value) {
log.info("添加緩存key:{},value:{}",key,value);
cache.put(key, value);
}
@Override
public Object getObject(Object key) {
log.info("獲取緩存key:{}",key);
return cache.get(key);
}
@Override
public Object removeObject(Object key) {
log.info("刪除緩存key:{}",key);
return cache.remove(key);
}
@Override
public void clear() {
log.info("清空緩存");
cache.clear();
}
@Override
public int getSize() {
log.info("獲取緩存數(shù)量:{}",cache.size());
return cache.size();
}
@Override
public ReadWriteLock getReadWriteLock() {
log.info("拿鎖");
ReentrantReadWriteLock readWriteLock = new ReentrantReadWriteLock(true);
return readWriteLock;
}
private void writeObject(ObjectOutputStream out) throws IOException {
out.writeObject(cache);
}
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException {
cache = (Map<Object, Object>) in.readObject();
}
}
做自己喜歡的事情,成為自己想成為的人。
插件機(jī)制

Mybatis插件可以在執(zhí)行過(guò)程中攔截指定的方法,對(duì)其進(jìn)行增強(qiáng)或者修改,原理是使用JDK動(dòng)態(tài)代理機(jī)制,對(duì)Mybatis的接口進(jìn)行代理,從而實(shí)現(xiàn)對(duì)SQL執(zhí)行過(guò)程的攔截和修改,可以實(shí)現(xiàn)一些比較復(fù)雜的功能,例如:
- 對(duì)SQL語(yǔ)句進(jìn)行攔截和修改,實(shí)現(xiàn)動(dòng)態(tài)SQL的功能。
- 統(tǒng)計(jì)SQL執(zhí)行的時(shí)間,方便對(duì)性能進(jìn)行優(yōu)化。
- 實(shí)現(xiàn)通用的分頁(yè)查詢(xún)功能。
- 對(duì)查詢(xún)結(jié)果進(jìn)行加密或解密。
自定義插件的步驟:
- 實(shí)現(xiàn)Interceptor接口,重寫(xiě)intercept方法。
- 在intercept方法中編寫(xiě)攔截邏輯,對(duì)需要攔截的方法進(jìn)行增強(qiáng)或修改。
- 在plugin方法中,將攔截器實(shí)例化,并返回代理對(duì)象。
- 在Mybatis配置中添加插件。
以下是一個(gè)統(tǒng)計(jì)SQL執(zhí)行時(shí)間示例:
@Intercepts({
@Signature(type = StatementHandler.class, method = "query", args = {Statement.class, ResultHandler.class})
})
@Slf4j
public class MybatisPlugin implements Interceptor {
@Override
public Object intercept(Invocation invocation) throws Throwable {
// TODO: 攔截邏輯
log.info("進(jìn)入攔截器");
long startTime = System.currentTimeMillis();
Object result = invocation.proceed();
long endTime = System.currentTimeMillis();
long sqlTime = endTime - startTime;
StatementHandler statementHandler = (StatementHandler)invocation.getTarget();
String sql = statementHandler.getBoundSql().getSql();
ParameterHandler parameterHandler = statementHandler.getParameterHandler();
log.info("執(zhí)行sql:{},參數(shù):{},花費(fèi)了{(lán)}毫秒",sql,parameterHandler.getParameterObject().toString(),sqlTime);
return result;
}
@Override
public Object plugin(Object target) {
log.info("生成代理對(duì)象");
return Interceptor.super.plugin(target);
}
@Override
public void setProperties(Properties properties) {
log.info("設(shè)置插件屬性");
Interceptor.super.setProperties(properties);
}
}
添加插件
@Component
public class MySQLSessionFactoryBeanCustomizer implements SqlSessionFactoryBeanCustomizer{
@Override
public void customize(SqlSessionFactoryBean factoryBean) {
//注冊(cè)插件
factoryBean.setPlugins(new MybatisPlugin());
}
}
保持熱情與好奇心,不斷追求進(jìn)步和創(chuàng)新。
自定義類(lèi)型轉(zhuǎn)換
Mybatis中的類(lèi)型轉(zhuǎn)換指的是Java類(lèi)型和數(shù)據(jù)庫(kù)類(lèi)型之間的轉(zhuǎn)換。在Mybatis中,我們可以使用TypeHandler來(lái)實(shí)現(xiàn)自定義的類(lèi)型轉(zhuǎn)換。
自定義TypeHandler的步驟如下:
- 創(chuàng)建一個(gè)類(lèi),實(shí)現(xiàn)org.Apache.ibatis.type.TypeHandler接口。
- 在類(lèi)上使用@MappedJdbcTypes注解指定要轉(zhuǎn)換的JDBC類(lèi)型。
- 在類(lèi)上使用@MappedTypes注解指定要轉(zhuǎn)換的Java類(lèi)型。
- 重寫(xiě)TypeHandler接口中的方法,實(shí)現(xiàn)自定義的類(lèi)型轉(zhuǎn)換邏輯。
示例:
@MappedJdbcTypes(JdbcType.VARCHAR)
@MappedTypes(String.class)
@Slf4j
public class MyStringTypeHandler implements TypeHandler<String> {
@Override
public void setParameter(PreparedStatement ps, int i, String parameter, JdbcType jdbcType) throws SQLException {
log.info("將Java類(lèi)型的參數(shù)轉(zhuǎn)換為JDBC類(lèi)型的參數(shù),并設(shè)置到PreparedStatement中");
ps.setString(i, parameter);
}
@Override
public String getResult(ResultSet rs, String columnName) throws SQLException {
log.info("通過(guò)列名{}獲取數(shù)據(jù),將JDBC類(lèi)型中的結(jié)果轉(zhuǎn)換為java類(lèi)型",columnName);
return rs.getString(columnName);
}
@Override
public String getResult(ResultSet rs, int columnIndex) throws SQLException {
log.info("通過(guò)索引獲取數(shù)據(jù),將JDBC類(lèi)型中的結(jié)果轉(zhuǎn)換為java類(lèi)型");
return rs.getString(columnIndex);
}
@Override
public String getResult(CallableStatement cs, int columnIndex) throws SQLException {
log.info("通過(guò)索引獲取數(shù)據(jù),將JDBC類(lèi)型中的結(jié)果轉(zhuǎn)換為java類(lèi)型");
return cs.getString(columnIndex);
}
}
注冊(cè)
@Component
public class MySqlSessionFactoryBeanCustomizer implements ConfigurationCustomizer {
@Override
public void customize(Configuration configuration) {
configuration.getTypeHandlerRegistry().register(String.class,new MyStringTypeHandler());
}
}
以上示例中,我們自定義了一個(gè)將Java String類(lèi)型轉(zhuǎn)換為JDBC VARCHAR類(lèi)型的TypeHandler。
完整代碼
:https://gitee.com/youlaiorg/youlai-learning.git
總結(jié)
本文介紹了Mybatis的高級(jí)特性,包括動(dòng)態(tài)SQL的優(yōu)化技巧、緩存機(jī)制、插件機(jī)制和自定義類(lèi)型轉(zhuǎn)換。動(dòng)態(tài)SQL的優(yōu)化技巧包括使用<where>標(biāo)簽生成WHERE語(yǔ)句、使用<foreach>標(biāo)簽批量操作時(shí)盡量使用batch模式等。緩存機(jī)制包括一級(jí)緩存和二級(jí)緩存,可以通過(guò)配置文件進(jìn)行開(kāi)啟或關(guān)閉。插件機(jī)制可以在Mybatis的執(zhí)行過(guò)程中攔截指定的方法,對(duì)其進(jìn)行增強(qiáng)或者修改。自定義類(lèi)型轉(zhuǎn)換可以將Java類(lèi)型和數(shù)據(jù)庫(kù)類(lèi)型之間進(jìn)行轉(zhuǎn)換。