Mybatis引出的一系列问题-Mybatis缓存机制的探究

news2024/11/20 8:28:07

Mybatis 使用到了两种缓存:本地缓存(local cache)和二级缓存(second level cache)。

一级缓存默认是开启的,而且不能关闭,MyBatis的一些关键特性(例如通过<association><collection>建立级联映射、避免循环引用(circular references)、加速重复嵌套查询等)都是基于MyBatis一级缓存实现的,而且MyBatis结果集映射相关代码重度依赖CacheKey,所以目前MyBatis不支持关闭一级缓存。

虽然我们不能关闭一级缓存,但是我们可以更改他的作用范围: MyBatis提供了一个配置参数localCacheScope,用于控制一级缓存的级别,该参数的取值为SESSIONSTATEMENT当指定localCacheScope参数值为SESSION时,缓存对整个SqlSession有效,只有执行DML语句(更新语句)时,缓存才会被清除当localCacheScope值为STATEMENT时,缓存仅对当前执行的语句有效,当语句执行完毕后,缓存就会被清空

<settings>
  <setting name="localCacheScope" value="STATEMENT"/>
</settings>

能更改一级缓存的作用范围这一点很重要后面我们讲解中会用到这一特性。

一级缓存默认是SqlSession级别的: 在操作数据库时需要构造 sqlSession 对象,在对象中有一个(内存区域)数据结构(HashMap)用于存储缓存数据。不同的 sqlSession 之间的缓存数据区域(HashMap)是互相不影响的。用一张图来表示一下一级缓存,其中每一个 SqlSession 的内部都会有一个一级缓存对象。
在这里插入图片描述
1、一级缓存同一个会话共享数据 模拟思路:打开一个会话,进行两次查询通过日志查看第二次是否走数据库。

  @Test
   public void testSession() throws IOException {
       try (SqlSession sqlSession = sqlSessionFactory.openSession()) {
           OrderMapper orderMapper = sqlSession.getMapper(OrderMapper.class);
           List<Order> orders = orderMapper.queryById(620898339119480832L);
           System.out.println("第一次查询:" + JSON.toJSONString(orders));
           OrderMapper orderMapper2 = sqlSession.getMapper(OrderMapper.class);
           List<Order> orders2 = orderMapper2.queryById(620898339119480832L);
           System.out.println("第二次查询:" + JSON.toJSONString(orders2));
      }
  }

在这里插入图片描述
分析:第一次查询打印了 sql 日志信息,说明是通过数据库获取到数据,第二次也查询到数据但是没有打印日志信息,说明走了缓存。
结论:一级缓存同一个会话共享数据。

2、同一个会话如果有更新操作则缓存清除 模拟思路:打开一个会话,先进行查询,然后进行更新操作,最后再次查询刚才的语句,看是否打印查询数据库的 sql 日志(这些操作都是对一条数据的操作)。

@Test
public void testUpdate() throws IOException {
  try (SqlSession sqlSession = sqlSessionFactory.openSession()) {
      // 同一个会话 第一次查询
      System.out.println("第一次会会话的 第一次查询");
      OrderMapper orderMapper = sqlSession.getMapper(OrderMapper.class);
      List<Order> orders = orderMapper.queryById(620898339119480832L);
      Order order = orders.get(0);
      order.setAmount(12L);
      // 进行更新
      orderMapper.updateByPrimaryKey(order);
      // 同一个会话 第二次查询
      System.out.println("第一次会会话的 第二次查询");
      List<Order> orders2 = orderMapper.queryById(620898339119480832L);
      System.out.println(JSON.toJSONString(orders2));
  }
}

在这里插入图片描述
分析:第一次查询打印了 sql 日志,然后进行数据更新,最后进行第二次查询发现仍旧查询数据库,说明缓存已经失效。
结论:同一个会话如果有更新操作则缓存清除。

3、导致脏数据 模拟思路:打开两个会话,第一个会话查询数据库获取数据后 ,接着第二个会话修改数据,最后第一个会话再查询数据,那最后这次查询如果和第一次查询相同,那说明一级缓存会导致脏数据问题。

