Mybatis快取
- 快取的基本概念
- Mybatis一級快取
- 證明一級快取的存在
- 撰寫用戶持久層 Dao 介面
- 撰寫用戶持久層映射檔案
- 撰寫測驗方法
- 一級快取的分析
- 測驗一級快取的清空
- 添加updateUser方法
- 測驗快取的同步
- Mybatis二級快取
- 二級快取結構圖
- 二級快取的開啟與關閉
- 第一步:在 SqlMapConfig.xml 檔案開啟二級快取
- 第二步:配置相關的 Mapper 映射檔案
- 第三步:配置 statement 上面的 useCache 屬性
- 二級快取測驗
- 二級快取注意事項
快取的基本概念
快取是存在于記憶體中的臨時資料,
使用快取減少和資料庫的互動次數,提高執行效率,
適用于快取:
(1)經常查詢并且不經常改變的,
(2)資料的正確與否對最終結果影響不大的,
不適用于快取:
(1)經常改變的資料
(2)資料的正確與否對最終結果影響很大的,
例如:商品的庫存,銀行的匯率,股市的牌價,
Mybatis一級快取
一級快取:
它指的是Mybatis中SqlSession物件的快取,
當我們執行查詢之后,查詢的結果會同時存入到SqlSession為我們提供一塊區域中,
該區域的結構是一個Map,當我們再次查詢同樣的資料,mybatis會先去sqlsession中
查詢是否有,有的話直接拿出來用,
當SqlSession物件消失時,mybatis的一級快取也就消失了,
一級快取是 SqlSession 級別的快取,只要 SqlSession 沒有 flush 或 close,它就存在,
證明一級快取的存在
撰寫用戶持久層 Dao 介面
IUserDao:
package com.keafmd.dao;
import com.keafmd.domain.User;
import java.util.List;
/**
* Keafmd
*
* @ClassName: IUserDao
* @Description: 用戶的持久層介面
* @author: 牛哄哄的柯南
* @date: 2021-02-06 19:29
*/
public interface IUserDao {
/**
* 查詢所有用戶,同時獲取到用戶下所有賬戶的資訊
* @return
*/
List<User> findAll();
/**
* 根據id查新用戶資訊
* @param id
* @return
*/
User findById(Integer id);
}
撰寫用戶持久層映射檔案
IUserDao.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.keafmd.dao.IUserDao">
<!--配置查詢所有-->
<select id="findAll" resultType="user">
select * from user
</select>
<!--根據id查詢用戶-->
<select id="findById" parameterType="Integer" resultType="user">
select * from user where id = #{id}
</select>
</mapper>
撰寫測驗方法
MybatisTest:
package com.keafmd.test;
import com.keafmd.dao.IUserDao;
import com.keafmd.domain.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.InputStream;
import java.util.List;
/**
* Keafmd
*
* @ClassName: MybatisTest
* @Description: 測驗類,測驗crud操作
* @author: 牛哄哄的柯南
* @date: 2021-02-08 15:24
*/
public class UserTest {
private InputStream in;
private SqlSessionFactory factory;
private SqlSession sqlSession;
private IUserDao userDao;
@Before // 用于在測驗方法執行前執行
public void init()throws Exception{
//1.讀取組態檔,生成位元組輸入流
in = Resources.getResourceAsStream("SqlMapConfig.xml");
//2.創建SqlSessionFactory工廠
SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
factory = builder.build(in);
//3.使用工廠生產SqlSession物件
sqlSession = factory.openSession(true); //里面寫個true,下面每次就不用了寫 sqlsession.commit(); 了
//4.使用SqlSession創建Dao介面的代理物件
userDao = sqlSession.getMapper(IUserDao.class);
}
@After // 用于在測驗方法執行后執行
public void destory() throws Exception{
//提交事務
//sqlSession.commit();
//6.釋放資源
sqlSession.close();
in.close();
}
/**
* 測驗一級快取
*/
@Test
public void testFirstLevelCache(){
User user1 = userDao.findById(41);
System.out.println(user1);
User user2 = userDao.findById(41);
System.out.println(user2);
System.out.println(user1==user2);
}
}
運行結果:
2021-02-16 15:52:44,863 359 [ main] DEBUG ansaction.jdbc.JdbcTransaction - Opening JDBC Connection
2021-02-16 15:52:45,164 660 [ main] DEBUG source.pooled.PooledDataSource - Created connection 905735620.
2021-02-16 15:52:45,168 664 [ main] DEBUG m.keafmd.dao.IUserDao.findById - ==> Preparing: select * from user where id = ?
2021-02-16 15:52:45,200 696 [ main] DEBUG m.keafmd.dao.IUserDao.findById - ==> Parameters: 41(Integer)
2021-02-16 15:52:45,227 723 [ main] DEBUG m.keafmd.dao.IUserDao.findById - <== Total: 1
com.keafmd.domain.User@400cff1a
com.keafmd.domain.User@400cff1a
true
我們可以看到,只發起了一次查詢,相當于第一次是查詢,而第二次是從快取中取得,
一級快取的分析
一級快取是 SqlSession 范圍的快取,當呼叫 SqlSession 的修改,添加,洗掉,commit(),close()等方法時,就會清空一級快取,
舉個例子:
第一次發起查詢用戶 id 為 1 的用戶資訊,先去找快取中是否有 id 為 1 的用戶資訊,如果沒有,從資料庫查詢用戶資訊,
得到用戶資訊,將用戶資訊存盤到一級快取中,
如果 sqlSession 去執行 commit 操作(執行插入、更新、洗掉),清空 SqlSession 中的一級快取,這樣做的目的為了讓快取中存盤的是最新的資訊,避免臟讀,
第二次發起查詢用戶 id 為 1 的用戶資訊,先去找快取中是否有 id 為 1 的用戶資訊,快取中有,直接從快取中獲取用戶資訊,
測驗一級快取的清空
改變下測驗代碼:
/**
* 測驗一級快取
*/
@Test
public void testFirstLevelCache(){
User user1 = userDao.findById(41);
System.out.println(user1);
/*sqlSession.close();
//再次獲取sqlSession物件
sqlSession = factory.openSession();*/
sqlSession.clearCache();//此方法也可以清空快取
userDao = sqlSession.getMapper(IUserDao.class);
User user2 = userDao.findById(41);
System.out.println(user2);
System.out.println(user1==user2);
}
運行結果:
2021-02-16 16:14:57,171 194 [ main] DEBUG ansaction.jdbc.JdbcTransaction - Opening JDBC Connection
2021-02-16 16:14:57,498 521 [ main] DEBUG source.pooled.PooledDataSource - Created connection 93314457.
2021-02-16 16:14:57,503 526 [ main] DEBUG m.keafmd.dao.IUserDao.findById - ==> Preparing: select * from user where id = ?
2021-02-16 16:14:57,541 564 [ main] DEBUG m.keafmd.dao.IUserDao.findById - ==> Parameters: 41(Integer)
2021-02-16 16:14:57,560 583 [ main] DEBUG m.keafmd.dao.IUserDao.findById - <== Total: 1
com.keafmd.domain.User@57175e74
2021-02-16 16:14:57,561 584 [ main] DEBUG m.keafmd.dao.IUserDao.findById - ==> Preparing: select * from user where id = ?
2021-02-16 16:14:57,561 584 [ main] DEBUG m.keafmd.dao.IUserDao.findById - ==> Parameters: 41(Integer)
2021-02-16 16:14:57,562 585 [ main] DEBUG m.keafmd.dao.IUserDao.findById - <== Total: 1
com.keafmd.domain.User@c540f5a
false
2021-02-16 16:14:57,563 586 [ main] DEBUG ansaction.jdbc.JdbcTransaction - Closing JDBC Connection [com.mysql.jdbc.JDBC4Connection@58fdd99]
2021-02-16 16:14:57,563 586 [ main] DEBUG source.pooled.PooledDataSource - Returned connection 93314457 to pool.
Process finished with exit code 0
我們可以看到這樣就發起了兩次查詢,我們用這兩種方式都可以清空快取,
添加updateUser方法
IUserDao:
package com.keafmd.dao;
import com.keafmd.domain.User;
import java.util.List;
/**
* Keafmd
*
* @ClassName: IUserDao
* @Description: 用戶的持久層介面
* @author: 牛哄哄的柯南
* @date: 2021-02-06 19:29
*/
public interface IUserDao {
/**
* 查詢所有用戶,同時獲取到用戶下所有賬戶的資訊
* @return
*/
List<User> findAll();
/**
* 根據id查新用戶資訊
* @param id
* @return
*/
User findById(Integer id);
/**
* 更新用戶資訊
* @param user
*/
void updateUser(User user);
}
IUserDao.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.keafmd.dao.IUserDao">
<!--配置查詢所有-->
<select id="findAll" resultType="user">
select * from user
</select>
<!--根據id查詢用戶-->
<select id="findById" parameterType="Integer" resultType="user">
select * from user where id = #{id}
</select>
<!--更新用戶資訊-->
<select id="updateUser" resultType="user">
update user set username=#{username},address=#{address} where id=#{id}
</select>
</mapper>
測驗快取的同步
UserTest:
package com.keafmd.test;
import com.keafmd.dao.IUserDao;
import com.keafmd.domain.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.InputStream;
import java.util.List;
/**
* Keafmd
*
* @ClassName: MybatisTest
* @Description: 測驗類
* @author: 牛哄哄的柯南
* @date: 2021-02-08 15:24
*/
public class UserTest {
private InputStream in;
private SqlSessionFactory factory;
private SqlSession sqlSession;
private IUserDao userDao;
@Before // 用于在測驗方法執行前執行
public void init()throws Exception{
//1.讀取組態檔,生成位元組輸入流
in = Resources.getResourceAsStream("SqlMapConfig.xml");
//2.創建SqlSessionFactory工廠
SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
factory = builder.build(in);
//3.使用工廠生產SqlSession物件
sqlSession = factory.openSession(true); //里面寫個true,下面每次就不用了寫 sqlsession.commit(); 了
//4.使用SqlSession創建Dao介面的代理物件
userDao = sqlSession.getMapper(IUserDao.class);
}
@After // 用于在測驗方法執行后執行
public void destory() throws Exception{
//提交事務
//sqlSession.commit();
//6.釋放資源
sqlSession.close();
in.close();
}
/**
* 測驗一級快取
*/
@Test
public void testFirstLevelCache(){
User user1 = userDao.findById(41);
System.out.println(user1);
/*sqlSession.close();
//再次獲取sqlSession物件
sqlSession = factory.openSession();*/
sqlSession.clearCache();//此方法也可以清空快取
userDao = sqlSession.getMapper(IUserDao.class);
User user2 = userDao.findById(41);
System.out.println(user2);
System.out.println(user1==user2);
}
/**
* 測驗快取的同步
*/
@Test
public void testClearCache(){
//1.根據id查詢用戶
User user1 = userDao.findById(41);
System.out.println(user1);
//2.更新用戶資訊
user1.setUsername("update user clear cache");
user1.setAddress("上海");
userDao.updateUser(user1);
//手動提交
sqlSession.commit();
//3.再次查詢id為41的用戶
User user2 = userDao.findById(41);
System.out.println(user2);
System.out.println(user1==user2);
}
}
運行testClearCache():
2021-02-16 16:13:04,277 209 [ main] DEBUG ansaction.jdbc.JdbcTransaction - Opening JDBC Connection
2021-02-16 16:13:04,560 492 [ main] DEBUG source.pooled.PooledDataSource - Created connection 93314457.
2021-02-16 16:13:04,565 497 [ main] DEBUG m.keafmd.dao.IUserDao.findById - ==> Preparing: select * from user where id = ?
2021-02-16 16:13:04,618 550 [ main] DEBUG m.keafmd.dao.IUserDao.findById - ==> Parameters: 41(Integer)
2021-02-16 16:13:04,645 577 [ main] DEBUG m.keafmd.dao.IUserDao.findById - <== Total: 1
com.keafmd.domain.User@57175e74
2021-02-16 16:13:04,646 578 [ main] DEBUG keafmd.dao.IUserDao.updateUser - ==> Preparing: update user set username=?,address=? where id=?
2021-02-16 16:13:04,646 578 [ main] DEBUG keafmd.dao.IUserDao.updateUser - ==> Parameters: update user clear cache(String), 上海(String), 41(Integer)
2021-02-16 16:13:04,647 579 [ main] DEBUG m.keafmd.dao.IUserDao.findById - ==> Preparing: select * from user where id = ?
2021-02-16 16:13:04,648 580 [ main] DEBUG m.keafmd.dao.IUserDao.findById - ==> Parameters: 41(Integer)
2021-02-16 16:13:04,649 581 [ main] DEBUG m.keafmd.dao.IUserDao.findById - <== Total: 1
com.keafmd.domain.User@c540f5a
false
2021-02-16 16:13:04,650 582 [ main] DEBUG ansaction.jdbc.JdbcTransaction - Closing JDBC Connection [com.mysql.jdbc.JDBC4Connection@58fdd99]
2021-02-16 16:13:04,650 582 [ main] DEBUG source.pooled.PooledDataSource - Returned connection 93314457 to pool.
Process finished with exit code 0
我們在第一次查詢后進行的更新操作,所以會清空一級快取,然后第二次會在進行查詢,
Mybatis二級快取
二級快取:
它指的是Mybatis中SqlSessionFactory物件的快取,由同一個SqlSessionFactory物件創建的SqlSession共享其快取,
二級快取的使用步驟:
第一步:讓Mybatis框架支持二級快取(在SqlMapConfig.xml中配置)
第二步:讓當前的映射檔案支持二級快取(在IUserDao.xml中配置)
第三步:讓當前的操作支持二級快取(在select標簽中配置)
二級快取是 mapper 映射級別的快取,多個 SqlSession 去操作同一個 Mapper 映射的 sql 陳述句,多個SqlSession 可以共用二級快取,二級快取是跨 SqlSession 的,
二級快取結構圖
首先開啟 mybatis 的二級快取,
sqlSession1 去查詢用戶資訊,查詢到用戶資訊會將查詢資料存盤到二級快取中,
如果 SqlSession3 去執行相同 mapper 映射下 sql,執行 commit 提交,將會清空該 mapper 映射下的二級快取區域的資料,
sqlSession2 去查詢與 sqlSession1 相同的用戶資訊,首先會去快取中找是否存在資料,如果存在直接從快取中取出資料,
二級快取的開啟與關閉
第一步:在 SqlMapConfig.xml 檔案開啟二級快取
<settings>
<!--開啟二級快取的支持-->
<setting name="cacheEnabled" value="true"/>
</settings>
因為 cacheEnabled 的取值默認就為 true,所以這一步可以省略不配置,為 true 代表開啟二級快取;為false 代表不開啟二級快取,
第二步:配置相關的 Mapper 映射檔案
IUserDao.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.keafmd.dao.IUserDao">
<!--開啟user支持二級快取-->
<cache/>
<!--配置查詢所有-->
<select id="findAll" resultType="user">
select * from user
</select>
<!--根據id查詢用戶-->
<select id="findById" parameterType="Integer" resultType="user" useCache="true">
select * from user where id = #{id}
</select>
<!--更新用戶資訊-->
<select id="updateUser" resultType="user">
update user set username=#{username},address=#{address} where id=#{id}
</select>
</mapper>
第三步:配置 statement 上面的 useCache 屬性
<!--根據id查詢用戶-->
<select id="findById" parameterType="Integer" resultType="user" useCache="true">
select * from user where id = #{id}
</select>
將 UserDao.xml 映射檔案中的標簽中設定 useCache=”true”代表當前這個statement 要使用二級快取,如果不使用二級快取可以設定為 false,
注意:針對每次查詢都需要最新的資料 sql,要設定成 useCache=false,禁用二級快取,
二級快取測驗
SecondLevelCacheTest:
package com.keafmd.test;
import com.keafmd.dao.IUserDao;
import com.keafmd.domain.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.InputStream;
/**
* Keafmd
*
* @ClassName: MybatisTest
* @Description: 測驗類,測驗crud操作
* @author: 牛哄哄的柯南
* @date: 2021-02-08 15:24
*/
public class SecondLevelCacheTest {
private InputStream in;
private SqlSessionFactory factory;
@Before // 用于在測驗方法執行前執行
public void init()throws Exception{
//1.讀取組態檔,生成位元組輸入流
in = Resources.getResourceAsStream("SqlMapConfig.xml");
//2.創建SqlSessionFactory工廠
SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
factory = builder.build(in);
}
@After // 用于在測驗方法執行后執行
public void destory() throws Exception{
in.close();
}
/**
* 測驗二級快取
*/
@Test
public void testSecondLevelCache(){
SqlSession sqlSession1 = factory.openSession();
IUserDao dao1 = sqlSession1.getMapper(IUserDao.class);
User user1 = dao1.findById(41);
System.out.println(user1);
sqlSession1.close(); //一級快取消失
SqlSession sqlSession2 = factory.openSession();
IUserDao dao2 = sqlSession2.getMapper(IUserDao.class);
User user2 = dao2.findById(41);
System.out.println(user2);
sqlSession2.close();
System.out.println(user1==user2);
}
}
運行結果:
2021-02-16 17:07:05,474 179 [ main] DEBUG ansaction.jdbc.JdbcTransaction - Opening JDBC Connection
2021-02-16 17:07:05,723 428 [ main] DEBUG source.pooled.PooledDataSource - Created connection 905735620.
2021-02-16 17:07:05,723 428 [ main] DEBUG ansaction.jdbc.JdbcTransaction - Setting autocommit to false on JDBC Connection [com.mysql.jdbc.JDBC4Connection@35fc6dc4]
2021-02-16 17:07:05,726 431 [ main] DEBUG m.keafmd.dao.IUserDao.findById - ==> Preparing: select * from user where id = ?
2021-02-16 17:07:05,752 457 [ main] DEBUG m.keafmd.dao.IUserDao.findById - ==> Parameters: 41(Integer)
2021-02-16 17:07:05,770 475 [ main] DEBUG m.keafmd.dao.IUserDao.findById - <== Total: 1
com.keafmd.domain.User@400cff1a
2021-02-16 17:07:05,777 482 [ main] DEBUG ansaction.jdbc.JdbcTransaction - Resetting autocommit to true on JDBC Connection [com.mysql.jdbc.JDBC4Connection@35fc6dc4]
2021-02-16 17:07:05,778 483 [ main] DEBUG ansaction.jdbc.JdbcTransaction - Closing JDBC Connection [com.mysql.jdbc.JDBC4Connection@35fc6dc4]
2021-02-16 17:07:05,778 483 [ main] DEBUG source.pooled.PooledDataSource - Returned connection 905735620 to pool.
2021-02-16 17:07:05,782 487 [ main] DEBUG com.keafmd.dao.IUserDao - Cache Hit Ratio [com.keafmd.dao.IUserDao]: 0.5
com.keafmd.domain.User@75c072cb
false
Process finished with exit code 0
經過上面的測驗,我們發現執行了兩次查詢,并且在執行第一次查詢后,我們關閉了一級快取,再去執行第二次查詢時,我們發現并沒有對資料庫發出 sql 陳述句,所以此時的資料就只能是來自于我們所說的二級快取,
注意:二級快取中存放的內容是資料,而不是物件,內容雖然是同樣的,但是存放的是資料,第二次雖然沒有發起查詢,但從二級快取中獲取時,會把內容封裝到新的物件回傳,所以是false,
二級快取注意事項
當我們在使用二級快取時,所快取的類一定要實作 java.io.Serializable 介面,這種就可以使用序列化方式來保存物件,
User:
package com.keafmd.domain;
import java.io.Serializable;
import java.util.Date;
import java.util.List;
/**
* Keafmd
*
* @ClassName: User
* @Description:
* @author: 牛哄哄的柯南
* @date: 2021-02-08 15:16
*/
public class User implements Serializable {
private Integer id;
private String username;
private String sex;
private String address;
private Date birthday;
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
public String getUsername() {
return username;
}
public void setUsername(String username) {
this.username = username;
}
public String getSex() {
return sex;
}
public void setSex(String sex) {
this.sex = sex;
}
public String getAddress() {
return address;
}
public void setAddress(String address) {
this.address = address;
}
public Date getBirthday() {
return birthday;
}
public void setBirthday(Date birthday) {
this.birthday = birthday;
}
}
以上就是Mybatis快取的全部內容,
看完如果對你有幫助,感謝點贊支持!
如果你是電腦端的話,看到右下角的 “一鍵三連” 了嗎,沒錯點它[哈哈]

加油!
共同努力!
Keafmd
轉載請註明出處,本文鏈接:https://www.uj5u.com/ruanti/260296.html
標籤:其他


