博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
(转)MyBatis 一、二级缓存和自定义缓存
阅读量:5869 次
发布时间:2019-06-19

本文共 9059 字,大约阅读时间需要 30 分钟。

1、一级缓存

        MyBatis 默认开启了一级缓存,一级缓存是在SqlSession 层面进行缓存的。即,同一个SqlSession ,多次调用同一个Mapper和同一个方法的同一个参数,

        只会进行一次数据库查询,然后把数据缓存到缓冲中,以后直接先从缓存中取出数据,不会直接去查数据库。

​       但是不同的SqlSession对象,因为用的SqlSession都是相互隔离的,所以相同的Mapper、参数和方法,他还是会再次发送到SQL到数据库去执行,返回结果;

       思考:在spring 管理的SqlSession对象 是使用什么样的机制进行管理的呢 才能保证其线程安全  我猜测是TheadLocal 对其进行管理,导致我通过页面第二次

       访问相同的查询语句、仍然不走一级缓存;

1 public static void main(String[] args) { 2         // 自定义的单例SqlSessionFactory模式 3         SqlSessionFactory factory = SqlSessionFactoryUtil.openSqlSession(); 4  5         // 获得SqlSession对象 6         SqlSession sqlSession = factory.openSession(); 7         // 获得dao实体 8         UserMapper userMapper = sqlSession.getMapper(UserMapper.class); 9         // 进行两次相同的查询操作10         userMapper.selectByPrimaryKey(1);11         userMapper.selectByPrimaryKey(1);12         // 注意,当我们使用二级缓存时候,sqlSession需要使用commit时候才会生效13         sqlSession.commit();14 15         System.out.println("\n\n=============================================================");16         // 获得一个新的SqlSession 对象17         SqlSession sqlSession1 = factory.openSession();18         // 进行相同的查询操作19         sqlSession1.getMapper(UserMapper.class).selectByPrimaryKey(1);20         // 注意,当我们使用二级缓存时候,sqlSession需要使用commit时候才会生效21         sqlSession.commit();22     }
View Code

日志输出

DEBUG [main] - ooo Using Connection [com.mysql.jdbc.JDBC4Connection@77caeb3e]DEBUG [main] - ==>  Preparing: select user_ID, login_name,user_name, user_code, user_type, user_active, organization_ID,user_position,password from user where user_ID = ? DEBUG [main] - ==> Parameters: 1(Integer)TRACE [main] - <==    Columns: user_ID, login_name, user_name, user_code, user_type, user_active, organization_ID, user_position, passwordTRACE [main] - <==        Row: 1, ASH-001, 小明, JIKF-001, ADMIN, 1, 0, 销售员, 1212121212121DEBUG [main] - <==      Total: 1=============================================================DEBUG [main] - ooo Using Connection [com.mysql.jdbc.JDBC4Connection@553f17c]DEBUG [main] - ==>  Preparing: select user_ID, login_name,user_name, user_code, user_type, user_active, organization_ID,user_position,password from user where user_ID = ? DEBUG [main] - ==> Parameters: 1(Integer)TRACE [main] - <==    Columns: user_ID, login_name, user_name, user_code, user_type, user_active, organization_ID, user_position, passwordTRACE [main] - <==         Row: 1, ASH-001, 小明, JIKF-001, ADMIN, 1, 0, 销售员, 1212121212121DEBUG [main] - <==      Total: 1

可以发现,第一次的两个相同操作,只执行了一次数据库。后来的那个操作又进行了数据库查询;

2、二级缓存

        为了克服这个问题,需要开启二级缓存,是的缓存在SqlSessionFactory层面给各个SqlSession 对象共享。默认二级缓存是不开启的,需要手动进行配置;

如果这样配置的话,很多其他的配置就会被默认进行,如:

  • 映射文件所有的select 语句会被缓存
  • 映射文件的所有的insert、update和delete语句会刷新缓存
  • 缓存会使用默认的Least Recently Used(LRU,最近最少使用原则)的算法来回收缓存空间
  • 根据时间表,比如No Flush Interval,(CNFI,没有刷新间隔),缓存不会以任何时间顺序来刷新
  • 缓存会存储列表集合或对象(无论查询方法返回什么)的1024个引用
  • 缓存会被视为是read/write(可读/可写)的缓存,意味着对象检索不是共享的,而且可以很安全的被调用者修改,不干扰其他调用者或县城所作的潜在修改

添加后日志打印如下,可以发现所有过程只使用了一次数据库查询

EBUG [main] - ooo Using Connection [com.mysql.jdbc.JDBC4Connection@5622fdf]DEBUG [main] - ==>  Preparing: select user_ID, login_name,user_name, user_code, user_type, user_active, organization_ID,user_position,password from user where user_ID = ? DEBUG [main] - ==> Parameters: 1(Integer)TRACE [main] - <==    Columns: user_ID, login_name, user_name, user_code, user_type, user_active, organization_ID, user_position, passwordTRACE [main] - <==        Row: 1, AS-01, 小明, HJ-009, ADMIN, 1, 0, 销售员, dasfasdfasdfsdfDEBUG [main] - <==      Total: 1=============================================================

可以在开启二级缓存时候,手动配置一些属性

各个属性意义如下:

  • eviction:缓存回收策略
    - LRU:最少使用原则,移除最长时间不使用的对象
    - FIFO:先进先出原则,按照对象进入缓存顺序进行回收
    - SOFT:软引用,移除基于垃圾回收器状态和软引用规则的对象
    - WEAK:弱引用,更积极的移除移除基于垃圾回收器状态和弱引用规则的对象
  • flushInterval:刷新时间间隔,单位为毫秒,这里配置的100毫秒。如果不配置,那么只有在进行数据库修改操作才会被动刷新缓存区
  • size:引用额数目,代表缓存最多可以存储的对象个数
  • readOnly:是否只读,如果为true,则所有相同的sql语句返回的是同一个对象(有助于提高性能,但并发操作同一条数据时,可能不安全),如果设置为false,则相同的sql,后面访问的是cache的clone副本。

          可以在Mapper的具体方法下设置对二级缓存的访问意愿:

          useCache配置

          如果一条语句每次都需要最新的数据,就意味着每次都需要从数据库中查询数据,可以把这个属性设置为false,如:

 

刷新缓存(就是清空缓存)

​ 二级缓存默认会在insert、update、delete操作后刷新缓存,可以手动配置不更新缓存,如下:

3、自定义缓存

自定义缓存对象,该对象必须实现 org.apache.ibatis.cache.Cache 接口,如下:

1 import org.apache.ibatis.cache.Cache; 2  3 import java.util.concurrent.ConcurrentHashMap; 4 import java.util.concurrent.locks.ReadWriteLock; 5 import java.util.concurrent.locks.ReentrantReadWriteLock; 6  7 /** 8  * Created by Luky on 2017/10/14. 9  */10 public class BatisCache implements Cache {11     private ReadWriteLock lock = new ReentrantReadWriteLock();12     private ConcurrentHashMap
cache = new ConcurrentHashMap
();13 private String id;14 15 public BatisCache(){16 System.out.println("初始化-1!");17 }18 19 //必须有该构造函数20 public BatisCache(String id){21 System.out.println("初始化-2!");22 this.id = id;23 }24 25 // 获取缓存编号26 public String getId() {27 System.out.println("得到ID:" + id);28 return id;29 }30 31 //获取缓存对象的大小32 public int getSize() {33 System.out.println("获取缓存大小!");34 return 0;35 }36 // 保存key值缓存对象37 public void putObject(Object key, Object value) {38 System.out.println("往缓存中添加元素:key=" + key+",value=" + value);39 cache.put(key,value);40 }41 42 //通过KEY43 public Object getObject(Object key) {44 System.out.println("通过kEY获取值:" + key);45 System.out.println("OVER");46 System.out.println("=======================================================");47 System.out.println("值为:" + cache.get(key));48 System.out.println("=====================OVER==============================");49 return cache.get(key);50 }51 52 // 通过key删除缓存对象53 public Object removeObject(Object key) {54 System.out.println("移除缓存对象:" + key);55 return null;56 }57 58 // 清空缓存59 public void clear() {60 System.out.println("清除缓存!");61 cache.clear();62 }63 64 // 获取缓存的读写锁65 public ReadWriteLock getReadWriteLock() {66 System.out.println("获取锁对象!!!");67 return lock;68 }69 }
View Code

​ 在Mapper文件里配置使用该自定义的缓存对象,如:

1 public static void main(String[] args) { 2  3         SqlSessionFactory factory = SqlSessionFactoryUtil.openSqlSession(); 4  5         // 获得SqlSession对象 6         SqlSession sqlSession = factory.openSession(); 7         // 获得dao实体 8         UserMapper userMapper = sqlSession.getMapper(UserMapper.class); 9         // 进行两次相同的查询操作10         userMapper.selectByPrimaryKey(1);11         userMapper.selectByPrimaryKey(1);12         // 注意,当我们使用二级缓存时候,sqlSession需要使用commit时候才会生效13         sqlSession.commit();14 15         System.out.println("\n\n=============================================================");16         // 获得一个新的SqlSession 对象17         SqlSession sqlSession1 = factory.openSession();18         // 进行相同的查询操作19         sqlSession1.getMapper(UserMapper.class).selectByPrimaryKey(1);20         sqlSession1.commit();21     }

​ 日志输出如下:

初始化-2!得到ID:com.sanyue.dao.UserMapper获取锁对象!!!通过kEY获取值:151355725:1423317450:com.sanyue.dao.UserMapper.selectByPrimaryKey:0:2147483647:        select                user_ID, login_name,user_name, user_code, user_type, user_active, organization_ID,user_position,password            from user        where user_ID = ?    :1OVER=======================================================值为:null=====================OVER==============================获取锁对象!!!获取锁对象!!!通过kEY获取值:151355725:1423317450:com.sanyue.dao.UserMapper.selectByPrimaryKey:0:2147483647:        select                user_ID, login_name,user_name, user_code, user_type, user_active, organization_ID,user_position,password            from user        where user_ID = ?    :1OVER=======================================================值为:null=====================OVER==============================获取锁对象!!!获取锁对象!!!往缓存中添加元素:key=151355725:1423317450:com.sanyue.dao.UserMapper.selectByPrimaryKey:0:2147483647:        select                user_ID, login_name,user_name, user_code, user_type, user_active, organization_ID,user_position,password            from user        where user_ID = ?    :1,value=[User{userId=1, loginName='AS-01', password='12121212121', userName='小明', userCode='JSD-009', userType='ADMIN', userActive=true, userPosition='销售员'}]获取锁对象!!!=============================================================获取锁对象!!!通过kEY获取值:151355725:1423317450:com.sanyue.dao.UserMapper.selectByPrimaryKey:0:2147483647:        select                user_ID, login_name,user_name, user_code, user_type, user_active, organization_ID,user_position,password            from user        where user_ID = ?    :1OVER=======================================================值为:[User{userId=1, loginName='AS-01', password='12121212121', userName='小明', userCode='JSD-009', userType='ADMIN', userActive=true, userPosition='销售员'}]=====================OVER==============================获取锁对象!!!
View Code

可以看出,每次查询数据库前,MyBatis都会先在缓存中查找是否有该缓存对象。只有当调用了commit() 方法,MyBatis才会往缓存中写入数据,数据记录的键为 数字编号+Mapper名+方法名+SQL语句+参数 格式,值为返回的对象值。

转载于:https://www.cnblogs.com/tzhyy/p/9635403.html

你可能感兴趣的文章
SCDPM2012 R2实战一:基于SQL 2008 R2集群的SCDPM2012 R2的安装
查看>>
SQL SERVER中字段类型与C#数据类型的对应关系
查看>>
Linux lsof命令详解
查看>>
SVG path
查看>>
js判断checkbox是否选中
查看>>
多系统盘挂载
查看>>
MySQL函数怎么加锁_MYSQL 函数调用导致自动生成共享锁问题
查看>>
MR1和MR2的工作原理
查看>>
Eclipse中修改代码格式
查看>>
GRUB Legacy
查看>>
关于 error: LINK1123: failure during conversion to COFF: file invalid or corrupt 错误的解决方案...
查看>>
hexo博客解决不蒜子统计无法显示问题
查看>>
python实现链表
查看>>
java查找string1和string2是不是含有相同的字母种类和数量(string1是否是string2的重新组合)...
查看>>
Android TabActivity使用方法
查看>>
Eclipse的 window-->preferences里面没有Android选项
查看>>
《麦田里的守望者》--[美]杰罗姆·大卫·塞林格
查看>>
遇到的那些坑
查看>>
央行下属的上海资信网络金融征信系统(NFCS)签约机构数量突破800家
查看>>
[转] Lazy evaluation
查看>>