mybatis基础系列(四)——关联查询、延迟加载、一级缓存与二级缓存
关本文是mybatis基础系列的第四篇文章,点击下面链接可以查看前面的文章:
关联查询
表设计时通常需要分析表与表的关联关系、数据库级别表与表之间的业务关系。
一对一查询
员工表和部门表之间的关系分析:一个员工只能属于一个部门。
需求:查询出员工编号为7369的员工信息和部门信息。
sql语句:
select * from t_emp join t_dept on(t_emp.deptno=t_dept.deptno) where t_emp.empno=7369
resulttype映射
看看mybatis中的写法
mapper.xml
<select id="queryempdeptinfo" parametertype="com.itpsc.request.emprequest" resulttype="com.itpsc.vo.empvo"> select * from t_emp join t_dept on(t_emp.deptno=t_dept.deptno) where t_emp.empno=#{emp.empno} </select>
扩展emp类增加部门熟悉
public class empvo extends emp{ //增加dept表的属性 private integer deptno; private string dname; private string loc; //.... }
运行结果
==> preparing: select * from t_emp join t_dept on(t_emp.deptno=t_dept.deptno) where t_emp.empno=? ==> parameters: 7369(integer) <== columns: empno, ename, job, mgr, hiredate, sal, comm, deptno, deptno, dname, loc <== row: 7369, smith, clerk, 7902, 1980-12-17, 800.00, null, 20, 20, research, dallas <== total: 1 closing non transactional sqlsession [org.apache.ibatis.session.defaults.defaultsqlsession@266e9dda] emp{empno=7369, ename='smith', job='clerk', mgr=7902, hiredate=wed dec 17 00:00:00 cst 1980, sal=800.0, comm=null, deptno=null}
从上面可以看出,如果输出映射的实体类中没有包括查询出来的列名,需要增加列名对应的属性,即可完成映射。
resultmap映射
除了用empvo类继承emp类并且增加部门属性外,也可以在emp类中增加dept类型的对象来完成映射。mapper.xml中association 标签来映射关联对象。
public class emp { private integer empno; private string ename; private string job; private integer mgr; private date hiredate; private float sal; private float comm; private integer deptno; private dept dept; //.... }
mybatis的写法
<select id="queryempdeptinfo" parametertype="com.itpsc.request.emprequest" resultmap="empmap"> select * from t_emp join t_dept on(t_emp.deptno=t_dept.deptno) where t_emp.empno=#{emp.empno} </select> <resultmap id="empmap" type="com.itpsc.entity.emp" > <result column="empno" property="empno" jdbctype="integer" /> <result column="ename" property="ename" jdbctype="varchar" /> <result column="job" property="job" jdbctype="varchar" /> <result column="mgr" property="mgr" jdbctype="integer" /> <result column="hiredate" property="hiredate" jdbctype="date" /> <result column="sal" property="sal" jdbctype="real" /> <result column="comm" property="comm" jdbctype="real" /> <result column="deptno" property="deptno" jdbctype="integer" /> <association property="dept" javatype="com.itpsc.entity.dept"> <result column="deptno" property="deptno" jdbctype="integer" /> <result column="dname" property="dname" jdbctype="varchar" /> <result column="loc" property="loc" jdbctype="varchar" /> </association> </resultmap>
运行结果
==> preparing: select * from t_emp join t_dept on(t_emp.deptno=t_dept.deptno) where t_emp.empno=? ==> parameters: 7369(integer) <== columns: empno, ename, job, mgr, hiredate, sal, comm, deptno, deptno, dname, loc <== row: 7369, smith, clerk, 7902, 1980-12-17, 800.00, null, 20, 20, research, dallas <== total: 1 closing non transactional sqlsession [org.apache.ibatis.session.defaults.defaultsqlsession@2a87ba34] emp{empno=7369, ename='smith', job='clerk', mgr=7902, hiredate=wed dec 17 00:00:00 cst 1980, sal=800.0, comm=null, deptno=20, dept=dept{deptno=20, dname='research', loc='dallas'}}
一对多查询
部门表和员工表之间的关系分析:一个部门可以有多个员工。
需求:查询部门编号为20的所有员工的信息。
sql语句语法:
select t_emp.* from t_emp join t_dept on(t_emp.deptno=t_dept.deptno) where t_dept.deptno=20;
看看mybatis中的写法:
<select id="queryempinfobydeptno" parametertype="com.itpsc.request.emprequest" resulttype="com.itpsc.entity.emp"> select t_emp.* from t_emp join t_dept on(t_emp.deptno=t_dept.deptno) where t_dept.deptno=#{emp.deptno}; </select>
运行结果
==> preparing: select t_emp.* from t_emp join t_dept on(t_emp.deptno=t_dept.deptno) where t_dept.deptno=?; ==> parameters: 20(integer) <== columns: empno, ename, job, mgr, hiredate, sal, comm, deptno <== row: 7369, smith, clerk, 7902, 1980-12-17, 800.00, null, 20 <== row: 7566, jones, manager, 7839, 1981-04-02, 2975.00, null, 20 <== row: 7788, scott, analyst, 7566, 1987-04-19, 3000.00, null, 20 <== row: 7876, adams, clerk, 7788, 1987-05-23, 1100.00, null, 20 <== row: 7902, ford, analyst, 7566, 1981-12-03, 3000.00, null, 20 <== row: 7100, itpsc, mannager, 7902, 1980-01-10, null, 1000.00, 20 <== row: 7101, itpsc2, developer, 7902, 1980-01-10, 2000.00, 1000.00, 20 <== total: 7
多对多查询
部门表和员工表之间的关系分析:一个部门可以有多个员工。
员工表和技能表之间的关系分析:一个员工可以有多个技能。
需求:查询部门编号为20的所有员工的信息,并查询这些员工拥有的技能。
sql 语句:
select t1.*,t_skill.* from ( select t_dept.*, t_emp.empno, t_emp.ename, t_emp.job, t_emp.mgr, t_emp.hiredate, t_emp.sal from t_emp join t_dept on(t_emp.deptno=t_dept.deptno) where t_dept.deptno=20) t1 join t_skill on (t1.empno=t_skill.empno);
deptmapper.xml
<mapper namespace="com.itpsc.mapper.deptmapper" > <!--查询部门信息--> <resultmap id="deptmap" type="com.itpsc.entity.dept" > <result column="deptno" property="deptno" jdbctype="integer" /> <result column="dname" property="dname" jdbctype="varchar" /> <result column="loc" property="loc" jdbctype="varchar" /> <!--查询部门下的员工信息,一个部门有多个员工,用collection--> <collection property="emplist" oftype="com.itpsc.entity.emp"> <result column="empno" property="empno" jdbctype="integer" /> <result column="ename" property="ename" jdbctype="varchar" /> <result column="job" property="job" jdbctype="varchar" /> <result column="mgr" property="mgr" jdbctype="integer" /> <result column="hiredate" property="hiredate" jdbctype="date" /> <result column="sal" property="sal" jdbctype="real" /> <result column="comm" property="comm" jdbctype="real" /> <collection property="skilllist" oftype="com.itpsc.entity.skill"> <result column="skillid" property="skillid" jdbctype="integer" /> <result column="empno" property="empno" jdbctype="integer" /> <result column="sname" property="sname" jdbctype="varchar" /> <result column="descs" property="descs" jdbctype="varchar" /> </collection> </collection> </resultmap> <select id="querybydeptno" parametertype="com.itpsc.request.emprequest" resultmap="deptmap"> select t1.*,t_skill.* from ( select t_dept.*, t_emp.empno, t_emp.ename, t_emp.job, t_emp.mgr, t_emp.hiredate, t_emp.sal from t_emp join t_dept on(t_emp.deptno=t_dept.deptno) where t_dept.deptno=#{emp.deptno}) t1 join t_skill on (t1.empno=t_skill.empno); </select> </mapper>
运行结果
==> preparing: select t1.*,t_skill.* from ( select t_dept.*, t_emp.empno, t_emp.ename, t_emp.job, t_emp.mgr, t_emp.hiredate, t_emp.sal from t_emp join t_dept on(t_emp.deptno=t_dept.deptno) where t_dept.deptno=?) t1 join t_skill on (t1.empno=t_skill.empno); ==> parameters: 20(integer) ... <== total: 6 closing non transactional sqlsession [org.apache.ibatis.session.defaults.defaultsqlsession@1129829c] dept{deptno=20, dname='research', loc='dallas', emplist=[emp{empno=7100, ename='itpsc', job='mannager', mgr=7902, hiredate=thu jan 10 00:00:00 cst 1980, sal=null, comm=null, deptno=null, skilllist=[skill{skillid=1001, empno=7100, sname='mybatis', descs='database crud'}, skill{skillid=1002, empno=7100, sname='mysql', descs='data store'}, skill{skillid=1003, empno=7100, sname='java', descs='program language'}]}, emp{empno=7369, ename='smith', job='clerk', mgr=7902, hiredate=wed dec 17 00:00:00 cst 1980, sal=800.0, comm=null, deptno=null, skilllist=[skill{skillid=1004, empno=7369, sname='spring', descs='spring'}, skill{skillid=1005, empno=7369, sname='spring mvc', descs='spring mvc'}, skill{skillid=1006, empno=7369, sname='thymealf', descs='thymealf'}]}]}
总结
resulttype:将查询结果按照表列名与java对象属性名一一对应映射到java对象中。
resultmap:自定义表列名与java对象属性名之间的映射关系。结合association和collection完成一对一和一对多高级映射。association标签的作用是将关联的信息映射到一个对象中,实现一对一的映射。而collection标签将关联信息映射到一个list集合中,实现一对多的映射。
延迟加载
延迟加载基本概念
上面我们已经知道使用association、collection可以实现一对一及一对多映射,association、collection还有另外一个延迟加载的功能。
延迟加载(lazy load)是关联对象默认的加载方式,延迟加载机制是为了避免一些无谓的性能开销而提出来的,所谓延迟加载就是当在真正需要数据的时候,才真正执行数据加载操作。
mybatis默认没有开启延迟加载功能,需要在springboot的yml配置文件中启动延迟加载功能:
mybatis-plus: mapper-locations: "classpath:com/itpsc/mapper/**/*.xml" type-aliases-package: "com.itpsc.entity" global-config: db-column-underline: true configuration: map-underscore-to-camel-case: true cache-enabled: true #配置的缓存的全局开关 lazyloadingenabled: true #延时加载的开关 log-impl: org.apache.ibatis.logging.stdout.stdoutimpl #打印sql语句,调试用
延迟加载例子
比如查询员工信息的时候关联查询员工的部门信息。我们可以先把员工信息查询出来,当遍历员工信息需要查询对应的部门信息的时候,就可以调用员工的getdept()方法去加载部门信息。
empmapper.xml
<!--resultmap 延迟加载--> <resultmap id="emplazyloaddeptmap" type="com.itpsc.entity.emp" > <result column="empno" property="empno" jdbctype="integer" /> <result column="ename" property="ename" jdbctype="varchar" /> <result column="job" property="job" jdbctype="varchar" /> <result column="mgr" property="mgr" jdbctype="integer" /> <result column="hiredate" property="hiredate" jdbctype="date" /> <result column="sal" property="sal" jdbctype="real" /> <result column="comm" property="comm" jdbctype="real" /> <result column="deptno" property="deptno" jdbctype="integer" /> <!--延迟加载关联对象,emp对象中延迟加载dept对象--> <association property="dept" javatype="com.itpsc.entity.dept" select="com.itpsc.mapper.deptmapper.querybydeptno" column="deptno"> </association> </resultmap> <select id="queryemplazyloaddept" resultmap="emplazyloaddeptmap"> select * from t_emp; </select>
deptmapper.xml
<select id="querybydeptno" parametertype="int" resulttype="com.itpsc.entity.dept"> select * from t_dept where t_dept.deptno=#{emp.deptno} </select>
测试代码
@test public void testqueryemplazyloaddept() { list<emp> emplist = empservice.queryemplazyloaddept(); system.out.println(emplist.size()); for(int i=0;i<emplist.size();i++) { emp emp = emplist.get(i); system.out.println("员工信息:" + emp.tostring()); system.out.println("员工所有部门信息:" + emp.getdept()); } }
运行结果
jdbc connection [com.mysql.jdbc.jdbc4connection@1cd6b1bd] will not be managed by spring ==> preparing: select * from t_dept where t_dept.deptno=? ==> parameters: 10(integer) <== columns: deptno, dname, loc <== row: 10, accounting, new york <== total: 1 员工信息:emp{empno=7934, ename='miller', job='clerk', mgr=7782, hiredate=sat jan 23 00:00:00 cst 1982, sal=1300.0, comm=null, deptno=10, skilllist=null} 员工所有部门信息:dept{deptno=10, dname='accounting', loc='new york'}
从运行结果可以看出,调用emp对象的getdept()方法是,才发出查询部门信息的sql语句,达到延迟加载的作用。
mybatis缓存
缓存的作用,主要是为了提高查询访问速度,某些数据被频繁查询时,可以缓存到内存中而不是每次都从数据库查询,这样可以减轻数据库压力。
mybatis的缓存机制,根据缓存的作用域(生命周期)可以划分为2种:一级查询缓存和二级查询缓存。
一级缓存介绍
一级缓存是sqlsession级别的缓存。每个sqlsession中持有了executor,每个executor中有一个hashmap类型的cache(我们称为local cache)。不同的sqlsession之间的缓存数据区域(hashmap)是互相不影响的。其作用域是sqlsession,当一个sqlsessoin结束后,该sqlsession中的一级查询缓存也就不存在了。
当用户发起查询时,在local cache进行查询,如果缓存命中的话,直接返回结果给用户,如果缓存没有命中的话,查询数据库结果写入local cache,最后返回结果给用户。
一级缓存失效问题
@test public void testquerybyid() { system.out.println(empservice.querybyid(7369)); system.out.println(empservice.querybyid(7369)); }
运行结果
creating a new sqlsession sqlsession [org.apache.ibatis.session.defaults.defaultsqlsession@66d25ba9] was not registered for synchronization because synchronization is not active jdbc connection [com.mysql.jdbc.jdbc4connection@31efacad] will not be managed by spring ==> preparing: select * from t_emp where empno=? ==> parameters: 7369(integer) <== columns: empno, ename, job, mgr, hiredate, sal, comm, deptno <== row: 7369, smith, clerk, 7902, 1980-12-17, 800.00, null, 20 <== total: 1 closing non transactional sqlsession [org.apache.ibatis.session.defaults.defaultsqlsession@66d25ba9] emp{empno=7369, ename='smith', job='clerk', mgr=7902, hiredate=wed dec 17 00:00:00 cst 1980, sal=800.0, comm=null, deptno=20, skilllist=null} creating a new sqlsession sqlsession [org.apache.ibatis.session.defaults.defaultsqlsession@2df65a56] was not registered for synchronization because synchronization is not active jdbc connection [com.mysql.jdbc.jdbc4connection@31efacad] will not be managed by spring ==> preparing: select * from t_emp where empno=? ==> parameters: 7369(integer) <== columns: empno, ename, job, mgr, hiredate, sal, comm, deptno <== row: 7369, smith, clerk, 7902, 1980-12-17, 800.00, null, 20 <== total: 1 closing non transactional sqlsession [org.apache.ibatis.session.defaults.defaultsqlsession@2df65a56] emp{empno=7369, ename='smith', job='clerk', mgr=7902, hiredate=wed dec 17 00:00:00 cst 1980, sal=800.0, comm=null, deptno=20, skilllist=null}
从上面的结果可以看出,执行2次querybyid方法分别创建了2次sqlsession,也就是mybatis的一级缓存没有起作用,这是因为与spring框架整合后的导致的。
mybatis的会话提供了编程式的事务管理,通过sqlsession.commit(), sqlsession.rollback() or sqlsession.close()这些方法进行事务管理。但是当与spring整合后,事务将交由spring管理,这就意味着你不能手动编程式的管理事务了。spring对mybatis的sqlsession的使用是由template控制的,每次数据库操作申请一个sqlsession,使用完后就关闭。所以就产生了上面一级缓存失效的问题。
二级缓存介绍
mybaits的二级缓存是mapper范围级别,多个sqlsession之间可以共享二级缓存。二级缓存开启后,每一个namespace的mapper都有一个二缓存区域。当开启二级缓存后,数据的查询执行的流程就是二级缓存 -> 一级缓存 -> 数据库。
二级缓存验证
开启二级缓存,实体要实现serializable接口序列化。
mybatis-plus: mapper-locations: "classpath:com/itpsc/mapper/**/*.xml" type-aliases-package: "com.itpsc.entity" global-config: db-column-underline: true configuration: map-underscore-to-camel-case: true cache-enabled: true #打开二级缓存 lazyloadingenabled: true #延时加载的开关 log-impl: org.apache.ibatis.logging.stdout.stdoutimpl #打印sql语句,调试用
测试代码
@test public void testquerybyid() { system.out.println(empservice.querybyid(7369)); system.out.println(empservice.querybyid(7369)); }
运行结果
creating a new sqlsession sqlsession [org.apache.ibatis.session.defaults.defaultsqlsession@7db40fd5] was not registered for synchronization because synchronization is not active cache hit ratio [com.itpsc.mapper.empmapper]: 0.0 jdbc connection [com.mysql.jdbc.jdbc4connection@670342a2] will not be managed by spring ==> preparing: select * from t_emp where empno=? ==> parameters: 7369(integer) <== columns: empno, ename, job, mgr, hiredate, sal, comm, deptno <== row: 7369, smith, clerk, 7902, 1980-12-17, 800.00, null, 20 <== total: 1 closing non transactional sqlsession [org.apache.ibatis.session.defaults.defaultsqlsession@7db40fd5] emp{empno=7369, ename='smith', job='clerk', mgr=7902, hiredate=wed dec 17 00:00:00 cst 1980, sal=800.0, comm=null, deptno=20, skilllist=null} creating a new sqlsession sqlsession [org.apache.ibatis.session.defaults.defaultsqlsession@c412556] was not registered for synchronization because synchronization is not active cache hit ratio [com.itpsc.mapper.empmapper]: 0.5 closing non transactional sqlsession [org.apache.ibatis.session.defaults.defaultsqlsession@c412556] emp{empno=7369, ename='smith', job='clerk', mgr=7902, hiredate=wed dec 17 00:00:00 cst 1980, sal=800.0, comm=null, deptno=20, skilllist=null}
可以看出,创建了两个sqlsession,第二次会话并没有去数据库查询而是从二级缓存中查询。
禁用或者刷新二级缓存
在statement中设置usecache=”false”可以禁用当前select语句的二级缓存,默认情况是true。如下:
<select id="querybyid" parametertype="int" resulttype="com.itpsc.entity.emp" usecache="false"> select * from t_emp where empno=#{empno} </select>
通常情况下insert、update、delete操作后需要刷新缓存,这时可以在对应的statement中设置flushcache="true",默认情况下为true。
<insert id="add" parametertype="com.itpsc.entity.emp" flushcache="true"> insert into t_emp(empno,ename,job,mgr,hiredate,sal,comm,deptno) values(#{empno},#{ename},#{job},#{mgr},#{hiredate,jdbctype=date},#{sal},#{comm},#{deptno}) </insert>
上一篇: c#根据字符串进行排序
下一篇: WebSocket API 学习笔记