原 03-MyBatis缓存和配置细节

来源:亮哥168 发布时间:2019-03-30 17:39:04 阅读量:697

* 有问题可以参加Java技术交流群:839366464

 

MyBatis缓存介绍

1 MyBatis 提供了一级缓存和二级缓存的支持

 

2 一级缓存: 基于PerpetualCache HashMap本地缓存,其存储作用域为 Session,当 Session flush close 之后,该Session中的所有 Cache 就将清空。

3. 二级缓存与一级缓存其机制相同,默认也是采用 PerpetualCacheHashMap存储,不同在于其存储作用域为 Mapper(Namespace)

 

4. 对于缓存数据更新机制,当某一个作用域(一级缓存Session/二级缓存Namespaces)的进行了 C/U/D 操作后,默认该作用域下所有 select 中的缓存将被clear

 

5.支持自定义缓存

 

* 一级缓存

 

MyBatis 默认开启了一级缓存,一级缓存是在SqlSession 层面进行缓存的。即,同一个SqlSession ,多次调用同一个Mapper和同一个方法的同一个参数,只会进行一次数据库查询,然后把数据缓存到缓冲中,以后直接先从缓存中取出数据,不会直接去查数据库。

 

 @Test

    public void test12(){

        SqlSession session = MyBatisUtils.getSqlSession();

        // 测试一级缓存

        UserMapper mapper = session.getMapper(UserMapper.class);

        // 进行两次相同的查询操作

        List<User> users = mapper.findUsers();

        users = mapper.findUsers();

        session.close();

    }

 

 

不同的SqlSession对象,会再次发送到SQL到数据库去执行

 

  @Test

    public void test13(){

        SqlSession session = MyBatisUtils.getSqlSession();

        // 测试一级缓存

        UserMapper mapper = session.getMapper(UserMapper.class);

        // 不同sqlSession对象测试

        List<User> users = mapper.findUsers();

        session.commit();

        // 获得一个新的SqlSession 对象

        session = MyBatisUtils.getSqlSession();

        mapper = session.getMapper(UserMapper.class);

        users = mapper.findUsers();

        session.close();

    }

 

 

* CUD的时候会清除缓存

 

@Test

    public void test36() throws Exception {

        SqlSession sqlSession = MyBatisUtils.getSqlSession();

        StudentMapper mapper = sqlSession.getMapper(StudentMapper.class);

        List<Integer> ids=new ArrayList<Integer>();

        ids.add(100001);

        ids.add(100002);

        ids.add(100003);

        List<Student> students = mapper.getStudentsByListIds(ids);

        Student student=new Student();

        student.setSid(100002);

        student.setSname("小黑");

        student.setSsex('');

        student.setSage(22);

        mapper.updateStudent(student);

        sqlSession.commit();

        students = mapper.getStudentsByListIds(ids);

        System.out.println(students);

        MyBatisUtils.close(sqlSession);

    }

 

 

* 二级缓存

 

假如需要不同sqlSession对象也要缓存的话,需要开启二级缓存,是缓存在SqlSessionFactory层面给各个SqlSession 对象共享。默认二级缓存是不开启的,需要手动进行配置。

配置:

<cache/>

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

映射文件所有的select 语句会被缓存

映射文件的所有的insertupdatedelete语句会刷新缓存

缓存会使用默认的Least Recently UsedLRU,最近最少使用原则)的算法来回收缓存空间

根据时间表,比如No Flush Interval,(CNFI,没有刷新间隔),缓存不会以任何时间顺序来刷新

缓存会存储列表集合或对象(无论查询方法返回什么)的1024个引用

缓存会被视为是read/write(可读/可写)的缓存,意味着对象检索不是共享的,而且可以很安全的被调用者修改,不干扰其他调用者或县城所作的潜在修改

 

 * 开启缓存的对象需要序列化

 

<mapper namespace="com.hx.hx02.mapper.UserMapper">

    <cache/>

    ...

</mapper>

 

 

 

 

 

 

 

<cache eviction="LRU" flushInterval="100000" size="" readOnly="true"/>

各个属性意义如下:

 

eviction:缓存回收策略

- LRU:最少使用原则,移除最长时间不使用的对象

- FIFO:先进先出原则,按照对象进入缓存顺序进行回收

- SOFT:软引用,移除基于垃圾回收器状态和软引用规则的对象

- WEAK:弱引用,更积极的移除移除基于垃圾回收器状态和弱引用规则的对象

flushInterval:刷新时间间隔,单位为毫秒。如果不配置,那么只有在进行数据库修改操作才会被动刷新缓存区

size:引用额数目,代表缓存最多可以存储的对象个数

readOnly:是否只读,如果为true,则所有相同的sql语句返回的是同一个对象(有助于提高性能,但并发操作同一条数据时,可能不安全),如果设置为false,则相同的sql,后面访问的是cacheclone副本。

 

 *细节

 

useCache 的使用:select 有权利选择要不要被缓存

