mybatis缓存机制

一 mybatis的以及缓存

默认条件下,一级缓存是开启的,并且一级缓存的作用域是SqlSession,即不同SqlSession执行相同的sql任然时查询两次数据库,一个SqlSession对象拥有一个缓存,而基于该SqlSession的mapper都共用该缓存,。
一级缓存的实现原理:当首次查询数据库时,会将结果对象或者集合保存在一级缓存中,第二次获取相同的数据时,就不会查询数据库,而是会在缓存中获取数据。而mybatis默认是使用HashMap的实现一级缓存的,即sql的id是Map的key,查询结果是Map的value(猜的)。为了保证数据的一致性,当对数据库进行插入/更新/删除时,会刷新数据库,即清空缓存。

二 mybatis的二级缓存

1 基于springboot+mybatis环境。

在将spring与mybatis整合后,由于SqlSession对象会交给spring容器去管理,在每次使用完SqlSession时都会对其进行关闭,这就造成了一级缓存完全没有作用,mybatis的二级缓存的作用就慢慢凸显了出来。
测试的日志打印如下

Creating a new SqlSession
SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@49798e84] was not registered for synchronization because synchronization is not active
JDBC Connection [HikariProxyConnection@1916720513 wrapping com.mysql.jdbc.JDBC4Connection@6b760460] will not be managed by Spring
==>  Preparing: select * from user 
==> Parameters: 
<==    Columns: userid, name, age
<==        Row: 3, zyb是个测试, 21
<==        Row: 11, testname, 45
<==        Row: 12, testname, 45
<==      Total: 3
Closing non transactional SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@49798e84]
Creating a new SqlSession
SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@6892cc6f] was not registered for synchronization because synchronization is not active
JDBC Connection [HikariProxyConnection@117249632 wrapping com.mysql.jdbc.JDBC4Connection@6b760460] will not be managed by Spring
==>  Preparing: select * from user 
==> Parameters: 
<==    Columns: userid, name, age
<==        Row: 3, zyb是个测试, 21
<==        Row: 11, testname, 45
<==        Row: 12, testname, 45
<==      Total: 3
Closing non transactional SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@6892cc6f]

sql的输出可以看出,在执行sql之前会创建一个SqlSession,执行完后就关闭,所以一级缓存是完全没有作用的。

一级缓存是基于SqlSession的,而二级缓存是基于mapper的,通过命名空间namespace区分,只要namespace是一个,那么就共同使用一个缓存,与SqlSession无关。

在springboot+mybatis环境下,实现二级缓存也比较简单,主要有两个步骤。
1)就是在Mapper.xml文件中添加以下标签。

<cache/>

添加该标签标示该mapper使用二级缓存。
2)mapper.xml文件中所有结果实体类实现Serializable接口
如果只进行步骤一,会出现如下错误

org.apache.ibatis.cache.CacheException: Error serializing object.  Cause: java.io.NotSerializableException: com.dahuici.zyb.entity.User

    at org.apache.ibatis.cache.decorators.SerializedCache.serialize(SerializedCache.java:102)
    at org.apache.ibatis.cache.decorators.SerializedCache.putObject(SerializedCache.java:56)
    at org.apache.ibatis.cache.decorators.LoggingCache.putObject(LoggingCache.java:51)
    at org.apache.ibatis.cache.decorators.SynchronizedCache.putObject(SynchronizedCache.java:45)
    at org.apache.ibatis.cache.decorators.TransactionalCache.flushPendingEntries(TransactionalCache.java:122)
    at org.apache.ibatis.cache.decorators.TransactionalCache.commit(TransactionalCache.java:105)
    at org.apache.ibatis.cache.TransactionalCacheManager.commit(TransactionalCacheManager.java:44)
    at org.apache.ibatis.executor.CachingExecutor.close(CachingExecutor.java:61)
    at org.apache.ibatis.session.defaults.DefaultSqlSession.close(DefaultSqlSession.java:264)

这里的com.dahuici.zyb.entity.User就是查询结果封装的实体类,对于mybatis的二级缓存来说,缓存不一定存储在内存中,还可能存储在硬盘里面,当存储在硬盘中时,查询结果封装的实体类就需要序列化,就必须实现序列化接口,如果实体类还有其他类的属性,同样也要实现序列化接口(Serializable)。

执行两次查询测试与结果如下。

单元测试代码如下,同样的查询执行两次,并输出结果。

@Test
    public  void  cacheTest(){
        List<User> users = userDao.allUsers();
        List<User> users1 = userDao.allUsers();
        System.out.println(users);
        System.out.println(users1);
    }

控制台输出如下

