MyBatis——MyBatis的缓存

MyBatis的缓存

创建工程：

1缓存介绍

为什么使用缓存？

首次访问时，查询数据库，并将数据存储到内存中；再次访问时直接访问缓存，减少IO、硬盘读写次数、提高效率
Mybatis中的一级缓存和二级缓存？
- 一级缓存:
  
  它指的是mybatis中的SqlSession对象的缓存。当我们执行完查询之后，查询的结果会同时存在在SqlSession为我们提供的一块区域中。当我们再次查询同样的数据，mybatis会先去SqlSession中查询是否有，有的话直接拿出来使用。当SqlSession对象消失时，Mybatis的一级缓存也就消失了。
- 二级缓存：
  
  它指的是Mybatis中SqlSessionFactory对象的缓存，由同一个SqlSessioFactory对象创建的SqlSession共享其缓存。

2.一级缓存

2.1.mapper

public interface UserDao {//根据id查询用户信息public User findUserById(Integer id);
}

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapperPUBLIC "-//mybatis.org//DTD Mapper 3.0//EN""http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.wt.dao.UserDao"><select id="findUserById" resultType="User" parameterType="int">select * from user where id=#{id}</select>
</mapper>

2.2.测试一级缓存

package com.wt.test;import com.wt.dao.UserDao;
import com.wt.pojo.User;
import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;import java.io.IOException;
import java.io.InputStream;public class MyBatisFirstTest {private SqlSessionFactory sessionFactory;private SqlSession sqlSession;private InputStream inputStream;@Beforepublic void init() throws IOException{//加载配置文件String resource = "mybatis-config.xml";inputStream = Resources.getResourceAsStream(resource);//创建sqlSessionFactorysessionFactory = new SqlSessionFactoryBuilder().build(inputStream);//获得数据的会话实例sqlSession = sessionFactory.openSession();}/*** 一级缓存* 一级缓存默认开启* 使用相同的sqlSession* 使用缓存*/@Testpublic void testGoCaChe(){//返回接口的代理类SqlSession sqlSession1 = sessionFactory.openSession();UserDao userDao1 = sqlSession1.getMapper(UserDao.class);UserDao userDao2 = sqlSession1.getMapper(UserDao.class);System.out.println("==========第一次查询==========");User user1 = userDao1.selectUserById(41);System.out.println(user1);                  //执行sql语句，创建缓存到sqlSessionSystem.out.println("==========第二次查询==========");User user2 = userDao2.selectUserById(41);System.out.println(user2);                  //不执行sql语句，使用sqlSession的缓存}@Afterpublic void close() throws  IOException{sqlSession.close();inputStream.close();}
}

2.3.一级缓存的分析

一级缓存是SqlSession范围的缓存，当调用SqlSession的commit()，close()等方法时，就会清空一级缓存。

在这里插入图片描述

第一次发起查询用户id为 1 的用户信息，先去找缓存中是否有id为 1 的用户信息，如果没有，从数据库查询用户信息。得到用户信息，将用户信息存储到一级缓存中。
如果sqlSession去执行 commit操作（执行插入、更新、删除），清空 SqlSession 中的一级缓存，这样做的目的为了让缓存中存储的是最新的信息，避免脏读。
第二次发起查询用户id为1的用户信息，先去找缓存中是否有id为1的用户信息，缓存中有，直接从缓存中获取用户信息。

2.4.测试清空一级缓存

	/*** 一级缓存* 一级缓存默认开启* 使用不同的sqlSession* 不使用缓存*/@Testpublic void testNoGoCaChe(){//返回接口的代理类SqlSession sqlSession1 = sessionFactory.openSession();SqlSession sqlSession2 = sessionFactory.openSession();UserDao userDao1 = sqlSession1.getMapper(UserDao.class);UserDao userDao2 = sqlSession2.getMapper(UserDao.class);System.out.println("==========第一次查询==========");User user1 = userDao1.selectUserById(41);System.out.println(user1);                  //执行sql语句，创建缓存到sqlSession1System.out.println("==========第二次查询==========");User user2 = userDao2.selectUserById(41);System.out.println(user2);                  //执行sql语句，创建缓存到sqlSession2}/*** 一级缓存* 一级缓存默认开启* 使用相同的sqlSession* 在两次查询之间插入增删改操作（提交）* 不使用缓存*/@Testpublic void testNoGoCaChe2(){//返回接口的代理类SqlSession sqlSession = sessionFactory.openSession();UserDao userDao1 = sqlSession.getMapper(UserDao.class);UserDao userDao2 = sqlSession.getMapper(UserDao.class);System.out.println("==========第一次查询==========");User user1 = userDao1.selectUserById(41);System.out.println(user1);                  //执行sql语句，创建缓存到sqlSessionSystem.out.println("==========两次查询之间插入增删改操作==========");userDao1.deleteUserById(1);sqlSession.commit();                        //执行增删改操作并提交，清空sqlSession缓存System.out.println("==========第二次查询==========");User user2 = userDao2.selectUserById(41);System.out.println(user2);                  //执行sql语句，重新创建缓存到sqlSession}

3.二级缓存

3.1.pojo

注意：当我们在使用二级缓存时，所缓存的类一定要实现java.io.Serializable接口，这种就可以使用序列化方式来保存对象。

public class User implements Serializable {private Integer id;private String username;private String password;private Date birthday;private String sex;private String address;//set get... ...
}

3.2.开启二级缓存

在SqlMapConfig.xml 文件开启二级缓存

<settings><!-- 开启二级缓存的支持，默认值为true，所以可以省略 --><setting name="cacheEnabled" value="true"/>
</settings>

配置相关的Mapper映射文件

<mapper namespace="com.by.dao.UserDao"><!-- 开启二级缓存的支持 --><cache></cache>

3.3.测试二级缓存

package com.wt.test;import com.wt.dao.UserDao;
import com.wt.pojo.User;
import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;import java.io.IOException;
import java.io.InputStream;public class MyBatisSecondTest {private SqlSessionFactory sessionFactory;private SqlSession sqlSession;private InputStream inputStream;@Beforepublic void init() throws IOException{//加载配置文件String resource = "mybatis-config.xml";inputStream = Resources.getResourceAsStream(resource);//创建sqlSessionFactorysessionFactory = new SqlSessionFactoryBuilder().build(inputStream);//获得数据的会话实例sqlSession = sessionFactory.openSession();}/*** 二级缓存* 前提：开启二级缓存，二级缓存默认不开启* 使用相同的sqlSessionFactory* 使用缓存**/@Testpublic void testGoCaChe(){//返回接口的代理类SqlSession sqlSession1 = sessionFactory.openSession();SqlSession sqlSession2 = sessionFactory.openSession();UserDao userDao1 = sqlSession1.getMapper(UserDao.class);UserDao userDao2 = sqlSession2.getMapper(UserDao.class);System.out.println("==========第一次查询==========");User user1 = userDao1.selectUserById(41);System.out.println(user1);                  //执行sql语句，创建缓存到sqlSessionsqlSession1.commit();                       //提交，将一级缓存（sqlSession）存入到二级缓存（sqlSessionFactory）中System.out.println("==========第二次查询==========");User user2 = userDao2.selectUserById(41);System.out.println(user2);                  //不执行sql语句，使用sqlSessionFactory的二级缓存}@Afterpublic void close() throws  IOException{sqlSession.close();inputStream.close();}
}

3.4.二级缓存分析

二级缓存是mapper映射级别的缓存，多个SqlSession去操作同一个Mapper映射的sql语句，多个SqlSession可以共用二级缓存，二级缓存是跨SqlSession的。

二级缓存结构图:

3.5.测试清空二级缓存

    /*** 二级缓存* 前提：开启二级缓存，二级缓存默认不开启* 使用不同的sqlSessionFactory* 不使用缓存*/@Testpublic void testNoGoCaChe() throws IOException {//加载配置文件String resource1 = "mybatis-config.xml";InputStream inputStream1 = Resources.getResourceAsStream(resource1);//创建sqlSessionFactorySqlSessionFactory sessionFactory1 = new SqlSessionFactoryBuilder().build(inputStream1);//返回接口的代理类SqlSession sqlSession1 = sessionFactory1.openSession();//加载配置文件String resource2 = "mybatis-config.xml";InputStream inputStream2 = Resources.getResourceAsStream(resource2);//创建sqlSessionFactorySqlSessionFactory sessionFactory2 = new SqlSessionFactoryBuilder().build(inputStream2);SqlSession sqlSession2 = sessionFactory2.openSession();UserDao userDao1 = sqlSession1.getMapper(UserDao.class);UserDao userDao2 = sqlSession2.getMapper(UserDao.class);System.out.println("==========第一次查询==========");User user1 = userDao1.selectUserById(41);System.out.println(user1);                  //执行sql语句，创建缓存到sqlSession1sqlSession1.commit();                       //提交，将一级缓存（sqlSession1）存入到二级缓存（sqlSessionFactory1）中System.out.println("==========第二次查询==========");User user2 = userDao2.selectUserById(41);System.out.println(user2);                  //执行sql语句，创建缓存到sqlSession2sqlSession2.commit();                       //提交，将一级缓存（sqlSession2）存入到二级缓存（sqlSessionFactory2）中}/*** 二级缓存* 前提：开启二级缓存，二级缓存默认不开启* 使用相同的sqlSessionFactory* 在两次查询之间插入增删改操作（提交）* 不使用缓存*/@Testpublic void testNoGoCaChe2(){//返回接口的代理类SqlSession sqlSession1 = sessionFactory.openSession();SqlSession sqlSession2 = sessionFactory.openSession();UserDao userDao1 = sqlSession1.getMapper(UserDao.class);UserDao userDao2 = sqlSession2.getMapper(UserDao.class);System.out.println("==========第一次查询==========");User user1 = userDao1.selectUserById(41);System.out.println(user1);                  //执行sql语句，创建缓存到sqlSession1sqlSession1.commit();                       //提交，将一级缓存（sqlSession1）存入到二级缓存（sqlSessionFactory）中System.out.println("==========两次查询之间插入增删改操作==========");userDao1.deleteUserById(1);sqlSession1.commit();                        //执行增删改操作并提交，清空sqlSession1的一级缓存和sqlSessionFactory的二级缓存System.out.println("==========第二次查询==========");User user2 = userDao2.selectUserById(41);System.out.println(user2);                  //执行sql语句，创建缓存到sqlSession2sqlSession2.commit();                       //提交，将一级缓存（sqlSession2）存入到二级缓存（sqlSessionFactory）中}