"1、一级缓存[链接] MyBatis 默认开启了一级缓存，一级缓存是在 SqlSession 层面进行缓存的。即，同一个 SqlSession ，多次调用同一个 Mapper 和同一个方法的同一个参数，只会进行一次数据库查询，然后把数据缓存到缓冲中，以后直接先从缓存中取出数据，不会直接去查数据库。 ...."

someone1
AI专业者开发社区 1 号成员
AI开发者社区 • 0 回帖 • 1 浏览 • 5 个月前

MyBatis 一、二级缓存和自定义缓存

1、一级缓存#

MyBatis 默认开启了一级缓存，一级缓存是在 SqlSession 层面进行缓存的。即，同一个 SqlSession ，多次调用同一个 Mapper 和同一个方法的同一个参数，只会进行一次数据库查询，然后把数据缓存到缓冲中，以后直接先从缓存中取出数据，不会直接去查数据库。

但是不同的 SqlSession 对象，因为不用的 SqlSession 都是相互隔离的，所以相同的 Mapper、参数和方法，他还是会再次发送到 SQL 到数据库去执行，返回结果。

Copy
public static void main(String[] args) {
		// 自定义的单例 SqlSessionFactory 模式
        SqlSessionFactory factory = SqlSessionFactoryUtil.openSqlSession();
    <span class="hljs-comment">// 获得SqlSession对象</span>
    <span class="hljs-type">SqlSession</span> <span class="hljs-variable">sqlSession</span> <span class="hljs-operator">=</span> factory.openSession();
    <span class="hljs-comment">// 获得dao实体</span>
    <span class="hljs-type">UserMapper</span> <span class="hljs-variable">userMapper</span> <span class="hljs-operator">=</span> sqlSession.getMapper(UserMapper.class);
    <span class="hljs-comment">// 进行两次相同的查询操作</span>
    userMapper.selectByPrimaryKey(<span class="hljs-number">1</span>);
    userMapper.selectByPrimaryKey(<span class="hljs-number">1</span>);
	<span class="hljs-comment">// 注意，当我们使用二级缓存时候，sqlSession需要使用commit时候才会生效</span>
    sqlSession.commit();

    System.out.println(<span class="hljs-string">"\n\n============================================================="</span>);
    <span class="hljs-comment">// 获得一个新的SqlSession 对象</span>
    <span class="hljs-type">SqlSession</span> <span class="hljs-variable">sqlSession1</span> <span class="hljs-operator">=</span> factory.openSession();
    <span class="hljs-comment">// 进行相同的查询操作</span>
    sqlSession1.getMapper(UserMapper.class).selectByPrimaryKey(<span class="hljs-number">1</span>);
	<span class="hljs-comment">// 注意，当我们使用二级缓存时候，sqlSession需要使用commit时候才会生效</span>
    sqlSession.commit();
}

日志输出

Copy
DEBUG [main] - ooo Using Connection [com.mysql.jdbc.JDBC4Connection@77caeb3e]
DEBUG [main] - ==>  Preparing: select user_ID, login_name,user_name, user_code, user_type, user_active, organization_ID,user_position,password from user where user_ID = ? 
DEBUG [main] - ==> Parameters: 1(Integer)
TRACE [main] - <==    Columns: user_ID, login_name, user_name, user_code, user_type, user_active, organization_ID, user_position, password
TRACE [main] - <==        Row: 1, ASH-001, 小明, JIKF-001, ADMIN, 1, 0, 销售员, 1212121212121
DEBUG [main] - <==      Total: 1
=============================================================
DEBUG [main] - ooo Using Connection [com.mysql.jdbc.JDBC4Connection@553f17c]
DEBUG [main] - ==>  Preparing: select user_ID, login_name,user_name, user_code, user_type, user_active, organization_ID,user_position,password from user where user_ID = ?
DEBUG [main] - ==> Parameters: 1(Integer)
TRACE [main] - <==    Columns: user_ID, login_name, user_name, user_code, user_type, user_active, organization_ID, user_position, password
TRACE [main] - <==         Row: 1, ASH-001, 小明, JIKF-001, ADMIN, 1, 0, 销售员, 1212121212121
DEBUG [main] - <==      Total: 1