@Test
   public void testDirtyData() throws IOException {
       SqlSession sqlSession1 = sqlSessionFactory.openSession(true);
       SqlSession sqlSession2 = sqlSessionFactory.openSession(true);
       try {
           // 同一个会话 第一次查询
           OrderMapper orderMapper1 = sqlSession1.getMapper(OrderMapper.class);
           OrderMapper orderMapper2 = sqlSession2.getMapper(OrderMapper.class);
           List<Order> orders = orderMapper1.queryById(620898339119480832L);
           System.out.println("第一次会会话第一次查询的结果" + orders);
           Order order1 = getOrder(orders);
           System.out.println("=========更新数据======");
           orderMapper2.updateByPrimaryKey(order1);
           sqlSession2.commit();
           List<Order> orders1 =  orderMapper1.queryById(620898339119480832L);
           System.out.println("第二次查询:"+JSON.toJSONString(orders1));
 
      }catch (Exception e){
           sqlSession1.close();
           sqlSession2.close();
      }
  }

在这里插入图片描述
分析:第一个会话第一次查询 amount 值是1212,第二会话将 amount 更改为666,第一个会话再次查询数据获取的 amount 值为1212,这说明第一个会话的第二次查询命中缓存导致了脏数据问题。
结论:一级缓存在多会话中会导致脏数据。
解决方式:在配置一级缓存作用范围的时候将其设置为 STATEMENT,那么缓存仅对当前执行的语句有效,当语句执行完毕后,缓存就会被清空。

<settings>
  <setting name="localCacheScope" value="STATEMENT"/>
</settings>

你可以随时调用以下方法来清空本地缓存:

void clearCache()

二级缓存: 二级缓存的原理和一级缓存原理一样,第一次查询,会将数据放入缓存中,然后第二次查询则会直接去缓存中取。但是一级缓存是基于sqlSession的,而二级缓存是基于mapper文件的namespace的,也就是说多个sqlSession可以共享一个mapper中的二级缓存区域,并且如果两个mapper的namespace 相同,即使是两个mapper,那么这两个mapper中执行sql查询到的数据也将存在相同的二级缓存区域中。
在这里插入图片描述
和一级缓存默认开启不一样,二级缓存需要我们手动开启首先在全局配置文件sqlMapConfig.xml文件中加入如下代码:

<!--开启二级缓存-->

<settings>
 	<setting name="cacheEnabled" value="true"/>
</settings>

其次在UserMapper.xml文件中开启缓存(如果我们是基于注解形式进行查询,可以在mapper查询接口上添加@CacheNamespace注解开启二级缓存)

方式一:在xml文件中配置
<!--开启二级缓存-->
<cache></cache>

方式二:在mapper接口上添加上
@CacheNamespace
后面可以带参数指定加载自定义的缓存实现类
@CacheNamespace(implementation = RedisCache.class)//开启二级缓存

我们可以看到mapper.xml文件中就这么一个空标签,其实这里可以配置,PerpetualCache这个类是mybatis默认实现缓存功能的类。我们不写type就使用mybatis默认的缓存,也可以去实现Cache接口来自定义缓存。
在这里插入图片描述

public class PerpetualCache implements Cache {
    private final String id;
    private MapcObject, Object> cache = new HashMapC);
    public PerpetualCache(St ring id) { this.id = id;
}

我们可以看到二级缓存底层还是HashMap结构。

public class User implements Serializable(
    //⽤户ID
    private int id;
    //⽤户姓名
    private String username;
    //⽤户性别
    private String sex;
}

注意:开启了二级缓存后,还需要将要缓存的pojo实现Serializable接口,为了将缓存数据取出执行反序列化操作,因为二级缓存数据存储介质多种多样,不一定只存在内存中,有可能存在硬盘中,如果我们要再取这个缓存的话,就需要反序列化了。所以mybatis中的pojo都去实现Serializable接口

测试⼆级缓存和sqlSession无关,可以看出下面两个不同的sqlSession,第一个关闭了,第二次查询依然不发出sql查询语句。

