Mybatis缓存技术

其他 2020-03-08 10:50:32 阅读次数: 0

项目结构：

log4j.xml：

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE log4j:configuration SYSTEM "log4j.dtd">

<log4j:configuration xmlns:log4j="http://jakarta.apache.org/log4j/">

	<appender name="STDOUT" class="org.apache.log4j.ConsoleAppender">
		<param name="Encoding" value="UTF-8" />
		<layout class="org.apache.log4j.PatternLayout">
			<param name="ConversionPattern" value="%-5p %d{MM-dd HH:mm:ss,SSS} %m  (%F:%L) \n" />
		</layout>
	</appender>
	<logger name="java.sql">
		<level value="debug" />
	</logger>
	<logger name="org.apache.ibatis">
		<level value="info" />
	</logger>
	<root>
		<level value="debug" />
		<appender-ref ref="STDOUT" />
	</root>
	
</log4j:configuration>

mybatis-config.xml:

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
	<environments default="development">
		<!-- 配置数据库连接信息 -->
		<environment id="development">
			<transactionManager type="JDBC" />
			<dataSource type="POOLED">
				<property name="driver" value="com.mysql.jdbc.Driver" />
				<property name="url" value="jdbc:mysql://127.0.0.1:3306/test" />
				<property name="username" value="root" />
				<property name="password" value="123456" />
			</dataSource>
		</environment>
	</environments>

	<!-- 注册Mapper xml文件 sql语句 -->
	<mappers>
		<mapper resource="./user_info.xml" />
	</mappers>
</configuration>

userinfo.xml:

<?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.jd.userinfo.dao.IUserInfoDao">
	<!-- 查询使用select标签，id与抽象方法啊名相同，resultType为返回值类型 -->
		
	<select id="select" resultType="com.jd.vo.UserInfo">
		SELECT * from user_info 
	</select>
	
</mapper>

暂且只写一个查询语句：
 

UserInfo.java:

package com.jd.vo;

public class UserInfo {

	private int id;
	public int getId() {
		return id;
	}
	public void setId(int id) {
		this.id = id;
	}
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	public String getMobile() {
		return mobile;
	}
	public void setMobile(String mobile) {
		this.mobile = mobile;
	}
	public String getAddress() {
		return address;
	}
	public void setAddress(String address) {
		this.address = address;
	}
	private String name;
	private String mobile;
	private String address;
}

IUserInfoDao.java:

package com.jd.userinfo.dao;

import java.util.List;

import org.apache.ibatis.annotations.Param;

import com.jd.vo.UserInfo;

public interface IUserInfoDao {
	List<UserInfo> select();

}

Test.java:

package com.jd.test;

import java.io.IOException;
import java.io.InputStream;
import java.util.List;

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 com.jd.userinfo.dao.IUserInfoDao;
import com.jd.vo.UserInfo;

public class Test {
	