<select id="findUsers" resultType="com.hx.hx02.bean.User" useCache="false">

        SELECT *

        FROM user;

    </select>

 

 

 

二级缓存默认会在insertupdatedelete操作后刷新缓存

 

 @Test

    public void test14(){

        SqlSession session = MyBatisUtils.getSqlSession();

        UserMapper mapper = session.getMapper(UserMapper.class);

        List<User> users = mapper.findUsers();

        User user=new User();

        user.setUsername("xiao123");

        user.setSex('');

        user.setPsw("123");

        mapper.insertUser(user);

        session.commit();

        // 获得一个新的SqlSession 对象

        session = MyBatisUtils.getSqlSession();

        mapper = session.getMapper(UserMapper.class);

        users = mapper.findUsers();

        session.commit();

        session.close();

    }

 

 

  flushCache:可以配置要不要刷新缓存

    <insert id="insertUser" parameterType="com.hx.hx02.bean.User" flushCache="false">

        INSERT INTO USER(username, psw, sex)

        VALUES (#{username}, #{psw}, #{sex});

    </insert>

 

<cache eviction="LRU" flushInterval="100" size="1" readOnly="true"/>

 

public void test37() throws Exception {

        SqlSession sqlSession = MyBatisUtils.getSqlSession();

        StudentMapper mapper = sqlSession.getMapper(StudentMapper.class);

        List<Integer> ids=new ArrayList<Integer>();

        ids.add(100001);

        ids.add(100002);

        ids.add(100003);

        List<Student> students = mapper.getStudentsByListIds(ids);

        sqlSession.commit();

 

 

        sqlSession = MyBatisUtils.getSqlSession();

        mapper = sqlSession.getMapper(StudentMapper.class);

        HashMap<String,Object> map=new HashMap<String,Object>();

        map.put("ssex","");

        students = mapper.getStudentsByParams(map);

        sqlSession.commit();

 

        sqlSession = MyBatisUtils.getSqlSession();

        mapper = sqlSession.getMapper(StudentMapper.class);

        map.put("ssex","");

        students = mapper.getStudentsByParams(map);

        sqlSession.commit();

 

        sqlSession = MyBatisUtils.getSqlSession();

        mapper = sqlSession.getMapper(StudentMapper.class);

        mapper.getStudentsByListIds(ids);

        sqlSession.commit();

        MyBatisUtils.close(sqlSession);

    }

 

 

* 自定义缓存(扩展)

 

* mybatis 自带的缓存:

 

* public class PerpetualCache implements Cache

 

 

 

  * 自定义LRUCache缓存

 

public class LruCache implements Cache {

    private String id;

    private ReadWriteLock lock = new ReentrantReadWriteLock();

    private LinkedHashMap cache = new LinkedHashMap(16, 0.75f, true);

 

    public LruCache() {

        System.out.println("LruCache 初始化");

    }

 

    public LruCache(String id) {

        System.out.println("LruCache 初始化:" + id);

        this.id = id;

    }

 

    @Override

    public String getId() {

        return this.id;

    }

 

    @Override

    public void putObject(Object key, Object value) {

        System.out.println("放进缓存了....");

        try {

            lock.writeLock().lock();

            cache.put(key, value);

        } finally {

            lock.writeLock().unlock();

        }

    }

 

    @Override

    public Object getObject(Object key) {

        lock.readLock().lock();

        try {

            System.out.println("获得缓存:"+cache.get(key)+"缓存的大小:"+cache.size());

            return cache.get(key);

        } finally {

            lock.readLock().unlock();

        }

 

    }

 

    @Override

    public Object removeObject(Object key) {

        System.out.println("移除缓存对象:" + key);

        try {

            lock.writeLock().lock();

            return cache.remove(key);

        } finally {

            lock.writeLock().unlock();

        }

 

    }

 

    @Override

    public void clear() {

        System.out.println("清除缓存!");

        cache.clear();

    }

 

    @Override

    public int getSize() {

        System.out.println("获取缓存大小!" + cache.size());

        return cache.size();

    }

 

 

    @Override

    public ReadWriteLock getReadWriteLock() {

        System.out.println("获取锁对象!!!");

        return lock;

    }

}

 

 

 <cache type="com.hx.hx02.cache.LruCache"/>

 

 

* Mybatis细节

 

    * 配置mapper方式(包的方式)    

 

<mappers>

        <package name="com.hx.hx02.mapper"/>

    </mappers>

 

 

 

   * 配置package的方式出错的解决方案

 

 

 

解决方案,原来是IDEA maven项目默认不会把src下除java文件外的文件打包到classes文件夹下,需要在maven中增加配置如下

 

 

 

<resources>

            <resource>

                <directory>src/main/java</directory>

                <includes>

                    <include>**/*.xml</include>

                </includes>

                <!--默认是true-->

                <!--<filtering>true</filtering>-->

            </resource>

        </resources>

 

 

 

   * 实体bean的配置

 

     <typeAliases>

        <package name="com.hx.hx02.bean"></package>

    </typeAliases>


分享:
评论:
你还没有登录,请先