@Test
public void testTwoCache(){
    //根据 sqlSessionFactory 产⽣ session
    SqlSession sqlSession1 = sessionFactory.openSession();
    SqlSession sqlSession2 = sessionFactory.openSession();
    UserMapper userMapper1 = sqlSession1.getMapper(UserMapper. class );
    UserMapper userMapper2 = sqlSession2.getMapper(UserMapper. class );
    //第⼀次查询,发出sql语句,并将查询的结果放⼊缓存中
    User u1 = userMapper1.selectUserByUserId(1);
    System.out.println(u1);
    sqlSession1.close(); //第⼀次查询完后关闭 sqlSession ,sqlsession关闭后就会清除一级缓存
    //第⼆次查询,即使sqlSession1已经关闭了,这次查询依然不发出sql语句
    User u2 = userMapper2.selectUserByUserId(1);
    System.out.println(u2);
    sqlSession2.close();
}

测试执行commit()操作,二级缓存数据清空

@Test
public void testTwoCache(){
    //根据 sqlSessionFactory 产⽣ session
    SqlSession sqlSession1 = sessionFactory.openSession();
    SqlSession sqlSession2 = sessionFactory.openSession();
    SqlSession sqlSession3 = sessionFactory.openSession();
    String statement = "com.lagou.pojo.UserMapper.selectUserByUserld" ;
    UserMapper userMapper1 = sqlSession1.getMapper(UserMapper. class );
    UserMapper userMapper2 = sqlSession2.getMapper(UserMapper. class );
    UserMapper userMapper3 = sqlSession2.getMapper(UserMapper. class );
    
    //第⼀次查询,发出sql语句,并将查询的结果放⼊缓存中
    User u1 = userMapperl.selectUserByUserId( 1 );
    System.out.println(u1);
    sqlSessionl .close(); //第⼀次查询完后关闭sqlSession
    
    //执⾏更新操作,commit()
    u1.setUsername( "aaa" );
    userMapper3.updateUserByUserId(u1);
    sqlSession3.commit();
 
    //第⼆次查询,由于上次更新操作,缓存数据已经清空(防⽌数据脏读),这⾥必须再次发出sql语
    User u2 = userMapper2.selectUserByUserId( 1 );
    System.out.println(u2);
    sqlSession2.close();
}

在这里插入图片描述
mybatis中还可以配置userCacheflushCache等配置项,userCache是用来设置是否禁用二级缓存的,在statement中设置useCache=false可以禁⽤当前select语句的二级缓存,即每次查询都会发出sql去查询,默认情况是true,即该sql使用二级缓存,还可以使用注解方式禁用@Options(useCache=false),flushCache的注解配置方法同上 。

方法一:
<select id="selectUserByUserId" useCache="false" resultType="com.lagou.pojo.User" parameterType="int">
     select * from user where id=#{id}
</select> 

方法二:
@Options(useCache = false)
@Select({"select * from user where id = #{id}"})
public User findUserById(Integer id);

这种情况是针对每次查询都需要最新的数据sql,要设置成useCache=false,禁用二级缓存,直接从数据库中获取。

在mapper的同一个namespace中,如果有其它insert、update, delete操作数据后需要刷新缓存,如果不执行刷新缓存会出现脏读。

设置statement配置中的flushCache="true”属性,默认情况下为true,即刷新缓存,如果改成false则 不会刷新。使用缓存时如果手动修改数据库表中的查询数据会出现脏读。

一般下执行完commit操作都需要刷新缓存,flushCache=true表示刷新缓存,这样可以避免数据库脏读。所以我们不用设置,默认即可。

一个会话查询一条数据,这个数据就会被放在当前会话的一级缓存中,如果当前会话关闭了,这个会话对应的一级缓存就没了;但是我们想要的是,会话关闭了,一级缓存中的数据被保存到二级缓存中,新的会话查询信息,就可以从二级缓存中获取内容,同的mapper查出的数据会放在自己对应的缓存(map)中。

  1. 只要开启了二级缓存,我们在同一个Mapper【namespace】中的查询,可以在二级缓存中拿到数据
  2. 查出的数据都会被默认先放在一级缓存中
  3. 只有会话提交或者关闭以后,一级缓存中的数据才会转到二级缓存中

