一 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,并在查询结束后将其关闭,所以就不存在这个问题。