可以发现，第一次的两个相同操作，只执行了一次数据库。后来的那个操作又进行了数据库查询。

2、二级缓存#

为了克服这个问题，需要开启二级缓存，是的缓存 zaiSqlSessionFactory 层面给各个 SqlSession 对象共享。默认二级缓存是不开启的，需要手动进行配置。

Copy
<cache/>

如果这样配置的话，很多其他的配置就会被默认进行，如：

映射文件所有的 select 语句会被缓存
映射文件的所有的 insert、update 和 delete 语句会刷新缓存
缓存会使用默认的 Least Recently Used（LRU，最近最少使用原则）的算法来回收缓存空间
根据时间表，比如 No Flush Interval，（CNFI，没有刷新间隔），缓存不会以任何时间顺序来刷新
缓存会存储列表集合或对象（无论查询方法返回什么）的 1024 个引用
缓存会被视为是 read/write（可读 / 可写）的缓存，意味着对象检索不是共享的，而且可以很安全的被调用者修改，不干扰其他调用者或县城所作的潜在修改

添加后日志打印如下，可以发现所有过程只使用了一次数据库查询

Copy
EBUG [main] - ooo Using Connection [com.mysql.jdbc.JDBC4Connection@5622fdf]
DEBUG [main] - ==>  Preparing: select user_ID, login_name,user_name, user_code, user_type, user_active, organization_ID,user_position,password from user where user_ID = ? 
DEBUG [main] - ==> Parameters: 1(Integer)
TRACE [main] - <==    Columns: user_ID, login_name, user_name, user_code, user_type, user_active, organization_ID, user_position, password
TRACE [main] - <==        Row: 1, AS-01, 小明, HJ-009, ADMIN, 1, 0, 销售员, dasfasdfasdfsdf
DEBUG [main] - <==      Total: 1
=============================================================

可以在开启二级缓存时候，手动配置一些属性

Copy
<cache eviction="LRU" flushInterval="100000" size="1024" readOnly="true"/>

各个属性意义如下：

eviction：缓存回收策略
- LRU：最少使用原则，移除最长时间不使用的对象
- FIFO：先进先出原则，按照对象进入缓存顺序进行回收
- SOFT：软引用，移除基于垃圾回收器状态和软引用规则的对象
- WEAK：弱引用，更积极的移除移除基于垃圾回收器状态和弱引用规则的对象
flushInterval：刷新时间间隔，单位为毫秒，这里配置的 100 毫秒。如果不配置，那么只有在进行数据库修改操作才会被动刷新缓存区
size：引用额数目，代表缓存最多可以存储的对象个数
readOnly：是否只读，如果为 true，则所有相同的 sql 语句返回的是同一个对象（有助于提高性能，但并发操作同一条数据时，可能不安全），如果设置为 false，则相同的 sql，后面访问的是 cache 的 clone 副本。

可以在 Mapper 的具体方法下设置对二级缓存的访问意愿：

useCache 配置

如果一条语句每次都需要最新的数据，就意味着每次都需要从数据库中查询数据，可以把这个属性设置为 false，如：

Copy
  <select id="selectAll" resultMap="BaseResultMap" useCache="false">

刷新缓存（就是清空缓存）

二级缓存默认会在 insert、update、delete 操作后刷新缓存，可以手动配置不更新缓存，如下：

Copy
  <update id="updateById" parameterType="User" flushCache="false" />

3、自定义缓存#

自定义缓存对象，该对象必须实现 org.apache.ibatis.cache.Cache 接口，如下：