缓存原理:

  1. 用户先查二级缓存
  2. 再查询一级缓存
  3. 最后查询数据库

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/830484.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

亚马逊采集淘宝(实现跨平台电商商品同步)

跨平台电商已成为当前电商行业的发展趋势&#xff0c;亚马逊作为全球的电商平台之一&#xff0c;为了更好地服务消费者&#xff0c;近期开始采集淘宝商品&#xff0c;并实现同步。 1. 亚马逊采集淘宝商品的背景 近年来&#xff0c;随着全球电商市场的不断扩大&#xff0c;跨平…

aspose-words、itextpdf完美解决java将word、excel、ppt、图片转换为pdf文件

我是傲骄鹿先生&#xff0c;沉淀、学习、分享、成长。 如果你觉得文章内容还可以的话&#xff0c;希望不吝您的「一键三连」&#xff0c;文章里面有不足的地方希望各位在评论区补充疑惑、见解以及面试中遇到的奇葩问法 面对日常开发过程中&#xff0c;将各种文件转换为pdf文件的…

MQ(一)-MQ理论与消息中间件简介

MQ理论 队列&#xff0c;是一种FIFO 先进先出的数据结构。消息&#xff1a;在不同应用程序之间传递的数据。将消息以队列的形式存储起来&#xff0c;并且在不同的应用程序之间进行传递&#xff0c;这就成了MessageQueue。MQ通常三大作用&#xff1a; 异步、解耦、限流 Spring…

【k8s】二进制部署k8s

二进制部署k8s 1.操作系统初始化配置2.部署etcd集群3.部署docker引擎4.部署Master组件4.部署 Worker Node 组件 二进制搭建 Kubernetes v1.20 k8s集群master01&#xff1a;192.168.80.10 kube-apiserver kube-controller-manager kube-scheduler etcd k8s集群master02&#xf…

前端实现打印1 - 使用 iframe 实现 并 分页打印

目录 打印代码对话框预览打印预览 打印代码 <!-- 打印 --> <template><el-dialogtitle"打印":visible.sync"dialogVisible"width"50%"top"7vh"append-to-bodyclose"handleClose"><div ref"print…

京东API分享:获取京东商品评论接口

接口名称&#xff1a;item_review-获得JD商品评论 接口背景介绍&#xff1a; 京东是一家中国知名的综合性电商平台&#xff0c;成立于1998年。作为中国最大的B2C在线零售商之一&#xff0c;京东提供了包括电子产品、家居用品、服装配饰、食品饮料等在内的广泛商品选择。为了…

防抖函数,定时的清除

什么是防抖函数 在某一个时间段内&#xff0c;一个函数频繁快速的调用&#xff0c;只执行最后一次的调用。 防抖函数实际应用场景 我们在执行一个数据搜索功能时&#xff0c;通过监听input框的值&#xff0c;值变化触发搜索&#xff0c; 如果我们在输入框输入"zhangsa…

使用 Simulink 进行 STM32 编程

目录 介绍 所需材料 步骤 1&#xff1a;在MATLAB中设置STM32-MAT软件路径步骤 2&#xff1a;在STM32CubeMX中创建一个项目步骤 3&#xff1a;配置时钟和 GPIO 引脚步骤 4&#xff1a;项目经理并生成代码步骤 5&#xff1a;在 Simulink 中创建模型步骤 6&#xff1a;在模型中插…

前端如何实现一个网站的桌面快捷方式

题记&#xff1a;我们工作中常常需要在我们的网站首页实现一个桌面快捷方式&#xff0c;那么我们怎么做呢&#xff1f; 图片展示&#xff1a; 代码实现&#xff1a; 第一步&#xff1a;获取路径与标题名&#xff1b; sName: document.title, sUrl: window.location.href 第二步…

Java版知识付费平台免费搭建 Spring Cloud+Spring Boot+Mybatis+uniapp+前后端分离实现知识付费平台qt

&#xfeff;Java版知识付费源码 Spring CloudSpring BootMybatisuniapp前后端分离实现知识付费平台 提供职业教育、企业培训、知识付费系统搭建服务。系统功能包含&#xff1a;录播课、直播课、题库、营销、公司组织架构、员工入职培训等。 提供私有化部署&#xff0c;免费售…

