技術文章 » 【SSM - MyBatis篇11】MyBatis快取，spring整合MyBatis開啟二級快取，MyBatis開啟二級快取

【SSM - MyBatis篇11】MyBatis快取，spring整合MyBatis開啟二級快取，MyBatis開啟二級快取

2020-10-04 07:00:02

文章目錄

1. MyBatis快取機制

1.1 一級快取、二級快取

   一級快取：它指的是Mybatis中sqlSession物件的快取(基於PerpetualCache 的 HashMap本地快取，作用域是Session)，當我們執行查詢以後，查詢的結果會同時存入到SqlSession為我們提供的一塊區域中，該區域的結構是一個Map集合，當我們再次查詢同樣的資料，mybatis會先去sqlsession中查詢是否有，有的話直接拿出來用，當SqlSession物件消失時，mybatis的一級快取也就消失了，同時一級快取是SqlSession範圍的快取，當呼叫SqlSession物件的修改、新增、刪除、commit()、flush、close等方法時，就會清空一級快取。

   二級快取：是Mybatis中SqlSessionFactory物件的快取(預設也是採用 PerpetualCache，HashMap儲存，不同在於其儲存作用域為 Mapper(Namespace)，並且可自定義儲存源，如 Ehcache)，由同一個SqlSessionFactory物件建立的SqlSession共用其快取，但是其中快取的是資料而不是物件，所以從二級快取再次查詢出的結果的物件與第一次存入的物件是不一樣的。(就是二級快取存下來的是物件的資料(堆中具體存放的資料，而不是物件的參照，所以如果修改物件的值，但是二級快取裡面該物件的資料是不變的))

   MyBatis的快取資料更新機制中，當某一個作用域（不管是一級快取sqlSession/二級快取SqlSessionFactory）的進行了C/U/D 操作後，預設該作用域下所有select查詢中的快取都將被clear(因為資料被改變更新，所以快取就無效了，繼續使用就可能是沒有更新的數值)
   update、delete、insert修改資料庫的方法，無論是否commit提交，會同時清空一級和二級快取。


1.2 關於一級快取(本地快取)

快取：就是把資料放到記憶體資料中，下次使用直接去快取(記憶體)中查詢
MyBatis的一級快取預設是開啟狀態，且不能關閉，開發人員不需要管理它。
一級快取對於不同的session對應各自的快取，session之間不能相互存取對方的快取(session間不共用快取)
當一個 SqlSession 關閉和提交時，該 SqlSession 中的一級查詢快取也會清空。
可以通過session.clearCache();來清空一級快取

資料查詢時：

  • 第一次查詢後，將資料放入一級快取中，也就是預設快取。
  • 第二次查詢，會先從一級快取中查詢資料，如果命中(快取中找到)：使用一級快取資料 ；如果未命中：發sql語句去資料庫查詢然後返回結果。

1.2 關於二級快取

  • MyBatis的二級快取是mapper範圍級別的(namespace)
  • 二級快取是預設開啟的。（想開啟就不必做任何設定）
  • SqlSession關閉後才會將資料寫到二級快取區域

每個sql語句都可以有一個針對二級快取的設定（sql語句中的useCache屬性）
  除了遵循大的< cache >設定外，針對每一條sql語句可以單獨設定是否使用二級快取。通過useCache="true"開啟二級快取，false關閉二級快取。如果快取設定flushCache="false" ，那麼快取將不清空。

<select … flushCache=「false」 useCache=「true」/>
<inser … flushCache=「true」/>
(insert update delete更新資料庫的時候，預設情況下會同時清空一級、二級快取，只有session被關閉的時候，才會將自己一級快取中的資料放入二級快取。)

  < cache-ref >用於 在多個名稱空間中共用相同的快取設定和範例，通過cache-ref來參照另一個快取，每個二級快取是針對名稱空間設定的，可以通過cache-ref 將多個快取合併，快取合併只是記憶體空間的合併，儲存資料的時候還是按照名稱空間儲存。
  如果AMapper和當前BMapper共用一個快取空間，如果一個1M大小，一個2M大小，那麼這個快取空間就是3M資料。

	<!-- 在Mapper.xml對映檔案中開啟二級快取 -->
	<cache flushInterval="10000" eviction="LRU" blocking="false" readOnly="false" size="1024"/>
	<!-- 當前快取和UserMapper共用一個快取空間 -->
    <cache-ref namespace="com.xgf.cache.dao.UserMapper"/>