Copy
import org.apache.ibatis.cache.Cache;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.locks.ReadWriteLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;
/**


Created by Luky on 2017/10/14.
*/
public class BatisCache implements Cache {
private ReadWriteLock lock = new ReentrantReadWriteLock();
private ConcurrentHashMap<Object,Object> cache = new ConcurrentHashMap<Object, Object>();
private String id;
public  BatisCache(){
System.out.println("初始化 -1！");
}


// 必须有该构造函数
public BatisCache(String id){
System.out.println("初始化 -2！");
this.id = id;
}
<span class="hljs-comment">// 获取缓存编号</span>
<span class="hljs-keyword">public</span> String <span class="hljs-title function_">getId</span><span class="hljs-params">()</span> {
    System.out.println(<span class="hljs-string">"得到ID："</span> + id);
    <span class="hljs-keyword">return</span> id;
}

<span class="hljs-comment">//获取缓存对象的大小</span>
<span class="hljs-keyword">public</span> <span class="hljs-type">int</span> <span class="hljs-title function_">getSize</span><span class="hljs-params">()</span> {
    System.out.println(<span class="hljs-string">"获取缓存大小！"</span>);
    <span class="hljs-keyword">return</span> <span class="hljs-number">0</span>;
}
<span class="hljs-comment">// 保存key值缓存对象</span>
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">putObject</span><span class="hljs-params">(Object key, Object value)</span> {
    System.out.println(<span class="hljs-string">"往缓存中添加元素：key="</span> + key+<span class="hljs-string">",value="</span> + value);
    cache.put(key,value);
}

<span class="hljs-comment">//通过KEY</span>
<span class="hljs-keyword">public</span> Object <span class="hljs-title function_">getObject</span><span class="hljs-params">(Object key)</span> {
    System.out.println(<span class="hljs-string">"通过kEY获取值："</span> + key);
    System.out.println(<span class="hljs-string">"OVER"</span>);
    System.out.println(<span class="hljs-string">"======================================================="</span>);
    System.out.println(<span class="hljs-string">"值为："</span> + cache.get(key));
    System.out.println(<span class="hljs-string">"=====================OVER=============================="</span>);
    <span class="hljs-keyword">return</span> cache.get(key);
}

<span class="hljs-comment">// 通过key删除缓存对象</span>
<span class="hljs-keyword">public</span> Object <span class="hljs-title function_">removeObject</span><span class="hljs-params">(Object key)</span> {
    System.out.println(<span class="hljs-string">"移除缓存对象："</span> + key);
    <span class="hljs-keyword">return</span> <span class="hljs-literal">null</span>;
}

<span class="hljs-comment">// 清空缓存</span>
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">clear</span><span class="hljs-params">()</span> {
    System.out.println(<span class="hljs-string">"清除缓存！"</span>);
    cache.clear();
}

<span class="hljs-comment">// 获取缓存的读写锁</span>
<span class="hljs-keyword">public</span> ReadWriteLock <span class="hljs-title function_">getReadWriteLock</span><span class="hljs-params">()</span> {
    System.out.println(<span class="hljs-string">"获取锁对象！！！"</span>);
    <span class="hljs-keyword">return</span> lock;
}

}

在 Mapper 文件里配置使用该自定义的缓存对象，如：

Copy
<cache type="com.sanyue.utils.BatisCache"/>

测试如下：

Copy
 public static void main(String[] args) {
    <span class="hljs-type">SqlSessionFactory</span> <span class="hljs-variable">factory</span> <span class="hljs-operator">=</span> SqlSessionFactoryUtil.openSqlSession();

    <span class="hljs-comment">// 获得SqlSession对象</span>
    <span class="hljs-type">SqlSession</span> <span class="hljs-variable">sqlSession</span> <span class="hljs-operator">=</span> factory.openSession();
    <span class="hljs-comment">// 获得dao实体</span>
    <span class="hljs-type">UserMapper</span> <span class="hljs-variable">userMapper</span> <span class="hljs-operator">=</span> sqlSession.getMapper(UserMapper.class);
    <span class="hljs-comment">// 进行两次相同的查询操作</span>
    userMapper.selectByPrimaryKey(<span class="hljs-number">1</span>);
    userMapper.selectByPrimaryKey(<span class="hljs-number">1</span>);
    <span class="hljs-comment">// 注意，当我们使用二级缓存时候，sqlSession需要使用commit时候才会生效</span>
    sqlSession.commit();

    System.out.println(<span class="hljs-string">"\n\n============================================================="</span>);
    <span class="hljs-comment">// 获得一个新的SqlSession 对象</span>
    <span class="hljs-type">SqlSession</span> <span class="hljs-variable">sqlSession1</span> <span class="hljs-operator">=</span> factory.openSession();
    <span class="hljs-comment">// 进行相同的查询操作</span>
    sqlSession1.getMapper(UserMapper.class).selectByPrimaryKey(<span class="hljs-number">1</span>);
    sqlSession1.commit();
}

