MyBatis 缓存机制

MyBatis 缓存机制

 

MyBatis 提供了查询缓存来缓存数据，以提高查询的性能。MyBatis 的缓存分为一级缓存和二级缓存。

• 一级缓存是 SqlSession 级别的缓存
• 二级缓存是 mapper 级别的缓存，多个 SqlSession 共享

一级缓存

一级缓存是 SqlSession 级别的缓存，是基于 HashMap 的本地缓存。不同的 SqlSession 之间的缓存数据区域互不影响。

一级缓存的作用域是 SqlSession 范围，当同一个 SqlSession 执行两次相同的 sql 语句时，第一次执行完后会将数据库中查询的数据写到缓存，第二次查询时直接从缓存获取不用去数据库查询。当 SqlSession 执行 insert、update、delete 操做并提交到数据库时，会清空缓存，保证缓存中的信息是最新的。

MyBatis 默认开启一级缓存。

二级缓存

二级缓存是 mapper 级别的缓存，同样是基于 HashMap 进行存储，多个 SqlSession 可以共用二级缓存，其作用域是 mapper 的同一个 namespace。不同的 SqlSession 两次执行相同的 namespace 下的 sql 语句，会执行相同的 sql，第二次查询只会查询第一次查询时读取数据库后写到缓存的数据，不会再去数据库查询。

MyBatis 默认没有开启二级缓存，开启只需在配置文件中写入如下代码：

 

<settings>

<settingname="cacheEnabled"value="true"/>

</settings>

 

 

缓存测试

#### 环境 
- JDK1.7 
- MySQL 5.5.50 
- mybatis 3.3.0

注：MyBatis 下载地址https://github.com/mybatis/mybatis-3/releases

需要的 jar 包

• MyBatis jar 包： mybatis-3.3.0.jar
• MySQL 驱动 jar 包： mysql-connector-java-xxx.jar
• 日志记录 jar 包： log4j-xxx.jar

1.数据库准备

登录 MySQL 后新建一个数据库并取名 mybatis ，创建表 user ，并插入数据：

mysql>createtableuser(

->idintprimarykeyauto_increment,

->namevarchar(20),

->sexvarchar(10),

->ageint);

 

insertintouser(name,sex,age)values('Tom','male',20),('Jack','male',19),('Rose'

    ,'female',18),('Lucy','female',19);

 

 

2.新建工程项目

（1）首先在 Eclipse 里新建一个动态 Web 工程（Dynamic Web Project），命名为 CacheTest 。 
（2）将前面提到的三个 jar 包拷贝到工程的/WebContent/WEB-INF/lib/ 目录下，如下： 

3.实体类

在 Java Resources/src 的包 gler.cache.model 下新建类 User.Java，一个用户具有 id、name、sex、age 属性。

User.java 的代码如下：

4.创建方法接口和定义映射文件

新建包 gler.cache.mapper ，并在包下新建方法接口 UserMapper.java，代码如下：

 

packagegler.cache.mapper;

 

importgler.cache.model.User;

 

publicinterfaceUserMapper{

//刪除用戶

publicintdeleteUser(Integerid)throwsException;

 

//根据id查询用户信息

publicUserselectUserById(Integerid)throwsException;

}

 

 

同样在包下新建映射文件 UserMapper.xml，代码如下：

 

<?xmlversion="1.0"encoding="UTF-8"?>

<!DOCTYPEmapperPUBLIC"-//mybatis.org/DTDMapper3.0""http://mybatis.org/dtd

    /mybatis-3-mapper.dtd">

<mappernamespace="gler.cache.mapper.UserMapper">

<deleteid="deleteUser"parameterType="int">

deletefromuserwhere

id=#{id}

</delete>

 

<selectid="selectUserById"parameterType="int"resultType="User">

select*fromuserwhereid=#{id}

</select>

</mapper>

 

 

5.配置文件 mybatis.cfg.xml

在目录 Java Resources/src 下新建 MyBatis 配置文件 mybatis.cfg.xml，配置如下：

 

<?xmlversion="1.0"encoding="UTF-8"?>

<!DOCTYPEconfigurationPUBLIC"-//mybatis.org//DTDConfig3.0//EN""http

    ://mybatis.org/dtd/mybatis-3-config.dtd">

<configuration>

<typeAliases>

<packagename="gler.cache.model"/>

</typeAliases>

<!--配置mybatis运行环境-->

<environmentsdefault="development">

<environmentid="development">

<!--type="JDBC"代表直接使用JDBC的提交和回滚设置-->

<transactionManagertype="JDBC"/>

 

<!--POOLED表示支持JDBC数据源连接池-->

<!--数据库连接池

    ,由Mybatis管理，数据库名是mybatis，MySQL用户名root，密码为root-->

<dataSourcetype="POOLED">

<propertyname="driver"value="com.mysql.jdbc.Driver"/>

<propertyname="url"value="jdbc:mysql://localhost:3306/mybatis"

    />

<propertyname="username"value="root"/>

<propertyname="password"value="root"/>

</dataSource>

</environment>

</environments>

<mappers>

<!--通过mapper接口包加载整个包的映射文件-->

<packagename="gler/cache/mapper"/>

</mappers>

</configuration>

 

 

6.日志记录 log4j.properties

在项目目录 Java Resources/src 下新建 MyBatis 日志记录文件 log4j.properties，在里面添加如下内容：

 

 

#Globalloggingconfiguration

log4j.rootLogger=DEBUG,stdout

#Consoleoutput...

log4j.appender.stdout=org.apache.log4j.ConsoleAppender