2. Spring整合MyBatis開啟二級快取【*****】

啟用二級快取步驟：

  1. mybatis核心組態檔中開啟二級快取全域性變數：cacheEnabled = true （在mybatis核心組態檔中，設定屬性<setting name="cacheEnabled" value="true"/>）
  2. 在spring核心組態檔，sqlSessionFactory的bean中，將mybatis的設定粘入
  3. 需要在對應的對映檔案XxxMapper.xml的名稱空間namespace下加入< cache/ >來開啟二級快取。
  4. 需要在bean物件實現Serializable 介面序列化，僅用於標識(如果cache的readonly設定為true可以不用這一步)

2.1 建立MyBatis核心組態檔，在settings中開啟二級快取

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration
        PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-config.dtd">

<configuration>

    <!-- 使用mybatis方式全域性變數設定在核心組態檔sqlMapConfig.xml的settings中
         spring和mybatis整合的情況下，mybatis下的全域性引數<settings>在spring的組態檔中設定，
            在spring的sqlSessionFactory物件中，將設定粘入bean的property中

        settings用於設定全域性變數，有順序要求，要放在environment前面，設定全域性引數
        lazyLoadingEnabled 設定懶載入，全域性允許或靜止懶載入，所有的任務都懶載入
        具體實現懶載入：通過在resultMap中設定fetchType實現懶載入

        <setting name="cacheEnabled" value="true"/> cacheEnabled允許二級快取
    -->
    <settings>
        <!-- 開啟延遲載入 -->
        <setting name="lazyLoadingEnabled" value="true"/>
        <!-- 將積極載入改為消極載入即按需要載入 -->
        <setting name="aggressiveLazyLoading" value="false"/>
        <!-- 開啟二級快取(預設也是開啟的)-->
        <setting name="cacheEnabled" value="true"/>
    </settings>

</configuration>

2.2 在spring的核心組態檔中，sqlSessionFactory的bean中，將mybatis的設定粘入

	<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
        <property name="dataSource" ref="dataSource" />
        <!--將快取新增到spring中的sessionFactory中-->
        <property name="configLocation" value="com/xgf/mysql_cache/config/sqlMapConfig.xml"></property>
    </bean>

2.3 在mapper.xml對映檔案中新增< cache >< /cache >開啟二級快取

cache屬性描述
size在二級快取中可以儲存多少物件，預設1024個，超過就會按照指定的演演算法清除
eviction二級快取size存滿的時候，按照什麼規則來清除物件，預設LRU(最近最少使用)，其他方式FIFO（先進先出）、SOFT(軟參照)、WEAK(弱參照)
flushInterval重新整理間隔、清除時間，每隔多長時間進行快取的清除
blocking預設為false，為true時為阻塞式快取，當有一個執行緒讀取的時候，其他執行緒只能等待，只有當前執行緒操作完其他執行緒才能操作
type第三方快取，將第三方快取實現類寫在這裡(比如EhcacheCache)
readOnly預設為false
true：唯讀方式，快取當中物件的參照(地址)交給程式，速度快，但是不安全 。
false： 兌換成中物件進行克隆clone操作，速度慢，但是安全，類需要實現Serializable 。
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">

