标签:dwr 返回 src dao 接口 调用 集合 日志 log
MyBatis 默认开启了一级缓存,一级缓存是在SqlSession 层面进行缓存的。即,同一个SqlSession ,多次调用同一个Mapper和同一个方法的同一个参数,
只会进行一次数据库查询,然后把数据缓存到缓冲中,以后直接先从缓存中取出数据,不会直接去查数据库。
? 但是不同的SqlSession对象,因为用的SqlSession都是相互隔离的,所以相同的Mapper、参数和方法,他还是会再次发送到SQL到数据库去执行,返回结果;
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 }
日志输出
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, password TRACE [main] - <== Row: 1, ASH-001, 小明, JIKF-001, ADMIN, 1, 0, 销售员, 1212121212121 DEBUG [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, password TRACE [main] - <== Row: 1, ASH-001, 小明, JIKF-001, ADMIN, 1, 0, 销售员, 1212121212121 DEBUG [main] - <== Total: 1
可以发现,第一次的两个相同操作,只执行了一次数据库。后来的那个操作又进行了数据库查询;
为了克服这个问题,需要开启二级缓存,是的缓存在SqlSessionFactory层面给各个SqlSession 对象共享。默认二级缓存是不开启的,需要手动进行配置;
如果这样配置的话,很多其他的配置就会被默认进行,如:
添加后日志打印如下,可以发现所有过程只使用了一次数据库查询
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, password TRACE [main] - <== Row: 1, AS-01, 小明, HJ-009, ADMIN, 1, 0, 销售员, dasfasdfasdfsdf DEBUG [main] - <== Total: 1 =============================================================
可以在开启二级缓存时候,手动配置一些属性
<cache eviction="LRU" flushInterval="100000" size="1024" readOnly="true"/>
各个属性意义如下:
可以在Mapper的具体方法下设置对二级缓存的访问意愿:
useCache配置
如果一条语句每次都需要最新的数据,就意味着每次都需要从数据库中查询数据,可以把这个属性设置为false,如:
<select id="selectAll" resultMap="BaseResultMap" useCache="false">
刷新缓存(就是清空缓存)
? 二级缓存默认会在insert、update、delete操作后刷新缓存,可以手动配置不更新缓存,如下:
<update id="updateById" parameterType="User" flushCache="false" />
自定义缓存对象,该对象必须实现 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<Object,Object> cache = new ConcurrentHashMap<Object, Object>(); 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 //通过KEY 43 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 }
? 在Mapper文件里配置使用该自定义的缓存对象,如:
<cache type="com.sanyue.utils.BatisCache"/>
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 = ? :1 OVER ======================================================= 值为: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 OVER ======================================================= 值为: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 = ? :1 OVER ======================================================= 值为:[User{userId=1, loginName=‘AS-01‘, password=‘12121212121‘, userName=‘小明‘, userCode=‘JSD-009‘, userType=‘ADMIN‘, userActive=true, userPosition=‘销售员‘}] =====================OVER============================== 获取锁对象!!!
可以看出,每次查询数据库前,MyBatis都会先在缓存中查找是否有该缓存对象。只有当调用了commit() 方法,MyBatis才会往缓存中写入数据,数据记录的键为 数字编号+Mapper名+方法名+SQL语句+参数
格式,值为返回的对象值。
标签:dwr 返回 src dao 接口 调用 集合 日志 log
原文地址:https://www.cnblogs.com/tzhyy/p/9635403.html