log4j.appender.stdout.layout=org.apache.log4j.PatternLayout

log4j.appender.stdout.layout.ConversionPattern=%5p[%t]-%m%n

 

 

7.缓存测试

（1）创建一个获取 SqlSession 的辅助类 SqlSessionFac

在 Java Resources/src 的包 gler.cache.factory 下新建辅助类 SqlSessionFac，代码如下：

 

packagegler.cache.factory;

 

importjava.io.IOException;

importjava.io.InputStream;

 

importorg.apache.ibatis.io.Resources;

importorg.apache.ibatis.session.SqlSession;

importorg.apache.ibatis.session.SqlSessionFactory;

importorg.apache.ibatis.session.SqlSessionFactoryBuilder;

 

publicclassSqlSessionFac{

privatestaticSqlSessionFactorysqlSessionFactory=null;

static{

Stringresource="mybatis.cfg.xml";

InputStreaminputStream=null;

try{

inputStream=Resources.getResourceAsStream(resource);

}catch(IOExceptione){

e.printStackTrace();

}

sqlSessionFactory=newSqlSessionFactoryBuilder().build(inputStream);

}

 

publicstaticSqlSessiongetSqlSession(){

returnsqlSessionFactory.openSession();

}

}

 

 

（2）一级缓存测试程序 
在 Java Resources/src 的包 gler.cache.test 下新建一级缓存测试类 OneCacheTest，代码如下：

packagegler.cache.test;

 

importgler.cache.factory.SqlSessionFac;

importgler.cache.mapper.UserMapper;

importgler.cache.model.User;

 

importorg.apache.ibatis.session.SqlSession;

 

publicclassOneCacheTest{

publicstaticvoidmain(String[]args)throwsException{

OneCacheTestot=newOneCacheTest();

ot.test1();

//ot.test2();

}

 

//普通测试

publicvoidtest1()throwsException{

SqlSessionsession=SqlSessionFac.getSqlSession();

//第一次查询

Useruser=userMapper.selectUserById(1);

System.out.println(user.toString());

//第二次查询

Useruser2=userMapper.selectUserById(1);

System.out.println(user2.toString());

session.close();

}

 

//有delete操作和commit提交的测试

publicvoidtest2()throwsException{

SqlSessionsession=SqlSessionFac.getSqlSession();

UserMapperuserMapper=session.getMapper(UserMapper.class);

//第一次查询

Useruser=userMapper.selectUserById(1);

System.out.println(user.toString());

//delete和commit

userMapper.deleteUser(3);

session.commit();

//第二次查询

Useruser2=userMapper.selectUserById(1);

System.out.println(user2.toString());

session.close();

}

}

 

 

结果：

（1）运行 tes1() 方法

可以看到只有第一次查询时访问了数据库，第二次查询直接从缓存读取数据。

在这里我们将 test1() 中的代码改为下面的代码：

 

 

publicvoidtest1()throwsException{

//获取SqlSession对象

SqlSessionsession=SqlSessionFac.getSqlSession();

UserMapperuserMapper=session.getMapper(UserMapper.class);

Useruser=userMapper.selectUserById(1);

System.out.println(user.toString());

//关闭

session.close();

//再次获取SqlSession对象

session=SqlSessionFac.getSqlSession();

userMapper=session.getMapper(UserMapper.class);

Useruser2=userMapper.selectUserById(1);

System.out.println(user2.toString());

session.close();

}<imgid="__LEANOTE_D_IMG_1521701475474"title=""src="leanote://file

    /getImage?fileId=5ab3526367279c6b3a00000a"alt="这里写图片描述"data-mce-src

    ="leanote://file/getImage?fileId=5ab3526367279c6b3a00000a">

 

 

同样，由于是不同的 SqlSession，它们之间的缓存数据区域互不影响，因此两次均访问了数据库。

（2）运行test2() 方法

可以看到两次查询均访问了数据库，那是因为有 delete 操作，并把操作提交到了数据库，MyBatis 清空了缓存。

（3）二级缓存测试程序

首先我们先在配置文件中开启二级缓存

注：settings 元素在 configuration 标签元素中书写顺序排在第二位

<settings>

<settingname="cacheEnabled"value="true"/>

</settings>

 

 

接着在 UserMapper.xml 映射文件中开启当前 mapper 的 namespace 下的二级缓存

<cacheeviction="LRU"flushInterval="60000"size="512"readOnly="true"></cache>

 

 

注：cache 元素书写顺序排在第一位

在 Java Resources/src 的包 gler.cache.test 下新建一级缓存测试类 TwoCacheTest，代码如下：

packagegler.cache.test;

 

importgler.cache.factory.SqlSessionFac;

importgler.cache.mapper.UserMapper;

importgler.cache.model.User;

 

importorg.apache.ibatis.session.SqlSession;

 

publicclassTwoCacheTest{

publicstaticvoidmain(String[]args)throwsException{

TwoCacheTesttt=newTwoCacheTest();

tt.test();

}

 

publicvoidtest()throwsException{

//获取SqlSession对象

SqlSessionsession=SqlSessionFac.getSqlSession();

UserMapperuserMapper=session.getMapper(UserMapper.class);

Useruser=userMapper.selectUserById(1);

System.out.println(user.toString());

//关闭

session.close();

 

//再次获取SqlSession对象

session=SqlSessionFac.getSqlSession();

userMapper=session.getMapper(UserMapper.class);

Useruser2=userMapper.selectUserById(1);

System.out.println(user2.toString());

session.close();

}

}

可以看到只有第一次查询时访问了数据库，第二次查询直接从二级缓存读取数据