Creating a new SqlSession
SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@5226e402] was not registered for synchronization because synchronization is not active
Cache Hit Ratio [com.dahuici.zyb.Dao.UserDao]: 0.0
2020-01-02 20:31:20.836  INFO 5972 --- [           main] com.zaxxer.hikari.HikariDataSource       : HikariPool-1 - Starting...
2020-01-02 20:31:21.118  INFO 5972 --- [           main] com.zaxxer.hikari.pool.PoolBase          : HikariPool-1 - Driver does not support get/set network timeout for connections. (com.mysql.jdbc.JDBC4Connection.getNetworkTimeout()I)
2020-01-02 20:31:21.123  INFO 5972 --- [           main] com.zaxxer.hikari.HikariDataSource       : HikariPool-1 - Start completed.
JDBC Connection [HikariProxyConnection@540206885 wrapping com.mysql.jdbc.JDBC4Connection@4d23015c] will not be managed by Spring
==>  Preparing: select * from user 
==> Parameters: 
<==    Columns: id, name, age, sex
<==        Row: 1, zyb, 55, hhh
<==      Total: 1
Closing non transactional SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@5226e402]
Creating a new SqlSession
SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@72fe8a4f] was not registered for synchronization because synchronization is not active
Cache Hit Ratio [com.dahuici.zyb.Dao.UserDao]: 0.5
Closing non transactional SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@72fe8a4f]
[User(name=zyb, age=55, sex=hhh, id=1)]
[User(name=zyb, age=55, sex=hhh, id=1)]

在开启了控制台输出sql语句后,可以发现,查询sql只执行了一次,在第二次查询时,重新创建了一个SqlSession,但是没有执行sql语句,而是使用的缓存二级缓存获取数据。目前不知道Cache Hit Ratio [com.dahuici.zyb.Dao.UserDao]: 0.5代表什么意思。

2 原生环境的二级缓存(不整合spring)

原生环境下mybatis的二级缓存主要有三个步骤。
1)在mybatis核心配置文件中开启二级缓存

<settings>
        <!-- 在控制台输出执行的sql语句 -->
        <setting name="logImpl" value="STDOUT_LOGGING" />
        <!-- 开启二级缓存 -->
        <setting name="cacheEnabled" value="true"/>
    </settings>

2)mapper映射文件中使用二级缓存,添加如下标签

<cache/>

3)开启二级缓存的映射文件的所有结果实体类实现Serializable接口

package com.dahuici.zyb.entity;

import lombok.Data;

import java.io.Serializable;

@Data
public class User implements Serializable {
    private  String name;
    private String age;
    private String sex;
}

测试代码如下:

    @Test
    public void helloTest(){
        SqlSession sqlSession = MySqlSessionFactory.getSqlSession();
        SqlSession sqlSession1 = MySqlSessionFactory.getSqlSession();
        UserDao mapper = sqlSession.getMapper(UserDao.class);
        UserDao mapper1 = sqlSession1.getMapper(UserDao.class);
        List<User> list = mapper.getUserList();
        sqlSession.close();
        List<User> list1 = mapper1.getUserList();
        sqlSession1.close();
        System.out.println(list);
        System.out.println(list1);
    }

由于mybatis的二级缓存是基于mapper的,所以这里创建了两个SqlSession对象对象用于测试。需要特别注意的是,在使用了第一个SqlSession对象查询了结果后,必须将其关闭,才会在关闭的过程中将一级缓存中的结果存入二级缓存,如果不关闭SqlSession,那么二级缓存将没有数据,则第二次仍然会执行查询sql,因为二级缓存中没有数据。而如果整合springboot,由于SqlSession对象交给spring去管理了,每次查询都会创建一个新的SqlSession,并在查询结束后将其关闭,所以就不存在这个问题。

©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 今天是什么日子 起床:5点50(昨天睡得晚了些,所以早上醒来的时候,困意难挡。 今天是坚持早起的四天,周四。而且我...
    班瑞阅读 234评论 0 0
  • 我今天起来的超级超级早,早上四点起来和猪猪一起去洗头,哈哈,四点外面还是黑的,我不敢去,所以前天就给猪猪说了,叫他...
    莫子兮吖阅读 1,336评论 24 11
  • 致妈妈的大王子: 随着11月的到来,恭喜我的大王子,你已经顺利度过了两个月小学一年级的时光!仿佛是在昨天才背起书包...
    色拉美学阅读 241评论 2 9
  • 昨天 我说今天 一定要 早睡 就像我说 一定要 离开你 我都没做到
    三土老师阅读 313评论 0 0
  • 中国四大交易所 上海证券交易所(1990年11 月26日成立) 深圳证券交易所(1990年12月01日成立) 香港...
    长投渔阅读 1,457评论 0 0