日志输出如下：

Copy
初始化-2！
得到ID：com.sanyue.dao.UserMapper
获取锁对象！！！
通过kEY获取值：151355725:1423317450:com.sanyue.dao.UserMapper.selectByPrimaryKey:0:2147483647:
        select
    user_ID, login_name,user_name, user_code, user_type, user_active, organization_ID,user_position,password

    <span class="hljs-keyword">from</span> user
    <span class="hljs-keyword">where</span> user_ID = ?
:<span class="hljs-number">1</span>

OVER
值为：null
=====================OVER==============================
获取锁对象！！！
获取锁对象！！！
通过 kEY 获取值：151355725:1423317450:com.sanyue.dao.UserMapper.selectByPrimaryKey:0:2147483647:
select
    user_ID, login_name,user_name, user_code, user_type, user_active, organization_ID,user_position,password

    <span class="hljs-keyword">from</span> user
    <span class="hljs-keyword">where</span> user_ID = ?
:<span class="hljs-number">1</span>

OVER
值为：null
=====================OVER==============================
获取锁对象！！！
获取锁对象！！！
往缓存中添加元素：key=151355725:1423317450:com.sanyue.dao.UserMapper.selectByPrimaryKey:0:2147483647:
select
    user_ID, login_name,user_name, user_code, user_type, user_active, organization_ID,user_position,password

    <span class="hljs-keyword">from</span> user
    <span class="hljs-keyword">where</span> user_ID = ?
:<span class="hljs-number">1</span>,<span class="hljs-keyword">value</span>=[User{userId=<span class="hljs-number">1</span>, loginName=<span class="hljs-string">'AS-01'</span>, password=<span class="hljs-string">'12121212121'</span>, userName=<span class="hljs-string">'小明'</span>, userCode=<span class="hljs-string">'JSD-009'</span>, userType=<span class="hljs-string">'ADMIN'</span>, userActive=<span class="hljs-literal">true</span>, userPosition=<span class="hljs-string">'销售员'</span>}]

获取锁对象！！！
=============================================================
获取锁对象！！！
通过 kEY 获取值：151355725:1423317450:com.sanyue.dao.UserMapper.selectByPrimaryKey:0:2147483647:
select
    user_ID, login_name,user_name, user_code, user_type, user_active, organization_ID,user_position,password

    <span class="hljs-keyword">from</span> user
    <span class="hljs-keyword">where</span> user_ID = ?
:<span class="hljs-number">1</span>

OVER
值为：[User{userId=1, loginName='AS-01', password='12121212121', userName='小明', userCode='JSD-009', userType='ADMIN', userActive=true, userPosition='销售员'}]
=====================OVER==============================
获取锁对象！！！

可以看出，每次查询数据库前，MyBatis 都会先在缓存中查找是否有该缓存对象。只有当调用了 commit() 方法，MyBatis 才会往缓存中写入数据，数据记录的键为 数字编号+Mapper名+方法名+SQL语句+参数 格式，值为返回的对象值。

MyBatis 一、二级缓存和自定义缓存

1、一级缓存#

2、二级缓存#

3、自定义缓存#

OVER

OVER

OVER

相关帖子

随便看看

MyBatis 一、二级缓存和自定义缓存