玩轉Mybatis高階特性:讓你的資料操作更上一層樓

2023-03-23 18:01:02



Mybatis高階特效能夠幫助我們更加靈活地運算元據庫,包括動態SQL、快取機制、外掛機制、自定義型別轉換等。學習這些特性可以讓我們更好地利用Mybatis,提高資料操作的效率和質量。

未來的道路由自己抉擇,事業的高度由自己決定。

動態SQL

動態SQL中,Mybatis提供了多種標籤來幫助我們構建動態的SQL語句,其中包括:

  • <if>:用於條件判斷,可以動態新增WHERE語句的查詢條件。
  • <where>:動態生成WHERE語句,可以過濾掉不需要的條件。
  • <set>:動態生成UPDATE語句,可以更新需要修改的欄位。
  • <choose>:類似於Java中的switch語句,可以根據不同的條件生成不同的SQL語句。
  • <foreach>:用於迴圈遍歷集合,可以將集合中的元素作為SQL語句的引數進行批次操作。

範例:

<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>

動態SQL的優化技巧:

  1. 儘量使用<where>標籤生成WHERE語句,可以避免出現多餘的AND或OR關鍵字。
  2. 使用<foreach>標籤批次操作時,儘量使用batch模式,而不是簡單的迴圈逐一執行。
  3. 對於常用的動態SQL語句,可以使用Mybatis提供的快取機制進行優化。
  4. 儘量避免在動態SQL中使用select *語句,而是明確指定需要查詢的欄位。
  5. 在動態SQL中儘量使用預編譯語句,可以提高SQL語句的執行效率。
讓自己不斷進步,讓職業越來越優秀。

快取機制

  • 一級快取和二級快取的區別
  • 一級快取是Mybatis預設開啟的快取,它是在同一個SqlSession內部共用的快取,它可以通過查詢語句的唯一識別符號(id)和查詢引數作為key進行快取,可以有效地避免重複查詢。一級快取的生命週期與SqlSession相同,當SqlSession關閉時,它的快取也會被清空。
  • 二級快取是Mybatis的全域性快取,它可以被多個SqlSession共用,適用於需要跨SqlSession共用資料的場景。它的儲存方式是將資料放在一個HashMap中,key是查詢語句的唯一識別符號和查詢引數的組合,value是查詢到的結果。二級快取的生命週期與整個應用程式相同,它可以在應用程式的多個SqlSession之間共用查詢結果,但也由於這個原因,它的資料一旦被修改,就需要手動重新整理快取,否則會導致資料的不一致。
  • 快取的設定和使用方式

設定方式:


mybatis:
  configuration:
    cache-enabled: true   #開啟二級快取(預設開啟)
    local-cache-scope: statement #關閉一級快取(預設開啟)
#   local-cache-scope: session   #開啟一級快取(預設開啟)

使用方式:

<mapper namespace="com.youlai.mybatis.mapper.SysUserMapper">
    <cache type="com.youlai.mybatis.service.MyCustomCache"/
</mapper>

自定義快取實現,這裡採用本地儲存,分散式建議用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("獲取快取標識:{}",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("獲取快取數量:{}",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();
    }

}
做自己喜歡的事情,成為自己想成為的人。

外掛機制

Mybatis外掛可以在執行過程中攔截指定的方法,對其進行增強或者修改,原理是使用JDK動態代理機制,對Mybatis的介面進行代理,從而實現對SQL執行過程的攔截和修改,可以實現一些比較複雜的功能,例如:

  • 對SQL語句進行攔截和修改,實現動態SQL的功能。
  • 統計SQL執行的時間,方便對效能進行優化。
  • 實現通用的分頁查詢功能。
  • 對查詢結果進行加密或解密。

自定義外掛的步驟:

  1. 實現Interceptor介面,重寫intercept方法。
  2. 在intercept方法中編寫攔截邏輯,對需要攔截的方法進行增強或修改。
  3. 在plugin方法中,將攔截器範例化,並返回代理物件。
  4. 在Mybatis設定中新增外掛。

以下是一個統計SQL執行時間範例:

@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("進入攔截器");
        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("執行sql:{},引數:{},花費了{}毫秒",sql,parameterHandler.getParameterObject().toString(),sqlTime);
        return result;
    }

    @Override
    public Object plugin(Object target) {
        log.info("生成代理物件");
        return Interceptor.super.plugin(target);
    }

    @Override
    public void setProperties(Properties properties) {
        log.info("設定外掛屬性");
        Interceptor.super.setProperties(properties);
    }
}

新增外掛

@Component
public class MySqlSessionFactoryBeanCustomizer implements SqlSessionFactoryBeanCustomizer{
    @Override
    public void customize(SqlSessionFactoryBean factoryBean) {
        //註冊外掛
        factoryBean.setPlugins(new MybatisPlugin());
    }

}
保持熱情與好奇心,不斷追求進步和創新。

自定義型別轉換

Mybatis中的型別轉換指的是Java型別和資料庫型別之間的轉換。在Mybatis中,我們可以使用TypeHandler來實現自定義的型別轉換。

自定義TypeHandler的步驟如下:

  1. 建立一個類,實現org.apache.ibatis.type.TypeHandler介面。
  2. 在類上使用@MappedJdbcTypes註解指定要轉換的JDBC型別。
  3. 在類上使用@MappedTypes註解指定要轉換的Java型別。
  4. 重寫TypeHandler介面中的方法,實現自定義的型別轉換邏輯。

範例:

@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型別的引數轉換為JDBC型別的引數,並設定到PreparedStatement中");
        ps.setString(i, parameter);
    }

    @Override
    public String getResult(ResultSet rs, String columnName) throws SQLException {
        log.info("通過列名{}獲取資料,將JDBC型別中的結果轉換為java型別",columnName);
        return rs.getString(columnName);
    }

    @Override
    public String getResult(ResultSet rs, int columnIndex) throws SQLException {
        log.info("通過索引獲取資料,將JDBC型別中的結果轉換為java型別");
        return rs.getString(columnIndex);
    }

    @Override
    public String getResult(CallableStatement cs, int columnIndex) throws SQLException {
        log.info("通過索引獲取資料,將JDBC型別中的結果轉換為java型別");
        return cs.getString(columnIndex);
    }
}

註冊

@Component
public class MySqlSessionFactoryBeanCustomizer implements ConfigurationCustomizer {

    @Override
    public void customize(Configuration configuration) {
        configuration.getTypeHandlerRegistry().register(String.class,new MyStringTypeHandler());
    }
}

以上範例中,我們自定義了一個將Java String型別轉換為JDBC VARCHAR型別的TypeHandler。

完整程式碼:https://gitee.com/youlaiorg/youlai-learning.git

總結

本文介紹了Mybatis的高階特性,包括動態SQL的優化技巧、快取機制、外掛機制和自定義型別轉換。動態SQL的優化技巧包括使用<where>標籤生成WHERE語句、使用<foreach>標籤批次操作時儘量使用batch模式等。快取機制包括一級快取和二級快取,可以通過組態檔進行開啟或關閉。外掛機制可以在Mybatis的執行過程中攔截指定的方法,對其進行增強或者修改。自定義型別轉換可以將Java型別和資料庫型別之間進行轉換。

不斷學習和成長,實現自我價值和職業發展的雙贏。