<mapper namespace="com.xgf.mysql_cache.dao.CustomerMapper">

    <!--在對映檔案中開啟二級快取，flushInterval：每隔多長時間進行快取的清除
        eviction：二級快取size存滿的時候，按照什麼規則來清除物件
        size：二級快取中可以儲存多少物件
        readOnly：設定為false，會兌換成中物件進行克隆clone操作，速度慢，但是安全，類需要實現Serializable
        blocking：設定為false，為非阻塞式快取
     -->
    <cache flushInterval="10000" eviction="LRU" blocking="false" readOnly="false" size="1024"/>

    <!-- 可以在sql語句中單獨設定是否啟用二級快取 通過useCache="true"設定啟用二級快取 -->
    <select id="getCustomerByNameAndJobForWhere"
            parameterType="com.xgf.mysql_cache.bean.Customer"
            resultType="com.xgf.mysql_cache.bean.Customer" 
            useCache="true">
        select id,username,job
        from customer
        <where>
            <if test="username!=null and username!=''">
                and username like concat('%',#{username},'%')
            </if>
            <if test="job!=null and job!=''">
                and job=#{job}
            </if>
        </where>
    </select>
</mapper>

2.4 在對應的javabean類實現序列化介面Serializable(僅僅是一個標識作用，不實現會報錯)（如果快取cache的readOnly屬性為true，就可以不設定）

public class beanClass implements Serializable {}

3. MyBatis中開啟二級快取

  MyBatis中開啟二級快取機制和Spring整合MyBatis開啟二級快取步驟差不多，只是少了一個步驟（2.2 在spring的核心組態檔中，sqlSessionFactory的bean中，將mybatis的設定粘入），其他都一樣。



4. Spring整合MyBatis實現二級快取案例

4.1 建立customer表

-- ----------------------------
-- customer表，主鍵自動遞增
-- ----------------------------
DROP TABLE IF EXISTS `customer`;
CREATE TABLE `customer` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `username` varchar(50) DEFAULT NULL,
  `job` varchar(50) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=14 DEFAULT CHARSET=utf8;

-- ----------------------------
-- 初始資料
-- ----------------------------
INSERT INTO `customer` VALUES ('1', '張三', '程式設計師');
INSERT INTO `customer` VALUES ('2', '李四', '專案經理');
INSERT INTO `customer` VALUES ('3', '王五', '測試員');
INSERT INTO `customer` VALUES ('4', '趙六', '開發人員');
INSERT INTO `customer` VALUES ('5', '趙錢孫李', '開發人員');
INSERT INTO `customer` VALUES ('6', '趙雲', '保衛工作');
INSERT INTO `customer` VALUES ('7', '完璧歸趙', '歷史人物');

4.2 建立javabean物件

public class Customer {

    private Integer id;         //id主鍵自動增長
    private String username;    //使用者名稱
    private String job;         //工作
    //省略getter/setter方法
}

4.3 建立dao層介面

public interface CustomerMapper {
//    where標籤查詢資料 name和job滿足條件
    List<Customer> getCustomerByNameAndJobForWhere(Customer customer);
}

4.4 建立連線資料庫的屬性檔案db.properties(鍵值對形式)

jdbc.driver = com.mysql.jdbc.Driver
jdbc.url = jdbc:mysql://localhost:3306/mybatis?useUnicode=true&characterEncoding=UTF-8&useSSL=false
jdbc.username = root
jdbc.password = 861221293

4.5 MyBatis核心組態檔開啟二級快取

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration
        PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-config.dtd">

<configuration>
    <settings>
        <!-- 開啟延遲載入/懶載入 具體實現懶載入：通過在resultMap中設定fetchType實現懶載入 -->
        <setting name="lazyLoadingEnabled" value="true"/>
        <!-- 將積極載入改為消極載入即按需要載入 -->
        <setting name="aggressiveLazyLoading" value="false"/>
        <!-- 開啟二級快取 -->
        <setting name="cacheEnabled" value="true"/>
    </settings>

</configuration>

4.6 spring整合MyBatis，在sqlSessionFactory的bean中，將mybatis設定粘入bean的property中

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:mybatis="http://mybatis.org/schema/mybatis-spring" xmlns:tx="http://www.springframework.org/schema/tx"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://mybatis.org/schema/mybatis-spring http://mybatis.org/schema/mybatis-spring.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd">

    <!--1. 引入jdbc的屬性檔案，在設定中通過佔位使用 -->
    <context:property-placeholder location="classpath*:db.properties" />

    <!--2. <context:component-scan>掃描包中註解所標註的類(@Component、@Service、@Controller、@Repository) -->
    <context:component-scan base-package="com.xgf.mysql_cache"/>

    <!--3. 由spring管理    設定資料來源資料庫連線(從jdbc屬性檔案中讀取引數) -->
    <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
        <property name="username" value="${jdbc.username}"/>
        <property name="password" value="${jdbc.password}"/>
        <property name="url" value="${jdbc.url}"/>
        <property name="driverClassName" value="${jdbc.driver}"/>
    </bean>

    <!--  通過spring來管理Mybatis的sqlSessionFactory物件建立,將MyBatis的二級快取設定configLocation粘入  -->
    <!--4. 通過完全限定名匹配查詢  建立SqlSessionFactoryBean  -->
    <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
        <property name="dataSource" ref="dataSource" />
        <!-- 將快取新增到spring中的sessionFactory中 【***】-->
        <property name="configLocation" value="com/xgf/mysql_cache/config/sqlMapConfig.xml"></property>
    </bean>

    <!-- 5. mybatis提供的一個註解掃描標籤（搜尋對映器 Mapper 介面），通過自動掃描註解的機制，建立每個dao介面定義的bean  -->
    <mybatis:scan base-package="com.xgf.mysql_cache.dao"/>

</beans>

4.7 對映檔案mapper.xml中加入< cache/ >實現二級快取

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">

<mapper namespace="com.xgf.mysql_cache.dao.CustomerMapper">

    <!--在對映檔案中開啟二級快取，flushInterval：每隔多長時間進行快取的清除
        eviction：二級快取size存滿的時候，按照什麼規則來清除物件
        size：二級快取中可以儲存多少物件
        readOnly：設定為false，會兌換成中物件進行克隆clone操作，速度慢，但是安全，類需要實現Serializable
        blocking：設定為false，為非阻塞式快取
     -->
    <cache flushInterval="10000" eviction="LRU" blocking="false" readOnly="false" size="1024"/>

    <!--where標籤，如果後面沒有條件(條件都不滿足)不加where，如果後面有條件，會自動增加一個where
    會將多餘的and、or去掉，會自動填充第一個缺失的and、or-->
    <!-- 可以在sql語句中單獨設定是否啟用二級快取 通過useCache="true"設定啟用二級快取 -->
    <select id="getCustomerByNameAndJobForWhere"
            parameterType="com.xgf.mysql_cache.bean.Customer"
            resultType="com.xgf.mysql_cache.bean.Customer"
            useCache="true">
        select id,username,job
        from customer
        <where>
            <if test="username!=null and username!=''">
                and username like concat('%',#{username},'%')
            </if>
            <if test="job!=null and job!=''">
                and job=#{job}
            </if>
        </where>
    </select>
</mapper>

4.8 建立測試類

4.8.1 資料準備

public class TestCache {

    private static ApplicationContext applicationContext = null;
    private static CustomerMapper customerMapper = null;
    //查詢物件
    //通過getCustomerByNameAndJobForWhere查詢相當於
    private static Customer customer = new Customer("趙","開發人員");//初始化customer資料
    //查詢結果
    private List<Customer> customerList = null;

    //只載入一次  @BeforeClass@BeforeClass只在類中執行一次, 必須宣告為public static
    @BeforeClass
    public static void init(){
        //載入組態檔
        applicationContext = new ClassPathXmlApplicationContext("com/xgf/mysql_cache/config/applicationContext.xml");
        //獲取bean的兩種方式
        // 1.類名首字母小寫
//        customerMapper = (CustomerMapper) applicationContext.getBean("customerMapper");
        // 2.類.class
        customerMapper = (CustomerMapper) applicationContext.getBean(CustomerMapper.class);
    }
}

4.8.2 測試一級快取

//測試一級快取
    @Test
    public void test01(){

        System.out.println("******第一次查詢******");
//        查詢資料customerList和customer是前面的宣告
        customerList = customerMapper.getCustomerByNameAndJobForWhere(customer);
        System.out.println(customerList);

        //第二次查詢(非第一次)，去一級快取中查詢資料，命中：使用一級快取資料  未命中：發sql去資料庫查詢
        System.out.println("\n******第二次查詢，查詢和第一次相同內容(命中：使用一級快取資料 )******");
        customerList = customerMapper.getCustomerByNameAndJobForWhere(customer);
        System.out.println(customerList);

        System.out.println("\n*****第三次查詢，修改查詢內容，未命中，傳送sql語句去資料庫查詢********");
        customer.setUsername("修改username");
        customer.setJob("修改job");
        customerList = customerMapper.getCustomerByNameAndJobForWhere(customer);
        System.out.println(customerList);
    }

執行結果
>