Mybatis延迟加载和缓存深入讲解

更新时间：2019年02月11日 09:58:27 作者：风沙迷了眼

这篇文章主要给大家介绍了关于Mybatis延迟加载和缓存的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面来一起学习学习吧

一、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整合之后的测试结果

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家对脚本之家的支持。

您可能感兴趣的文章:

Java多线程中的Exchanger应用简析
这篇文章主要介绍了Java多线程中的Exchanger应用简析,Exchanger提供了一个同步点exchange方法,两个线程调用exchange方法时,无论调用时间先后,两个线程会互相等到线程到达exchange方法调用点,此时两个线程可以交换数据,将本线程产出数据传递给对方,需要的朋友可以参考下
2023-12-12
Java 实现加密数据库连接的步骤
这篇文章主要介绍了Java 实现加密数据库连接的步骤，帮助大家更好的理解和使用Java处理数据库，感兴趣的朋友可以了解下
2020-11-11
Java 异步线程监听与结果回调及异常捕获总结分析
异常是程序之中导致程序中断的一种指令流，异常一旦出现并且没有进行合理处理的话，那么程序就将中断执行，这篇文章综合介绍了异步线程监听与结果回调及异常捕获
2021-11-11
Java thrift服务器和客户端创建实例代码
Thrift是一个软件框架，用来进行可扩展且跨语言的服务的开发。接下来通过本文给大家介绍Java thrift服务器和客户端创建实例代码，需要的朋友参考下吧
2017-04-04
Java源码解析之TypeVariable详解
这篇文章主要介绍了Java源码解析之TypeVariable详解，具有一定参考价值，需要的朋友可以了解下。
2017-10-10
使用Spring Security控制会话的方法
在本文中，我们将说明Spring Security如何允许我们控制HTTP会话。这篇文章主要介绍了使用Spring Security控制会话 ,需要的朋友可以参考下
2019-05-05
springboot发送邮件功能的实现代码
发邮件是一个很常见的功能，在java中实现需要依靠JavaMailSender这个接口，今天通过本文给大家分享springboot发送邮件功能的实现代码，感兴趣的朋友跟随小编一起看看吧
2021-07-07
java中jdk代理和cglib代理使用步骤详解
这篇文章主要给大家介绍了关于java中jdk代理和cglib代理使用步骤的相关资料,JDK代理和CGLIB是Java中两种常见的代理实现方式,文中通过代码介绍的非常详细,需要的朋友可以参考下
2023-11-11
三分钟快速掌握Java中枚举(enum)
enum的全称为enumeration，是 JDK 1.5中引入的新特性，存放在 java.lang包中。下面这篇文章是我在使用enum过程中的一些经验和总结，分享出来方便大家快速的掌握Java中枚举(enum)，有需要的朋友们下面跟着小编来一起看看吧。
2016-12-12
SpringBoot使用Redisson实现分布式锁（秒杀系统）
这篇文章主要为大家详细介绍了SpringBoot使用Redisson实现分布式锁，秒杀系统，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2019-12-12