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.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;
@Before
public void init() throws IOException{
//加载配置文件
String resource = "mybatis-config.xml";
inputStream = Resources.getResourceAsStream(resource);
//创建sqlSessionFactory
sessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
//获得数据的会话实例
sqlSession = sessionFactory.openSession();
}
/**
* 一级缓存
* 一级缓存默认开启
* 使用相同的sqlSession
* 使用缓存
*/
@Test
public 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语句,创建缓存到sqlSession
System.out.println("==========第二次查询==========");
User user2 = userDao2.selectUserById(41);
System.out.println(user2); //不执行sql语句,使用sqlSession的缓存
}
@After
public 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
* 不使用缓存
*/
@Test
public 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语句,创建缓存到sqlSession1
System.out.println("==========第二次查询==========");
User user2 = userDao2.selectUserById(41);
System.out.println(user2); //执行sql语句,创建缓存到sqlSession2
}
/**
* 一级缓存
* 一级缓存默认开启
* 使用相同的sqlSession
* 在两次查询之间插入增删改操作(提交)
* 不使用缓存
*/
@Test
public 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语句,创建缓存到sqlSession
System.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;
@Before
public void init() throws IOException{
//加载配置文件
String resource = "mybatis-config.xml";
inputStream = Resources.getResourceAsStream(resource);
//创建sqlSessionFactory
sessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
//获得数据的会话实例
sqlSession = sessionFactory.openSession();
}
/**
* 二级缓存
* 前提:开启二级缓存,二级缓存默认不开启
* 使用相同的sqlSessionFactory
* 使用缓存
*
*/
@Test
public 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语句,创建缓存到sqlSession
sqlSession1.commit(); //提交,将一级缓存(sqlSession)存入到二级缓存(sqlSessionFactory)中
System.out.println("==========第二次查询==========");
User user2 = userDao2.selectUserById(41);
System.out.println(user2); //不执行sql语句,使用sqlSessionFactory的二级缓存
}
@After
public void close() throws IOException{
sqlSession.close();
inputStream.close();
}
}
3.4.二级缓存分析
二级缓存是mapper映射级别的缓存,多个SqlSession去操作同一个Mapper映射的sql语句,多个SqlSession可以共用二级缓存,二级缓存是跨SqlSession的。
二级缓存结构图:
3.5.测试清空二级缓存
/**
* 二级缓存
* 前提:开启二级缓存,二级缓存默认不开启
* 使用不同的sqlSessionFactory
* 不使用缓存
*/
@Test
public void testNoGoCaChe() throws IOException {
//加载配置文件
String resource1 = "mybatis-config.xml";
InputStream inputStream1 = Resources.getResourceAsStream(resource1);
//创建sqlSessionFactory
SqlSessionFactory sessionFactory1 = new SqlSessionFactoryBuilder().build(inputStream1);
//返回接口的代理类
SqlSession sqlSession1 = sessionFactory1.openSession();
//加载配置文件
String resource2 = "mybatis-config.xml";
InputStream inputStream2 = Resources.getResourceAsStream(resource2);
//创建sqlSessionFactory
SqlSessionFactory 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语句,创建缓存到sqlSession1
sqlSession1.commit(); //提交,将一级缓存(sqlSession1)存入到二级缓存(sqlSessionFactory1)中
System.out.println("==========第二次查询==========");
User user2 = userDao2.selectUserById(41);
System.out.println(user2); //执行sql语句,创建缓存到sqlSession2
sqlSession2.commit(); //提交,将一级缓存(sqlSession2)存入到二级缓存(sqlSessionFactory2)中
}
/**
* 二级缓存
* 前提:开启二级缓存,二级缓存默认不开启
* 使用相同的sqlSessionFactory
* 在两次查询之间插入增删改操作(提交)
* 不使用缓存
*/
@Test
public 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语句,创建缓存到sqlSession1
sqlSession1.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语句,创建缓存到sqlSession2
sqlSession2.commit(); //提交,将一级缓存(sqlSession2)存入到二级缓存(sqlSessionFactory)中
}