	public static void main(String[] args) {
		InputStream inputStream;
		try {
			inputStream = Resources.getResourceAsStream("mybatis-config.xml");
			SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
			SqlSession sqlSession = sqlSessionFactory.openSession();
			IUserInfoDao userInfoDao = sqlSession.getMapper(IUserInfoDao.class);
			List<UserInfo> list = userInfoDao.select();
			System.out.println(list.size());
			sqlSession.close();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}

这里在list集合中只打印数据个数：

运行结果：

一级缓存：

这里在test中在添加：

list = userInfoDao.select();
public static void main(String[] args) {
		InputStream inputStream;
		try {
			inputStream = Resources.getResourceAsStream("mybatis-config.xml");
			SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
			SqlSession sqlSession = sqlSessionFactory.openSession();
			IUserInfoDao userInfoDao = sqlSession.getMapper(IUserInfoDao.class);
			List<UserInfo> list = userInfoDao.select();
			System.out.println(list.size());
			list = userInfoDao.select();
			System.out.println(list.size());
			sqlSession.close();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}

此时按理应该执行两次select（）方法：

运行结果：

但是只执行了一次。
原因：这两次查询都是在一个SqlSession中查询，有缓存，查询一次即可。

所以导致缓存失效的方法有下面四种：

（a）在不同SqlSession中查询数据（第一个关闭，然后在开启第二个）

再次修改：

InputStream inputStream;
		try {
			inputStream = Resources.getResourceAsStream("mybatis-config.xml");
			SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
			SqlSession sqlSession = sqlSessionFactory.openSession();
			IUserInfoDao userInfoDao = sqlSession.getMapper(IUserInfoDao.class);
			List<UserInfo> list = userInfoDao.select();
			System.out.println(list.size());
			sqlSession.close();
			
		    sqlSession = sqlSessionFactory.openSession();
		    userInfoDao = sqlSession.getMapper(IUserInfoDao.class);
			list = userInfoDao.select();
			System.out.println(list.size());
			sqlSession.close();
		} catch (IOException e) {
			e.printStackTrace();
		}

第一个SqlSession运行完之后关闭，在开启第二个SqlSession。

运行结果：

（b）相同SqlSession中查询数据，但查询条件不同

try {
			InputStream inputStream = Resources.getResourceAsStream("mybatis-config.xml");
			SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
			SqlSession sqlSession = sqlSessionFactory.openSession();
			IUserInfoDao userInfoDao = sqlSession.getMapper(IUserInfoDao.class);
			List<UserInfo> list = userInfoDao.select("%m%");
			System.out.println(list.size());
			list = userInfoDao.select("%a%");
			System.out.println(list.size());
			sqlSession.close();
			} catch(IOException e) {
			e.printStackTrace();
			}

运行结果：

（c）相同SqlSession中查询数据，但两次查询之间执行了增删改操作

try {
			InputStream inputStream = Resources.getResourceAsStream("mybatis-config.xml");
			SqlSessionFactory sqlSessionFactory= new SqlSessionFactoryBuilder().build(inputStream);
			SqlSession sqlSession = sqlSessionFactory.openSession();
			IUserInfoDao userInfoDao = sqlSession.getMapper(IUserInfoDao.class);
			List<UserInfo> list = userInfoDao.select();
			System.out.println(list.size());
			
			boolean flag = userInfoDao.delete(1);
			System.out.println(flag);
			
			list = userInfoDao.select();
			System.out.println(list.size());
			sqlSession.close();
		} catch (IOException e) {

			e.printStackTrace();
		}

（d）相同SqlSession中查询数据，但第二次查询前，程序调用SqlSession对象clearCache()方法手动清除了一级缓存

try {
			InputStream inputStream = Resources.getResourceAsStream("mybatis-config.xml");
			SqlSessionFactory sqlSessionFactory= new SqlSessionFactoryBuilder().build(inputStream);
			SqlSession sqlSession = sqlSessionFactory.openSession();
			IUserInfoDao userInfoDao = sqlSession.getMapper(IUserInfoDao.class);
			List<UserInfo> list = userInfoDao.select();
			System.out.println(list.size());
			
			sqlSession.clearCache();
			
			list = userInfoDao.select();
			System.out.println(list.size());
			sqlSession.close();
		} catch (IOException e) {

			e.printStackTrace();
		}

下面开启二级缓存

1、该级缓存默认不开启，但如果使用二级缓存需要在每个XML映射文件中添加<cache></cache>以配置该级缓存。二级缓存可以通过在全局配置文件配置setting标签来关闭该级缓存。

cache标签属性：

eviction：缓存回收策略：

LRU – 最近最少使用的：移除最长时间不被使用的对象，默认值

FIFO – 先进先出：按对象进入缓存的顺序来移除它们。

SOFT – 软引用：移除基于垃圾回收器状态和软引用规则的对象。

WEAK – 弱引用：更积极地移除基于垃圾收集器状态和弱引用规则的对象。

flushInterval：刷新间隔，单位毫秒，默认情况是不设置，也就是没有刷新间隔，缓存仅仅调用语句时刷新

size：引用数目，正整数，代表缓存最多可以存储多少个对象，太大容易导致内存溢出

readOnly：只读，默认为false。true：只读缓存；会给所有调用者返回缓存对象的相同实例，速度快；false：读写缓存；会返回缓存对象的拷贝（通过序列化），速度慢但安全。

2、该级缓存为namespace级别的缓存

3、工作机制：通过SqlSession查询数据，这些数据将会放到当前会话的一级缓存中；如果当前会话关闭，则一级缓存中的数据会被保存到二级缓存中，此后新的SqlSession将从二级缓存中查找数据；

下面是二级缓存。

4、select标签的useCache属性用于设置是否使用二级缓存；insert、update、delete或select标签均有flushCache属性，其中增删改默认true，即sql执行以后，会同时清空一级和二级缓存，查询默认false。

package com.jd.test;

import java.io.IOException;
import java.io.InputStream;
import java.util.List;

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 com.jd.userinfo.dao.IUserInfoDao;
import com.jd.vo.UserInfo;

public class Test {
	
	public static void main(String[] args) {
		try {
			InputStream inputStream = Resources.getResourceAsStream("mybatis-config.xml");
			SqlSessionFactory sqlSessionFactory= new SqlSessionFactoryBuilder().build(inputStream);
			SqlSession sqlSession = sqlSessionFactory.openSession();
			IUserInfoDao userInfoDao = sqlSession.getMapper(IUserInfoDao.class);
			List<UserInfo> list = userInfoDao.select();
			System.out.println(list.size());
			
			sqlSession.close();
					
			sqlSession = sqlSessionFactory.openSession();
			userInfoDao = sqlSession.getMapper(IUserInfoDao.class);
			boolean flag = userInfoDao.delete(2);//清空二级缓存
			System.out.println(flag);
			
			list = userInfoDao.select();
			System.out.println(list.size());
			sqlSession.close();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}

一级缓存和二级缓存的区别：

①、一级缓存是SqlSession级别的缓存。在操作数据库时需要构造sqlSession对象，在对象中有一个数据结构（HashMap）用于存储缓存数据。不同的sqlSession之间的缓存数据区域（HashMap）是互相不影响的。

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

原文：https://www.jianshu.com/p/2be932206c59（下面是一级缓存和二级缓存的区别）

一只奋斗的小强
发布了91 篇原创文章 · 获赞 8 · 访问量 4738
私信 关注

猜你喜欢

转载自blog.csdn.net/niuxikun/article/details/104608349
今日推荐
周排行
成为C++高手之宏与枚举
在CAD二次开发中使用进度条
Js插件ECharts，HighCharts学习网址整理
Celery提交任务出错(on windows.)
cephfs内核客户端性能追踪
thinkphp中PHPExcel用法
EntityFramework动态组合多排序字段
汇编语言（八）实验9 根据材料编程
安装ubuntu后必须做的事情（对我而言）
JS函数式编程
每日归档
更多
2024-10-22(0)
2024-10-21(0)
2024-10-20(0)
2024-10-19(0)
2024-10-18(0)
2024-10-17(0)
2024-10-16(0)
2024-10-15(0)
2024-10-14(0)
2024-10-13(0)

代码天地 © 2018 codetd.com

境外服务器   最新电视剧2022