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 mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.by.dao.UserDao">
    <select id="findUserById" resultType="User" parameterType="int">
        select * from user where id=#{id}
    </select>
</mapper>

2.2.测试一级缓存

    @Test
    public void testFindUserById() throws Exception{
        SqlSession sqlSession1 = sqlSessionFactory.openSession();
        UserDao userDao = sqlSession1.getMapper(UserDao.class);
        User user1 = userDao.findUserById(41);//执行查询
        System.out.println("第一次查询:" + user1);
        User user2 = userDao.findUserById(41);//不执行查询
        System.out.println("第二次查询:" + user2);

        SqlSession sqlSession2 = sqlSessionFactory.openSession();
        userDao = sqlSession2.getMapper(UserDao.class);
        User user3 = userDao.findUserById(41);//执行查询
        System.out.println("第三次查询:" + user1);
    }

2.3.一级缓存的分析

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

1. 第一次发起查询用户id为 1 的用户信息，先去找缓存中是否有id为 1 的用户信息，如果没有，从数据库查询用户信息。 得到用户信息，将用户信息存储到一级缓存中。

2. 如果sqlSession去执行 commit操作（执行插入、更新、删除），清空 SqlSession 中的一级缓存，这样做的目的为了让缓存中存储的是最新的信息，避免脏读。

3. 第二次发起查询用户id为1的用户信息，先去找缓存中是否有id为1的用户信息，缓存中有，直接从缓存中获取用户信息。

2.4.测试清空一级缓存

    @Test
    public void testFindUserById() throws Exception{
        UserDao userDao = sqlSession.getMapper(UserDao.class);
        User user1 = userDao.findUserById(41);//执行查询
        System.out.println("第一次查询:" + user1);
        User user2 = userDao.findUserById(41);//不执行查询
        System.out.println("第二次查询:" + user2);
        sqlSession.commit();
        
        User user3 = userDao.findUserById(41);//执行查询
        System.out.println("第三次查询:" + user1);
    }

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.开启二级缓存

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

   <settings>
       <!-- 开启二级缓存的支持 -->
       <setting name="cacheEnabled" value="true"/>
   </settings>
   

2. 配置相关的Mapper映射文件

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

3.3.测试二级缓存

    @Test
    public void testSecondUserById(){
        SqlSession sqlSession1 = sqlSessionFactory.openSession();
        UserDao userDao = sqlSession1.getMapper(UserDao.class);
        User user1 = userDao.findUserById(41);//执行查询
        System.out.println("第一次查询:" + user1);
        sqlSession1.commit();//二级缓存在sqlSession.commit()或者sqlSession.close()之后生效

        SqlSession sqlSession2 = sqlSessionFactory.openSession();
        UserDao userDao2 = sqlSession2.getMapper(UserDao.class);
        User user2 = userDao2.findUserById(41);//不执行查询
        System.out.println("第二次查询:" + user2);
    }

3.4.二级缓存分析

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

二级缓存结构图:

3.5.测试清空二级缓存

    @Test
    public void testSecondUserById(){
        SqlSession sqlSession1 = sqlSessionFactory.openSession();
        UserDao userDao = sqlSession1.getMapper(UserDao.class);
        User user1 = userDao.findUserById(43);//执行查询
        System.out.println("第一次查询:" + user1);
        sqlSession1.commit();

        SqlSession sqlSession3 = sqlSessionFactory.openSession();
        UserDao userDao3 = sqlSession3.getMapper(UserDao.class);
        userDao3.deleteUserById(41);
        sqlSession3.commit();

        SqlSession sqlSession2 = sqlSessionFactory.openSession();
        UserDao userDao2 = sqlSession2.getMapper(UserDao.class);
        User user2 = userDao2.findUserById(43);不执行查询
        System.out.println("第二次查询:" + user2);
        sqlSession2.commit();
        sqlSession2.close();
    }