Mybatis延迟加载和缓存深入讲解
作者:风沙迷了眼 发布时间:2022-06-02 15:50:43
一、Mybatis中的延迟加载
1、延迟加载背景:Mybatis中Mapper配置文件中的resultMap可以实现高级映射(使用association、collection实现一对一及一对多(多对多)映射),同样的association、collection具备延迟加载功能。所谓延迟加载,就是先单表查询,需要时再从关联表去关联查询(同样也可能只是是单表查询),大大单表查询速度更快,所以可以间接的提高数据库性能
2、在mybatis核心配置文件中配置,其中lazyLoadingEnabled表示懒加载开关、aggressiveLazyLoading表示非懒加载(积极加载),通过在Mybatis核心配置文件中配置这些属性的值来使用Mybatis的懒加载,具体配置方式如下:
<settings>
<!--懒加载模式在Mybatis中默认是关闭的-->
<setting name="lazyLoadingEnabled" value="true"/>
<!--不同于懒加载的:积极加载方式,所以在懒加载的时候设置该属性为false-->
<setting name="aggressiveLazyLoading" value="false"></setting>
</settings>
3、由于是使用懒加载,所以我们显然可以将Mapper配置文件中的查询分为两张单表查询的statment,其中User表的查询放在Order查询配置的resultMap中,并进行延迟加载的设置
<select id="findUserByUid" parameterType="int" resultType="cn.mybatis.po.User">
SELECT * FROM USER WHERE uid = #{id}
</select>
<resultMap id="OrderAndUserByLazyLoading" type="cn.mybatis.po.Order">
<id column="oid" property="oid"></id>
<result column="total" property="total"></result>
<result column="ordertime" property="ordertime"></result>
<result column="name" property="name"></result>
<!--
实现延迟加载功能
select:指定延迟加载需要执行的statment的id(即根据用户id查询用户信息的select的statment)
column:关联查询的列信息-->
<association property="user" javaType="cn.mybatis.po.User" select="findUserByUid" column="uid">
</association>
</resultMap>
<select id="findOrderAndUserByLazyLoading" resultMap="OrderAndUserByLazyLoading">
SELECT * FROM orders
</select>
LazyLoading配置文件信息
4、在Mapper.java中添加了延迟加载的测试方法
//延迟加载测试方法
public List<Order> findOrderAndUserByLazyLoading() throws Exception;
5、使用Junit测试延迟加载的测试代码
@Test
public void testFindOrderAndUserByLazyLoading() throws Exception {
SqlSession sqlSession = sqlSessionFactory.openSession();
OrderMapper orderMapper = sqlSession.getMapper(OrderMapper.class);
List<Order> orderList= orderMapper.findOrderAndUserByLazyLoading();
for (Order order : orderList) {
System.out.println(order.getUser());
}
sqlSession.close();
}
6、测试结果,从测试结果可以看出,我们首先只是单表查询了order是表的信息,然后在遍历查询到的结果(打印User信息)的时候,又发出查询user信息的Sql,从而实现了延迟加载的功能
二、Mybatis中的一级缓存
1、一级缓存是在SqlSession 层面进行缓存的。即在同一个SqlSession 中,多次调用同一个Mapper中的同一个statment并且是同一个参数的话,只会进行一次数据库查询,然后把数据缓存到缓冲中,如果以后要查询相同的Sql和参数,就直接先从缓存中取出数据,不会直接去查数据库。 但是不同的SqlSession对象,因为不用的SqlSession都是相互隔离的,所以相同的Mapper、参数和方法,他还是会再次发送到SQL到数据库去执行,返回结果。(本质上是在SqlSession作用域下面的HashMap本地缓存,当 SqlSession 刷新或关闭之后,该Session中的所有 缓存数据就将清空。)可以用下面的这张图来表示一级缓存
2、我们来使用一级缓存进行测试,首先通过上面一级缓存的简单定义,我们可以得到下面的这张简略图,用以示解一级缓存。在实例图中,第一次查询某条记录时候,Mybatis所做的就是将查询到的结果放在该SqlSession的缓存中,如果期间没有该数据的修改、删除、或者增加操作,那么之后再读取该数据就会直接从缓存中得到数据,而不用再向数据库发Sql请求,当然,如果第一次查询之后,对数据进行了delete、update、insert操作,那么就会删除缓存中的数据,这样做的目的也很显然,保证数据的最新性,避免出现脏读的情况。
3、一级缓存的测试(Mybatis中默认开启的是一级缓存)
做个简单的测试:按照上面的图中所示,我们查询两次id=1的User信息,并且两次查询期间没有进行会清空缓存的操作,结果应该是只向数据库发送一次Sql查询
@Test
public void testUpdateUserInfo() throws Exception {
SqlSession sqlSession = sqlSessionFactory.openSession();
UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
User user1 = userMapper.findUserById(1);
System.out.println(user1);
User user2 = userMapper.findUserById(1);
System.out.println(user2);
sqlSession.close();
}
4、我们通过观察日志可以看出,只是在第一次查询的时候发送了Sql,第二次是直接打印user信息
当然,接下来要做的测试就是在两次查询期间做insert操作,然后观察日志,结果应该是发现会想数据库发送两次sql
@Test
public void testUpdateUserInfo() throws Exception {
SqlSession sqlSession = sqlSessionFactory.openSession();
UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
User user1 = userMapper.findUserById(1);
System.out.println(user1);
User user = new User("InsertTest","insert","insert","man");
userMapper.insertUserInfo(user);
sqlSession.commit();
User user2 = userMapper.findUserById(1);
System.out.println(user2);
sqlSession.close();
}
5、我们在测试代码中加了insert之后,通过观察日志可以发现,在查询过程中,向Database发送了两条select语句,可以验证上面的猜想
三、Mybatis中的二级缓存
1、二级缓存的实现机制基本上和一级缓存机制相同,不同的作用域不一样,二级缓存区域在一个个的mapper中。显然,由于多个SqlSession可以操作同一个mapper,所以二级缓存比一级缓存域更大。二级缓存按照mapper划分,简而言之,也可说成按照mapper中的namespace进行划分,这样看来,每一个namespace下面都有一个二级缓存区域,而如果两个mapper的namespace相同,那么数据会缓存在相同的缓存区域中。当然,类似于一级缓存的特点,如果不同的SqlSession进行数据的insert、delete、update操作的话,也会清空二级缓存中的数据
2、开启二级缓存后,进行测试。具体使用二级缓存在配置文件中的配置为:
首先在Mybatis的核心配置文件中配置二级缓存(本项目中的SQLMapConfig.xml)
<!--settings配置二级缓存 -->
<settings>
<setting name="cacheEnabled" value="true"></setting>
</settings>
然后在需要配置二级缓存的特定mapper配置文件中进行添加二级缓存的配置
3、编写测试程序并运行
@Test
public void testCache() throws Exception {
SqlSession sqlSession1 = sqlSessionFactory.openSession();
UserMapper userMapper1 = sqlSession1.getMapper(UserMapper.class);
User user1 = userMapper1.findUserById(1);
System.out.println(user1);
//需要将SqlSession关闭才能将数据写入缓存
sqlSession1.close();
SqlSession sqlSession2 = sqlSessionFactory.openSession();
UserMapper userMapper2 = sqlSession2.getMapper(UserMapper.class);
User user2 = userMapper2.findUserById(1);
System.out.println(user2);
sqlSession2.close();
}
在运行的时候出现了下面的异常,原因就是没有实现序列化接口,由于缓存数据可能再本地内存中,也可能在其他存储介质上,所以存在对象的序列化和反序列化
所以在实现序列化接口之后,再次运行,得到下面的结果
四、Mybatis和ehcache整合
1、首先说明ehcache是一个分布式的缓存框架,而使用Mybatis和ehcache进行整合的时候,首先就需要导入ehcache的jar包和mybatis与ehcache整合的jar包,如下图所示
2、下面是mybatis-ehcache整合jar包中的Cache接口实现类
3、然后我们在Mapper配置文件中配置二级缓存
<!--关于cache标签的一些属性说明:
type:指定Mybatis中默认实现的cache接口的实现类类型,Mybatis中默认使用PerpetualCache
如果和ehcache整合,需要将type配置为ehcache实现cache的实现类类型
-->
<cache type="org.mybatis.caches.ehcache.EhcacheCache"/>
4、下面是mybatis和ehcache整合之后的测试结果
来源:https://www.cnblogs.com/fsmly/p/10343184.html
猜你喜欢
- 一、场景描述仪器数据文件的格式包含Pdf、Word、Excel等多种,不同种格式的文件其数据的采集方式不同,因此定义仪器数据采集接口,并定义
- 一、引入pom<?xml version="1.0" encoding="UTF-8"?>
- 最近看spring的JDBCTemplete的模板方式调用时,对模板和回调产生了浓厚兴趣,查询了一些资料,做一些总结。回调函数:所谓回调,就
- 本文实例为大家分享了java实现2048小游戏的具体代码,供大家参考,具体内容如下效果图:游戏介绍:1.2048是一款益智类小游戏,刚开始随
- 这篇文章主要介绍了java加载property文件配置过程解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,
- 前言 因为自己在做的一个小软件里面需要用到从A-Z排序的ListView,所以自然而然的想到了微信的联系人,我想要的就是那样的效果。本来没
- Linux Hadoop 2.7.3 安装搭建Hadoop实现了一个分布式文件系统(Hadoop Distributed File Syst
- 创建新的项目的时候,文件名一直追加,不分层对于刚用idea的小白,这个问题困扰了我好几天了,幸好现在还不怎么敲代码,下面给一个详细的解决方案
- 阅读提示 具有mybatis基础,熟练使用mybatis-plus。概述 我们都知道,mybatis-plus是一个mybatis的增强
- 问题:写了一个新的dao接口,进行单元测试时提示:Initialization of bean failed; nested excepti
- 单例模式动机有时候只有一个类的实例是很重要的。比如,一个系统应该只有一个窗口管理实例。单例模式是最简单设计模式:类负责实例化自己,确保只有一
- 第一种方式:使用@Param注解方式此种方式用法是我们在接口中写方法的参数时,在每个参数的前面加上一个@Param注解即可。该注解有一个va
- git仓库直达List<String> strings = Lists.newArrayList("name=kk&q
- 一、基本介绍(Nexus(maven * ))1,如果没有搭建 * 会有什么问题?如果没有 * ,我们所需的所有构件都需要通过 Mave
- 编写程序,利用continue语句实现循环体过滤器,过滤“老鹰”字符串,并做相应的处理,但是放弃continue语句之后的所有代码。即若遇到
- 当你使用synchronized关键字的时候,是通过互斥器来保障线程安全以及对共享资源的同步访问。线程间也经常需要更进一步的协调
- 本文实例讲述了Java日期操作方法工具类。分享给大家供大家参考,具体如下:package com.gcloud.common;import
- Java.util.Collections类下有一个静态的shuffle()方法,如下:1)static void shuffle(List
- 1. 最小生成树连通图中的每一棵生成树 , 都是原图的极大无环子图 , 即: 从中删去任何一条边 , 生成树就不再连通;反之 , 在其中引入
- SpringMVC @RequestBody自动转json Http415错误项目中想用@RequestBody直接接收json串转成对象网