c++11 标准模板(STL)(std::basic_ofstream)(一)

定义于头文件 <fstream> template< class CharT, class Traits std::char_traits<CharT> > class basic_ifstream : public std::basic_istream<CharT, Traits> 类模板 basic_ifstream 实现文件流上的高层输入操作。它将 std::basic_istrea…

【Selenimu+AutoIT】非input标签上传文件(带参数)

工具下载 非input标签上传文件&#xff0c;就需要借助第三方工具&#xff0c;如AutoIT。 AutoIT下载 安装步骤略 使用 1.打开Auto Window Info 找到这个打开 拖住红框里面的标到需要定位的地方记录下来 2.打开SciTE Script Editor 打开后&#xff0c;修改为UTF-8&am…

程序员有必要参加软考吗?

作为程序员&#xff0c;如果一直从事着前线的编程工作&#xff0c;是否会对身体造成负担&#xff0c;难以持续到35岁呢&#xff1f;毕竟在项目赶期时&#xff0c;工作强度很高&#xff0c;而技术也在不断变化&#xff0c;因此很多程序员在30岁前就开始转型。我曾见过很多焦虑自…

观察者模式——对象间的联动

1、简介 1.1、概述 在软件系统中&#xff0c;有些对象之间也存在类似交通信号灯和汽车之间的关系。一个对象的状态或行为的变化将导致其他对象的状态或行为也发生改变&#xff0c;它们之间将产生联动&#xff0c;正所谓“触一而牵百发”。为了更好地描述对象之间存在的这种一…

【C++】初阶 --- 引用(超级详细版!!!)

文章目录 &#x1f36a;一、引用的概念&#x1f36a;二、引用的特性&#x1f37f;1、引用在定义时必须初始化&#x1f37f;2、一个变量可以有多个引用&#x1f37f;3、引用一旦引用一个实体&#xff0c;再不能引用其他实体 &#x1f36a;三、常引用(被const 修饰的引用)&#x…

idea打开传统eclipse项目

打开传统web项目 1.打开后选择项目文件 2.选择项目结构 3.设置jdk版本 4.导入当前项目模块 5.选择eclipse 6. 设置保存目录 7.右键模块&#xff0c;添加spring和web文件 8. 设置web目录之类的&#xff0c;并且创建打包工具 9.如果有本地lib&#xff0c;添加为库 最后点击应用&…

【linux】Linux桌面应用程序快捷方式

在linux系统里&#xff0c;很多应用程序虽然有对应的版本&#xff0c;但是下载了之后发现打开方式并不友好&#xff0c;比如&#xff0c;今天下载了DataGrip&#xff0c;打开文件夹才发现它里面有这些&#xff1a; 红框内的脚本是其正确的打开方式。每次你都要执行&#xff1a…

一篇文了解SHA2代码签名

在当今数字时代&#xff0c;各种网络隐私安全威胁层出不穷&#xff0c;对此&#xff0c;我们也采取了很多安全措施。SHA2代码签名作为一种非常重要的安全措施&#xff0c;它有助于确保软件代码和文件的完整性和真实性。那么你知道SHA2代码签名是什么&#xff1f;它的原理是什么…

天线辐射机制

电磁场如何从源中产生并最终脱离天线辐射到自由空间中去的呢&#xff1f;让我们首先来研究一下一些基本的辐射源。 1、单线Single Wire 导线是一种电荷运动产生电流特性的材料&#xff0c;假设用qv&#xff08;库仑/m3&#xff09;表示的一个电体积电荷密度均匀分布在一个横截…

云安全攻防(五)之 容器基础设施所面临的风险

容器基础设施所面临的风险 容器基础设施面临的风险 我们从容器镜像、活动容器、容器网络、容器管理程序接口、宿主机操作和软件漏洞六个方面来分析容器基础设施可能面临的风险 容器镜像存在的风险 所有容器都来自容器镜像。与虚拟机镜像不同的是&#xff0c;容器镜像是一个不…