基础

说说什么是MyBatis?

image-20220831124353772

优点:
Mybatis 是一个半 ORM(对象关系映射)框架,它内部封装了 JDBC,开发时只需要关注SQL 语句本身,不需要花费精力去处理加载驱动、创建连接、创建statement 等繁杂的过程。程序员直接编写原生态 sql,可以严格控制 sql 执行性能,灵活度高。MyBatis 可以使用 XML 或注解来配置和映射原生信息,将 POJO 映射成数据库中的记录,避免了几乎所有的 JDBC 代码和手动设置参数以及获取结果集。

缺点:
SQL语句的编写工作量较大,尤其当字段多、关联表多时,对开发人员编写SQL语句的功底有一定要求SQL语句依赖于数据库,导致数据库移植性差,不能随意更换数据库。

ORM是什么?

image-20220831124733088

ORM(Object Relational Mapping),对象关系映射,是一种为了解决关系型数据库数据与简单Java对象(POJO)的映射关系的技术。简单来说,ORM是通过使用描述对象和数据库之间映射的元数据,将程序中的对象自动持久化到关系型数据库中。

为什么说Mybatis是半自动ORM映射工具?它与全自动的区别在哪里?

Hibernate属于全自动ORM映射工具,使用Hibernate查询关联对象或者关联集合对象时,可以根据对象关系模型直接获取,所以它是全自动的。而Mybatis在查询关联对象或关联集合对象时,需要手动编写SQL来完成,所以,被称之为半自动ORM映射工具。

JDBC编程有哪些不足之处,MyBatis是如何解决的?

image-20220831125002543

1 、数据连接创建、释放频繁造成系统资源浪费从而影响系统性能
解决:在mybatis-config.xml中配置数据链接池,使用连接池统一管理数据库连接。
2 、sql语句写在代码中造成代码不易维护
解决:将sql语句配置在XXXXmapper.xml文件中与java代码分离。
3 、向sql语句传参数麻烦,因为sql语句的where条件不一定,可能多也可能少,占位符需要和参数一一对应。
解决: Mybatis自动将java对象映射至sql语句。
4 、对结果集解析麻烦,sql变化导致解析代码变化,且解析前需要遍历,如果能将数据库记录封装成pojo对象解析比较方便。
解决:Mybatis自动将sql执行结果映射至java对象。

Hibernate 和 MyBatis 有什么区别?

相同点

都是对jdbc的封装,都是应用于持久层的框架。

不同点

映射关系
MyBatis 是一个半自动映射的框架,配置Java对象与sql语句执行结果的对应关系,多表关联关系配置简单
Hibernate 是一个全表映射的框架,配置Java对象与数据库表的对应关系,多表关联关系配置复杂

SQL优化和移植性
Hibernate 对SQL语句封装,提供了日志、缓存、级联(级联比 MyBatis 强大)等特性,此外还提供 HQL(Hibernate Query Language)操作数据库,数据库无关性支持好,但会多消耗性能。如果项目需要支持多种数据库,代码开发量少,但SQL语句优化困难。
MyBatis 需要手动编写 SQL,支持动态 SQL、处理列表、动态生成表名、支持存储过程。开发工作量相对大些。直接使用SQL语句操作数据库,不支持数据库无关性,但sql语句优化容易。

MyBatis和Hibernate的适用场景?

image-20220831130749515

  • Hibernate 是标准的ORM框架,SQL编写量较少,但不够灵活,适合于需求相对稳定,中小型的软件项目,比如:办公自动化系统
  • MyBatis 是半ORM框架,需要编写较多SQL,但是比较灵活,适合于需求变化频繁,快速迭代的项目,比如:电商网站

MyBatis使用过程?生命周期?

MyBatis基本使用的过程大概可以分为这么几步:

image-20220831150538063

1 、 创建SqlSessionFactory

  • 可以从配置或者直接编码来创建SqlSessionFactory
1
2
3
4
String resource = "org/mybatis/example/mybatis-config.xml";
InputStream inputStream = Resources.getResourceAsStream(resource);
SqlSessionFactory sqlSessionFactory = new
SqlSessionFactoryBuilder().build(inputStream);

2 、 通过SqlSessionFactory创建SqlSession

  • SqlSession(会话)可以理解为程序和数据库之间的桥梁
1
SqlSession session = sqlSessionFactory.openSession();

3 、 通过sqlsession执行数据库操作

  • ​ 可以通过 SqlSession 实例来直接执行已映射的 SQL 语句:
1
Blog blog =(Blog)session.selectOne("org.mybatis.example.BlogMapper.selectBlog",101 );
  • ​ 更常用的方式是先获取Mapper(映射),然后再执行SQL语句:
1
2
BlogMapper mapper = session.getMapper(BlogMapper.class);
Blog blog = mapper.selectBlog( 101 );

4 、 调用session.commit()提交事务

  • 如果是更新、删除语句,我们还需要提交一下事务。

5 、 调用session.close()关闭会话

  • 最后一定要记得关闭会话。

MyBatis生命周期?

上面提到了几个MyBatis的组件,一般说的MyBatis生命周期就是这些组件的生命周期。

  • SqlSessionFactoryBuilder

    • 一旦创建了 SqlSessionFactory,就不再需要它了。 因此 SqlSessionFactoryBuilder 实例的生命周期只存在于方法的内部。
  • SqlSessionFactory

    • SqlSessionFactory 是用来创建SqlSession的,相当于一个数据库连接池,每次创建SqlSessionFactory都会使用数据库资源,多次创建和销毁是对资源的浪费。所以SqlSessionFactory是应用级的生命周期,而且应该是单例的。
  • SqlSession

    • SqlSession相当于JDBC中的Connection,SqlSession 的实例不是线程安全的,因此是不能被共享的,所以它的最佳的生命周期是一次请求或一个方法。
  • Mapper

    • 映射器是一些绑定映射语句的接又。映射器接又的实例是从 SqlSession 中获得的,它的生命周期在sqlsession事务方法之内,一般会控制在方法级。

image-20220831155449848

当然,万物皆可集成Spring,MyBatis通常也是和Spring集成使用,Spring可以帮助我们创建线程安全的、基于事务的 SqlSession 和映射器,并将它们直接注入到我们的 bean 中,我们不需要关心它们的创建过程和生命周期,那就是另外的故事了。

在mapper中如何传递多个参数?

image-20220831155632178

方法 1 :顺序传参法

1
2
3
4
5
6
public User selectUser(String name, int deptId);

<select id="selectUser" resultMap="UserResultMap">
select * from user
where user_name = #{ 0 } and dept_id = #{ 1 }
</select>
  • #{}里面的数字代表传入参数的顺序。
  • 这种方法不建议使用,sql层表达不直观,且一旦顺序调整容易出错。

方法 2 :@Param注解传参法

1
2
3
4
5
6
public User selectUser(@Param("userName") String name, int @Param("deptId") deptId)

<select id="selectUser" resultMap="UserResultMap">
select * from user
where user_name = #{userName} and dept_id = #{deptId}
</select>
  • #{}里面的名称对应的是注解@Param括号里面修饰的名称。
  • 这种方法在参数不多的情况还是比较直观的,(推荐使用)。

方法 3 :Map传参法

1
2
3
4
5
6
public User selectUser(Map<String, Object> params);

<select id="selectUser" parameterType="java.util.Map" resultMap="UserResultMap">
select * from user
where user_name = #{userName} and dept_id = #{deptId}
</select>
  • #{}里面的名称对应的是Map里面的key名称。
  • 这种方法适合传递多个参数,且参数易变能灵活传递的情况。

方法 4 :Java Bean传参法

1
2
3
4
5
public User selectUser(User user);
<select id="selectUser" parameterType="com.jourwon.pojo.User" resultMap="UserResultMap">
select * from user
where user_name = #{userName} and dept_id = #{deptId}
</select>
  • #{}里面的名称对应的是User类里面的成员属性。
  • 这种方法直观,需要建一个实体类,扩展不容易,需要加属性,但代码可读性强,业务逻辑处理方便,推荐使用。(推荐使用)。

实体类属性名和表中字段名不一样 ,怎么办?

  • 第 1 种: 通过在查询的SQL语句中定义字段名的别名,让字段名的别名和实体类的属性名一致。
1
2
3
4
5
<select id="getOrder" parameterType="int"
resultType="com.jourwon.pojo.Order">
select order_id id, order_no orderno ,order_price price form
orders where order_id=#{id};
</select>
  • 第 2 种: 通过resultMap 中的来映射字段名和实体类属性名的一一对应的关系。
1
2
3
4
5
6
7
8
9
10
11
<select id="getOrder" parameterType="int" resultMap="orderResultMap">
select * from orders where order_id=#{id}
</select>

<resultMap type="com.jourwon.pojo.Order" id="orderResultMap">
<!–用id属性来映射主键字段–>
<id property="id" column="order_id">
<!–用result属性来映射非主键字段,property为实体类属性名,column为数据库表中的属性–>
<result property ="orderno" column ="order_no"/>
<result property="price" column="order_price" />
</reslutMap>

Mybatis是否可以映射Enum枚举类?

  • Mybatis当然可以映射枚举类,不单可以映射枚举类,Mybatis可以映射任何对象到表的一列上。映射方式为自定义一个TypeHandler,实现TypeHandler的setParameter()和getResult()接口方法。
  • TypeHandler有两个作用,一是完成从javaType至jdbcType的转换,二是完成jdbcType至javaType的转换,体现为setParameter()和getResult()两个方法,分别代表设置sql问号占位符参数和获取列查询结果。

#{}和${}的区别?

image-20220831165343833

  • #{}是占位符,预编译处理;${}是拼接符,字符串替换,没有预编译处理。
  • Mybatis在处理#{}时,#{}传入参数是以字符串传入,会将SQL中的#{}替换为?号,调用PreparedStatement的set方法来赋值。
  • #{} 可以有效的防止SQL注入,提高系统安全性;${} 不能防止SQL 注入
  • #{} 的变量替换是在DBMS 中;${} 的变量替换是在 DBMS 外

例:

1
select * from user where name = #{userName};

设userName=yuze

看日志我们可以看到解析时将#{userName}替换成了

1
select * from user where name = ?;

然后再把yuze放进去,外面加上单引号

Mybatis在处理的 时 候 就 是 把 {}的时候就是把的时候就是把{}替换成变量的值,调用Statement来赋值
如:

1
select * from user where name = #{userName};

设userName=yuze

看日志可以发现就是直接把值拼接上去了

1
select * from user where name = yuze;

这极有可能发生sql注入,下面举了一个简单的sql注入案例

当用户登录,我们验证账号密码是否正确时用这个sql:

username=yyy;password=123

1
select * from user where username=${username} and password=${password}

显然这条sql没问题可以查出来,但是如果有人不知道密码但是想登录账号怎么办

我们不需要填写正确的密码:

密码输入1 or 1=1,sql执行的其实是

1
select * from user where username='yyy' and password=1 or 1 =1

#{}的变量替换是在DBMS中、变量替换后,#{}对应的变量自动加上单引号

${}的变量替换是在DBMS外,变量替换后 ,{}的变量替换是在DBMS外、变量替换后,的变量替换是在DBMS外、变量替换后,{}对应的变量不会加上单引号

使用#{}可以有效的防止sql注入,提高系统的安全性

模糊查询like语句该怎么写?

image-20220831172605851

1 ’**%${question}%**’ 可能引起SQL注入,不推荐
2 “%”#{question}”%” 注意:因为#{…}解析成sql语句时候,会在变量外侧自动加单引号’’,所以这里 % 需要使用双引号” “,不能使用单引号 ’ ‘,不然会查不到任何结果。
3 CONCAT(’%’,#{question},’%’) 使用CONCAT()函数,(推荐✨)
4 使用bind标签(不推荐)

1
2
3
4
5
<select id="listUserLikeUsername" resultType="com.jourwon.pojo.User">
<bind name="pattern" value="'%' + username + '%'" />
select id,sex,age,username,password from person where username LIKE #
{pattern}
</select>

Mybatis能执行一对一、一对多的关联查询吗?

当然可以,不止支持一对一、一对多的关联查询,还支持多对多、多对一的关联查询。

image-20220831172905299

  • 一对一

    比如订单和支付是一对一的关系,这种关联的实现:

    实体类:

    1
    2
    3
    4
    5
    6
    7
    8
    9
    public class Order {
    private Integer orderId;
    private String orderDesc;
    /**
    * 支付对象
    */
    private Pay pay;
    //......
    }

    结果映射

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    <!-- 订单resultMap -->
    <resultMap id="peopleResultMap" type="cn.fighter3.entity.Order">
    <id property="orderId" column="order_id" />
    <result property="orderDesc" column="order_desc"/>
    <!--一对一结果映射-->
    <association property="pay" javaType="cn.fighter3.entity.Pay">
    <id column="payId" property="pay_id"/>
    <result column="account" property="account"/>
    </association>
    </resultMap>

    查询就是普通的关联查

    1
    2
    3
    4
    5
    <select id="getTeacher" resultMap="getTeacherMap" parameterType="int">
    select * from order o
    left join pay p on o.order_id=p.order_id
    where o.order_id=#{orderId}
    </select>
  • 一对多
    比如商品分类和商品,是一对多的关系。
    实体类:

    1
    2
    3
    4
    5
    6
    7
    8
    9
    public class Category {
    private int categoryId;
    private String categoryName;
    /**
    * 商品列表
    **/
    List<Product> products;
    //......
    }

    结果映射

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    <resultMap type="Category" id="categoryBean">
    <id column="categoryId" property="category_id" />
    <result column="categoryName" property="category_name"/>
    <!-- 一对多的关系 -->
    <!-- property: 指的是集合属性的值, ofType:指的是集合中元素的类
    型 -->
    <collection property="products" ofType="Product">
    <id column="product_id" property="productId" />
    <result column="productName" property="productName"/>
    <result column="price" property="price" />
    </collection>
    </resultMap>

    查询

    查询就是一个普通的关联查询

    1
    2
    3
    4
    5
    <!-- 关联查询分类和产品表 -->
    <select id="listCategory" resultMap="categoryBean">
    select c.*, p.* from category_ c left join product_ p
    on c.id = p.cid
    </select>

Mybatis是否支持延迟加载?原理?

  • Mybatis支持association关联对象和collection关联集合对象的延迟加载,association指的就是一对一,collection指的就是一对多查询。在Mybatis配置文件中,可以配置是否启用延迟加载lazyLoadingEnabled=true|false。

  • 它的原理是,使用CGLIB创建目标对象的代理对象,当调用目标方法时,进入拦截器方法,比如调用a.getB().getName(),拦截器invoke()方法发现a.getB()是null值,那么就会单独发送事先保存好的查询关联B对象的sql,把B查询上来,然后调用a.setB(b),于是a的对象b属性就有值了,接着完成a.getB().getName()方法的调用。这就是延迟加载的基本原理。

  • 当然了,不光是Mybatis,几乎所有的包括Hibernate,支持延迟加载的原理都是一样的。

如何获取生成的主键?

新增标签中添加:keyProperty=” ID “ 即可

1
2
3
4
5
6
<insert id="insert" useGeneratedKeys="true" keyProperty="userId" >
insert into user(
user_name, user_password, create_time)
values(#{userName}, #{userPassword} , #{createTime, jdbcType=
TIMESTAMP})
</insert>

这时候就可以完成回填主键

1
2
mapper.insert(user);
user.getId;

MyBatis支持动态SQL吗?

MyBatis中有一些支持动态SQL的标签,它们的原理是使用OGNL从SQL参数对象中计算表达式的值,根据表达式的值动态拼接SQL,以此来完成动态SQL的功能。

image-20220831185515276

  • if

    根据条件来组成where子句

    1
    2
    3
    4
    5
    6
    7
    <select id="findActiveBlogWithTitleLike"resultType="Blog">
    SELECT * FROM BLOG
    WHERE state = ‘ACTIVE’
    <if test="title != null">
    AND title like #{title}
    </if>
    </select>
  • choose (when, otherwise)

    这个和Java 中的 switch 语句有点像

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    <select id="findActiveBlogLike" resultType="Blog">
    SELECT * FROM BLOG WHERE state = ‘ACTIVE’
    <choose>
    <when test="title != null">
    AND title like #{title}
    </when>
    <when test="author != null and author.name != null">
    AND author_name like #{author.name}
    </when>
    <otherwise>
    AND featured = 1
    </otherwise>
    </choose>
    </select>
  • trim (where, set)

    • 可以用在所有的查询条件都是动态的情况

      1
      2
      3
      4
      5
      6
      7
      8
      9
      10
      11
      12
      13
      14
      <select id="findActiveBlogLike" resultType="Blog">
      SELECT * FROM BLOG
      <where>
      <if test="state != null">
      state = #{state}
      </if>
      <if test="title != null">
      AND title like #{title}
      </if>
      <if test="author != null and author.name != null">
      AND author_name like #{author.name}
      </if>
      </where>
      </select>
    • 可以用在动态更新的时候

      1
      2
      3
      4
      5
      6
      7
      8
      9
      10
      <update id="updateAuthorIfNecessary">
      update Author
      <set>
      <if test="username != null">username=#{username},</if>
      <if test="password != null">password=#{password},</if>
      <if test="email != null">email=#{email},</if>
      <if test="bio != null">bio=#{bio}</if>
      </set>
      where id=#{id}
      </update>
    • foreach
      看到名字就知道了,这个是用来循环的,可以对集合进行遍历

      1
      2
      3
      4
      5
      6
      7
      8
      9
      10
      <select id="selectPostIn" resultType="domain.blog.Post">
      SELECT *
      FROM POST P
      <where>
      <foreach item="item" index="index" collection="list"
      open="ID in (" separator="," close=")" nullable="true">
      #{item}
      </foreach>
      </where>
      </select>

MyBatis如何执行批量操作?

image-20220831212914015

第一种方法:使用foreach标签

foreach的主要用在构建in条件中,它可以在SQL语句中进行迭代一个集合。foreach标签的属性主要有item,index,collection,open,separator,close。

  • item 表示集合中每一个元素进行迭代时的别名,随便起的变量名;
  • index 指定一个名字,用于表示在迭代过程中,每次迭代到的位置,不常用;
  • open 表示该语句以什么开始,常用“(”;
  • separator 表示在每次进行迭代之间以什么符号作为分隔符,常用“,”;
  • close 表示以什么结束,常用“)”。

在使用foreach的时候最关键的也是最容易出错的就是collection属性,该属性是必须指定的,但是在不同情况下,该属性的值是不一样的,主要有以下 3 种情况:

1. 如果传入的是单参数且参数类型是一个List的时候,collection属性值为list
2. 如果传入的是单参数且参数类型是一个array数组的时候,collection的属性值为array
3. 如果传入的参数是多个的时候,我们就需要把它们封装成一个Map了,当然单参数也可以封装成map,实际上如果你在传入参数的时候,在MyBatis里面也是会把它封装成一个Map的,map的key就是参数名,所以这个时候collection属性值就是传入的List或array对象在自己封装的map里面的key

看看批量保存的两种用法:

1
2
3
4
5
6
7
8
<!-- MySQL下批量保存,可以foreach遍历 mysql支持values(),(),()语法 --> //推荐使用
<insert id="addEmpsBatch">
INSERT INTO emp(ename,gender,email,did)
VALUES
<foreach collection="emps" item="emp" separator=",">
(#{emp.eName},#{emp.gender},#{emp.email},#{emp.dept.id})
</foreach>
</insert>
1
2
3
4
5
6
7
8
<!-- 这种方式需要数据库连接属性allowMutiQueries=true的支持
如jdbc.url=jdbc:mysql://localhost:3306/mybatis?allowMultiQueries=true -->
<insert id="addEmpsBatch">
<foreach collection="emps" item="emp" separator=";">
INSERT INTO emp(ename,gender,email,did)
VALUES(#{emp.eName},#{emp.gender},#{emp.email},#{emp.dept.id})
</foreach>
</insert>

第二种方法:使用ExecutorType.BATCH

Mybatis内置的ExecutorType有 3 种,默认为simple,该模式下它为每个语句的执行创建一个新的预处理语句,单条提交sql;而batch模式重复使用已经预处理的语句,并且批量执行所有更新语句,显然batch性能将更优; 但batch模式也有自己的问题,比如在Insert操作
时,在事务没有提交之前,是没有办法获取到自增的id,在某些情况下不符合业务的需求。
具体用法如下:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
//批量保存方法测试
@Test
public void testBatch() throws IOException{
SqlSessionFactory sqlSessionFactory = getSqlSessionFactory();
//可以执行批量操作的sqlSession
SqlSession openSession = sqlSessionFactory.openSession(ExecutorType.BATCH);
//批量保存执行前时间
long start = System.currentTimeMillis();
try {
EmployeeMapper mapper = openSession.getMapper(EmployeeMapper.class);
for (int i = 0 ; i < 1000 ; i++) {
mapper.addEmp(new
Employee(UUID.randomUUID().toString().substring( 0 , 5 ), "b", "1"));
}
openSession.commit();
long end = System.currentTimeMillis();
//批量保存执行后的时间
System.out.println("执行时⻓" + (end - start));
//批量 预编译sql一次==》设置参数==》 10000 次==》执行 1 次 677
//非批量 (预编译=设置参数=执行 )==》 10000 次 1121
} finally {
openSession.close();
}
}

mapper和mapper.xml如下

1
2
3
4
public interface EmployeeMapper {
//批量保存员工
Long addEmp(Employee employee);
}
1
2
3
4
5
6
7
<mapper namespace="com.jourwon.mapper.EmployeeMapper"
<!--批量保存员工 -->
<insert id="addEmp">
insert into employee(lastName,email,gender)
values(#{lastName},#{email},#{gender})
</insert>
</mapper>

MyBatis中一级缓存和二级缓存详解

缓存的作用

首先缓存的合理使用是优化中最常见的,将从数据库中查询出来的数据放入缓存中,下次使用时不必从数据库查询,而是直接从缓存中读取,避免频繁操作数据库,减轻数据的压力,同时提高系统性能。

为什么需要缓存

BS架构里面,用户的所有操作都是对数据库的增删改查,其中查询的操作是最多的,但如果用户想要某个数据时每次都去数据库查询,这无疑会增加数据库的压力,而且获取时间效率也会降低,所以为了解决这些问题,缓存应用而生,使用了缓存之后,服务器只需要查询一次数据库,然后将数据保存到服务器主机的内存中,以后读取时就直接取内存中的数据,而不需要每次都查数据库,这种方案除了降低数据库压力之外,还提高了响应速度,简直一箭双雕哇~

一级缓存

一级缓存是SqlSession级别的缓存,在操作数据库时需要构造SqlSession对象,在对象中有一个数据结构用于存储缓存数据。不同的sqlSession之间的缓存数据区域是互相不影响的。也就是他只能作用在同一个sqlSession中,不同的sqlSession中的缓存是互相不能读取的。
一级缓存的工作原理:
一级缓存默认是开启的,它在一个sqlSession会话里面的所有查询操作都会保存到缓存中,一般来说一个请求中的所有增删改查操作都是在同一个sqlSession里面的,所以我们可以认为每个请求都有自己的一级缓存,如果同一个sqlSession会话中2 个查询中间有一个 insert 、update或delete 语句,那么之前查询的所有缓存都会清空;
在这里插入图片描述

在这里插入图片描述

1、用户发起查询请求,查询某条数据,sqlSession先去缓存中查找,是否有该条数据,如果有,则读取并返回;如果没有,则需要从数据库中查询,并将查询到的数据放入到一级缓存区域,供下次查找使用。

2、sqlSession执行增删改操作并执行commit操作,则会清空缓存,这样做的目的是避免脏读

3、如果commit不清空缓存,会有以下场景:A查询了某商品库存为10件,并将10件库存的数据存入缓存中,之后被客户买走了10件,数据被delete了,但是下次查询这件商品时,并不从数据库中查询,而是从缓存中查询,就会出现错误。

4、示例代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
public static void main(String[] args) throws IOException {

// 加载mybatis配置文件
Reader reader = Resources.getResourceAsReader("config/configuration.xml");
//创建数据工厂
SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
SqlSessionFactory sqlSessionFactory = builder.build(reader);
SqlSession sqlSession = sqlSessionFactory.openSession(true);


// 获取mapper接口对象
UserMapper mapper = sqlSession.getMapper(UserMapper.class);

// 查询第一次
User user = mapper.selectByPrimaryKey("3rfrf34r34");
// 第二次查询
User user1 = mapper.selectByPrimaryKey("3rfrf34r34");
System.out.println("两个user对象是否相等:"+(user == user1));
//释放会话
sqlSession.clearCache();
sqlSession.close();
}

在这里插入图片描述

根据结果可以看到,代码中执行了2次查询, 但实际运行时只查询了一次数据库,第二次获取数据时直接从缓存中读取,并且2次读取的数据都是一样的,到这里,一级缓存就已经生效了;
接下来我们来测试第二种情况 :查询 -> 修改 -> 查询
示例代码:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
public static void main(String[] args) throws IOException {

// 加载mybatis配置文件
Reader reader = Resources.getResourceAsReader("config/configuration.xml");
//创建数据工厂
SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
SqlSessionFactory sqlSessionFactory = builder.build(reader);
SqlSession sqlSession = sqlSessionFactory.openSession(true);


// 获取mapper接口对象
UserMapper mapper = sqlSession.getMapper(UserMapper.class);
// 查询第一次
User user = mapper.selectByPrimaryKey("3rfrf34r34");
// 修改
mapper.updateByPrimaryKey(user);
// 第二次查询
User user1 = mapper.selectByPrimaryKey("3rfrf34r34");
System.out.println("两个user对象是否相等:"+(user == user1));
//释放会话
sqlSession.clearCache();
sqlSession.close();
}

在这里插入图片描述

控制台打印了三次sql,其中第一个查询和第三个查询是一样的,但是并没有使用缓存,是因为每次增删改操作都有可能会改变原来的数据,所以必须刷新缓存

二级缓存

二级缓存是mapper级别的缓存,多个SqlSession去操作同一个Mapper的sql语句,多个SqlSession可以共用二级缓存,二级缓存是跨SqlSession的。二级缓存的作用范围更大

二级缓存流程图:

在这里插入图片描述

第一种配置方式

单个mapper配置,主需要在需要开启二级缓存的mapper.xml文件中加入以下配置即可开启。

1
2
<!-- 开启单个mapper的二级缓存,也叫全局缓存-->
<cache />

注意一定要加到xxMapper.xml的文件内,千万不要加到[mybatis] 的主配置文件里面了,会报错的。

在这里插入图片描述

第二种配置方式

所有的mapper都开启二级缓存,在mybatis.xml主配置文件中加入以下配置即可

1
2
3
4
5
<settings>
<!-- 开启所有mapper的二级缓存 -->
<!--<setting name="cacheEnabled" value="true" />-->
</settings>

在这里插入图片描述

示例代码:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
    
public static void main(String[] args) throws IOException {
// 加载mybatis配置文件
Reader reader = Resources.getResourceAsReader("config/configuration.xml");
//创建数据工厂
SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();

SqlSessionFactory sqlSessionFactory = builder.build(reader);
// 第一个会话
SqlSession sqlSession = sqlSessionFactory.openSession(true);
// 获取会话一的mapper接口对象
UserMapper mapper = sqlSession.getMapper(UserMapper.class);
// 第一次查询
User user = mapper.selectByPrimaryKey("3rfrf34r34");
//释放第一个会话
sqlSession.clearCache();
sqlSession.close();
// 第二个会话
SqlSession sqlSession2 = sqlSessionFactory.openSession(true);
// 获取会话二的mapper接口对象
UserMapper mapper2 = sqlSession2.getMapper(UserMapper.class);
// 第二次查询
User user1 = mapper2.selectByPrimaryKey("3rfrf34r34");
// 释放第二个会话
sqlSession2.clearCache();
sqlSession2.close();
}

打印结果:

在这里插入图片描述

打印结果很明显,2次查询,但是日志显示只查询了一次数据库, 第二次是从缓存中获取的数据,至此,二级缓存已开启!

总结:

1. 一级缓存: 基于 PerpetualCache 的 HashMap 本地缓存,其存储作用域为SqlSession,各个SqlSession之间的缓存相互隔离,当Session flush 或 close 之后,该 SqlSession 中的所有Cache 就将清空,MyBatis默认打开一级缓存。

image-20220901114614900

2. 二级缓存与一级缓存其机制相同,默认也是采用 PerpetualCache,HashMap 存储,不同之处在于其存储作用域为 Mapper(Namespace),可以在多个SqlSession之间共享,并且可自定义存储源,如 Ehcache。默认不打开二级缓存,要开启二级缓存,使用二级缓存属性类需要实现Serializable序列化接又(可用来保存对象的状态),可在它的映射文件中配置。

image-20220901114627565

原理

能说说MyBatis的工作原理吗?

我们已经大概知道了MyBatis的工作流程,按工作原理,可以分为两大步:生成会话工厂、会话运行

image-20220901123812730

MyBatis是一个成熟的框架,篇幅限制,这里抓大放小,来看看它的主要工作流程。

构建会话工厂

构造会话工厂也可以分为两步:

image-20220901130322195

  • 获取配置

获取配置这一步经过了几步转化,最终由生成了一个配置类Configuration实例,这个配置类实例非常重要,主要作用包括:

  • ​ 读取配置文件,包括基础配置文件和映射文件
  • ​ 初始化基础配置,比如MyBatis的别名,还有其它的一些重要的类对象,像插件、映射器、ObjectFactory等等
  • ​ 提供一个单例,作为会话工厂构建的重要参数
  • ​ 它的构建过程也会初始化一些环境变量,比如数据源
1
2
3
4
5
6
7
8
public SqlSessionFactory build(Reader reader, String environment,Properties properties) {
SqlSessionFactory var5;
//省略异常处理
//xml配置构建器
XMLConfigBuilder parser = new XMLConfigBuilder(reader,environment, properties);
//通过转化的Configuration构建SqlSessionFactory
var5 = this.build(parser.parse());
}
  • 构建SqlSessionFactory

    SqlSessionFactory只是一个接又,构建出来的实际上是它的实现类的实例,一般我们用的都是它的实现类DefaultSqlSessionFactory,

1
2
3
public SqlSessionFactory build(Configuration config) {
return new DefaultSqlSessionFactory(config);
}

会话运行

会话运行是MyBatis最复杂的部分,它的运行离不开四大组件的配合:image-20220901145328294

  • Executor(执行器)
    Executor起到了至关重要的作用,SqlSession只是一个门面,相当于客服,真正干活的是是Executor,就像是默默无闻的工程师。它提供了相应的查询和更新方法,以及事务方法。
1
2
3
4
5
6
Environment environment = this.configuration.getEnvironment();
TransactionFactory transactionFactory = this.getTransactionFactoryFromEnvironment(environment);
tx = transactionFactory.newTransaction(environment.getDataSource(), level, autoCommit);
//通过Configuration创建executor
Executor executor = this.configuration.newExecutor(tx,execType);
var8 = new DefaultSqlSession(this.configuration, executor,autoCommit);
  • StatementHandler(数据库会话器)
    StatementHandler,顾名思义,处理数据库会话的。我们以SimpleExecutor为例,看一下它的查询方法,先生成了一个StatementHandler实例,再拿这个handler去执行query。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
public <E> List<E> doQuery(MappedStatement ms, Object parameter,
RowBounds rowBounds, ResultHandler resultHandler, BoundSql boundSql)throws SQLException {
Statement stmt = null;
List var9;
try {
Configuration configuration = ms.getConfiguration();
StatementHandler handler = configuration.newStatementHandler(this.wrapper, ms, parameter,rowBounds,
resultHandler, boundSql);
stmt = this.prepareStatement(handler,ms.getStatementLog());
var9 = handler.query(stmt, resultHandler);
} finally {
this.closeStatement(stmt);
}
return var9;
}

再以最常用的PreparedStatementHandler看一下它的query方法,其实在上面的prepareStatement已经对参数进行了预编译处理,到了这里,就直接执行sql,使用ResultHandler处理返回结果。

1
2
3
4
5
public <E> List<E> query(Statement statement, ResultHandler resultHandler) throws SQLException {
PreparedStatement ps = (PreparedStatement)statement;
ps.execute();
return this.resultSetHandler.handleResultSets(ps);
}
  • ParameterHandler (参数处理器)
    PreparedStatementHandler里对sql进行了预编译处理
1
2
3
public void parameterize(Statement statement) throws SQLException {
this.parameterHandler.setParameters((PreparedStatement)statement);
}

这里用的就是ParameterHandler,setParameters的作用就是设置预编译SQL语句的参数。里面还会用到typeHandler类型处理器,对类型进行处理。

1
2
3
4
public interface ParameterHandler {
Object getParameterObject();
void setParameters(PreparedStatement var1) throws SQLException;
}
  • ResultSetHandler(结果处理器)

    我们前面也看到了,最后的结果要通过ResultSetHandler来进行处理,handleResultSets这个方法就是用来包装结果集的。Mybatis为我们提供了一个DefaultResultSetHandler,通常都是用这个实现类去进行结果的处理的。

1
2
3
4
5
6
7
public interface ResultSetHandler {
<E> List<E> handleResultSets(Statement var1) throws SQLException;

<E> Cursor<E> handleCursorResultSets(Statement var1) throws SQLException;

void handleOutputParameters(CallableStatement var1) throws SQLException;
}

它会使用typeHandle处理类型,然后用ObjectFactory提供的规则组装对象,返回给调用者。

整体上总结一下会话运行:

image-20220901153231196

把整个的⼯作流程串联起来,简单总结⼀下:

image-20220901153540814

1. 读取 MyBatis 配置文件——mybatis-config.xml 、加载映射文件——映射文件即 SQL 映射文件,文件中配置了操作数据库的 SQL 语句。最后生成一个配置对象
2. 构造会话工厂:通过 MyBatis 的环境等配置信息构建会话工厂 SqlSessionFactory
3. 创建会话对象:由会话工厂创建 SqlSession 对象,该对象中包含了执行 SQL 语句的所有方法。
4. Executor 执行器:MyBatis 底层定义了一个 Executor 接口来操作数据库,它将根据SqlSession 传递的参数动态地生成需要执行的 SQL 语句,同时负责查询缓存的维护。
5. StatementHandler:数据库会话器,串联起参数映射的处理和运行结果映射的处理。
**6.**参数处理:对输入参数的类型进行处理,并预编译
**7.**结果处理:对返回结果的类型进行处理,根据对象映射规则,返回相应的对象。

MyBatis的功能架构是什么样的?

image-20220901154447146

我们一般把Mybatis的功能架构分为三层:

  • API接口层:提供给外部使用的接又API,开发人员通过这些本地API来操纵数据库。接口层一接收到调用请求就会调用数据处理层来完成具体的数据处理。
  • 数据处理层:负责具体的SQL查找、SQL解析、SQL执行和执行结果映射处理等。它主要的目的是根据调用的请求完成一次数据库操作。
  • 基础支撑层:负责最基础的功能支撑,包括连接管理、事务管理、配置加载和缓存处理,这些都是共用的东西,将他们抽取出来作为最基础的组件。为上层的数据处理层提供最基础的支撑。

为什么Mapper接又不需要实现类?

四个字回答: 动态代理 ,我们来看一下获取Mapper的过程:

image-20220901155803040

  • 获取Mapper
    我们都知道定义的Mapper接口是没有实现类的,Mapper映射其实是通过 动态代理 实现的。

    1
    BlogMapper mapper = session.getMapper(BlogMapper.class);

    七拐八绕地进去看一下,发现获取Mapper的过程,需要先获取MapperProxyFactory——Mapper代理工厂。

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    public <T> T getMapper(Class<T> type, SqlSession sqlSession) {
    MapperProxyFactory<T> mapperProxyFactory = (MapperProxyFactory)this.knownMappers.get(type);
    if (mapperProxyFactory == null) {
    throw new BindingException("Type " + type + " is not known
    to the MapperRegistry.");
    } else {
    try {
    return mapperProxyFactory.newInstance(sqlSession);
    } catch (Exception var5) {
    throw new BindingException("Error getting mapper
    instance. Cause: " + var5, var5);
    }
    }
    }
  • MapperProxyFactory
    MapperProxyFactory的作用是生成MapperProxy(Mapper代理对象)。

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    public class MapperProxyFactory<T> {
    private final Class<T> mapperInterface;
    ......
    protected T newInstance(MapperProxy<T> mapperProxy) {
    return
    Proxy.newProxyInstance(this.mapperInterface.getClassLoader(), new Class[]{this.mapperInterface}, mapperProxy);
    }
    public T newInstance(SqlSession sqlSession) {
    MapperProxy<T> mapperProxy = new MapperProxy(sqlSession,
    this.mapperInterface, this.methodCache);
    return this.newInstance(mapperProxy);
    }
    }

    这里可以看到动态代理对接又的绑定,它的作用就是生成动态代理对象(占位),而代理的方法被放到了MapperProxy中。

    • MapperProxy

​ MapperProxy里,通常会生成一个MapperMethod对象,它是通过cachedMapperMethod方法对其进行初始化的,然后执行excute方 法。

1
2
3
4
5
6
7
8
9
public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
try {
return Object.class.equals(method.getDeclaringClass())?
method.invoke(this, args) : this.cachedInvoker(method).invoke(proxy,
method, args, this.sqlSession);
} catch (Throwable var5) {
throw ExceptionUtil.unwrapThrowable(var5);
}
}
  • MapperMethod
    MapperMethod里的excute方法,会真正去执行sql。这里用到了命令模式,其实绕一圈,最终它还是通过SqlSession的实例去运行对象的sql。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
public Object execute(SqlSession sqlSession, Object[] args) {
Object result;
Object param;
......
case SELECT:
if (this.method.returnsVoid() &&
this.method.hasResultHandler()) {
this.executeWithResultHandler(sqlSession, args);
result = null;
} else if (this.method.returnsMany()) {
result = this.executeForMany(sqlSession, args);
} else if (this.method.returnsMap()) {
result = this.executeForMap(sqlSession, args);
} else if (this.method.returnsCursor()) {
result = this.executeForCursor(sqlSession, args);
} else {
param =
this.method.convertArgsToSqlCommandParam(args);
result =
sqlSession.selectOne(this.command.getName(), param);
if (this.method.returnsOptional() && (result == null
|| !this.method.getReturnType().equals(result.getClass()))) {
result = Optional.ofNullable(result);
}
}
break;
......
}

Mybatis都有哪些Executor执行器?

image-20220901162602848

Mybatis有三种基本的Executor执行器,SimpleExecutor、ReuseExecutor、BatchExecutor

  • SimpleExecutor:每执行一次update或select,就开启一个Statement对象,用完立刻关闭Statement对象。
  • ReuseExecutor:执行update或select,以sql作为key查找Statement对象,存在就使用,不存在就创建,用完后,不关闭Statement对象,而是放置于Map<String, Statement>内,供下一次使用。简言之,就是重复使用Statement对象。
  • BatchExecutor:执行update(没有select,JDBC批处理不支持select),将所有sql都添加到批处理中(addBatch()),等待统一执行(executeBatch()),它缓存了多个Statement对象,每个Statement对象都是addBatch()完毕后,等待逐一执行executeBatch()批处理。与JDBC批处理相同。

作用范围:Executor的这些特点,都严格限制在SqlSession生命周期范围内。

Mybatis中如何指定使用哪一种Executor执行器?

  • 在Mybatis配置文件中,在设置(settings)可以指定默认的ExecutorType执行器类型,也可以手动给DefaultSqlSessionFactory的创建SqlSession的方法传递ExecutorType类型参数,如SqlSession openSession(ExecutorType execType)。
  • 配置默认的执行器。SIMPLE 就是普通的执行器;REUSE 执行器会重用预处理语句(prepared statements); BATCH 执行器将重用语句并执行批量更新。

插件

说说Mybatis的插件运行原理,如何编写一个插件?

插件的运行原理?

Mybatis会话的运行需要ParameterHandler、ResultSetHandler、StatementHandler、Executor这四大对象的配合,插件的原理就是在这四大对象调度的时候,插入一些我我们自己的代码。

image-20220901163556036

Mybatis使用JDK的动态代理,为目标对象生成代理对象。它提供了一个工具类Plugin,实现了InvocationHandler接口。

image-20220901163645793

使用Plugin生成代理对象,代理对象在调用方法的时候,就会进入invoke方法,在invoke方法中,如果存在签名的拦截方法,插件的intercept方法就会在这里被我们调用,然后就返回结果。如果不存在签名方法,那么将直接反射调用我们要执行的方法。

如何编写一个插件?

我们自己编写MyBatis 插件,只需要实现拦截器接又 Interceptor (org.apache.ibatis. pluginInterceptor ),在实现类中对拦截对象和方法进行处理。

  • 实现Mybatis的Interceptor接又并重写intercept()方法这里我们只是在目标对象执行目标方法的前后进行了打印;
1
2
3
4
5
6
7
8
9
10
11
12
public class MyInterceptor implements Interceptor {
Properties props=null;
@Override
public Object intercept(Invocation invocation) throws Throwable {
System.out.println("before......");
//如果当前代理的是一个非代理对象,那么就会调用真实拦截对象的方法
// 如果不是它就会调用下个插件代理对象的invoke方法
Object obj=invocation.proceed();
System.out.println("after......");
return obj;
}
}
  • 然后再给插件编写注解,确定要拦截的对象,要拦截的方法
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
@Intercepts({@Signature(
type = Executor.class, //确定要拦截的对象
method = "update", //确定要拦截的方法
args = {MappedStatement.class,Object.class} //拦截方法的参数
)})
public class MyInterceptor implements Interceptor {
Properties props=null;
@Override
public Object intercept(Invocation invocation) throws Throwable {
System.out.println("before......");
//如果当前代理的是一个非代理对象,那么就会调用真实拦截对象的方法
// 如果不是它就会调用下个插件代理对象的invoke方法
Object obj=invocation.proceed();
System.out.println("after......");
return obj;
}
}

最后,在MyBatis配置文件里面配置插件

1
2
3
4
5
<plugins>
<plugin interceptor="xxx.MyPlugin">
<property name="dbType",value="mysql"/>
</plugin>
</plugins>

Mybatis-分页插件

分页插件:

1.添加依赖:

1
2
3
4
5
6
<!-- https://mvnrepository.com/artifact/com.github.pagehelper/pagehelper -->
<dependency>
<groupId>com.github.pagehelper</groupId>
<artifactId>pagehelper</artifactId>
<version>5.2.0</version>
</dependency>

2.在mybatis主配置文件中配置分页插件:

img

分页插件使用:

  使用mybatis的分页插件实现分页功能:

    1.需要在查询功能之前开启分页

     PageHelper.startPage(2【从第几页开始】,4【每页显示的数据】);

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
/**
* limit,index,pageSize
* index:当前页的起始索引
* pageSize:每页显示的信息条数
* pageNum:当前的页码
* index=(pageNum-1)*pageSixe
*/
@Test
public void testHelpPage(){
try {
InputStream in = Resources.getResourceAsStream("Mybatis.xml");
SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(in);
SqlSession session = sqlSessionFactory.openSession(true);
EmpMapper mapper = session.getMapper(EmpMapper.class);
PageHelper.startPage(2,4);
List<Emp> emps = mapper.selectByExample(null);
PageInfo<Emp> page = new PageInfo<>(emps,5);
System.out.println(page);
emps.forEach(emp -> System.out.println(emp));
} catch (IOException e) {
e.printStackTrace();
}
}

2.在查询功能结束后获取分页相关信息

​ PageInfo page = new PageInfo<>(emps,5);进行导航分页

  emps:表示分页数据

  5:表示当前导航分页的数量

​ 运行结果:

img

显示第二页,一页4条数据

结果具体分析:

PageInfo{pageNum=2, pageSize=4, size=4, startRow=5, endRow=8, total=11, pages=3, list=Page{count=true, pageNum=2, pageSize=4, startRow=4, endRow=8, total=11, pages=3, reasonable=false, pageSizeZero=false}prePage=1, nextPage=3, isFirstPage=false, isLastPage=false, hasPreviousPage=true, hasNextPage=true, navigatePages=5, navigateFirstPage=1, navigateLastPage=3, navigatepageNums=[1, 2, 3]}

pageNum=2表示当前页码数
pageSize=4:表示一页的数据
size=4:这第二页的真实数据个数
startRow=5:第二页四个数据从数据库表单中第5个数据开始
endRow=8:第二页四个数据从数据库表单中第8个数据结束
total=11:数据库表单总数据条数
pages=3:总页数
prePage=1:这页的上一页
nextPage=3:这页的下一页
isFirstPage=false:判断是否是第一页
isLastPage=false:判断是否是最后一页
hasPreviousPage=true:是否有上一页
hasNextPage=true:是否有下一页
navigatePages=5:这个就是我们在方法中输入的参数(PageInfo page = new PageInfo<>(emps,5);)
navigateFirstPage=1:导航分页从第1页开始
navigateLastPage=3:导航分页从第3页结束
navigatepageNums=[1, 2, 3]:进行底层运算,计算出导航分页页码

总结:

  a>在查询功能之前使用PageHelper.startPage(int pageNum, int pageSize)开启分页功能

    pageNum:当前页的页码 pageSize:每页显示的条数

  b>在查询获取list集合之后,使用PageInfo pageInfo = new PageInfo<>(List list, int navigatePages)获取分页相关数据

     list:分页之后的数据 navigatePages:导航分页的页码数

  c>分页相关数据

    PageInfo{ pageNum=8, pageSize=4, size=2, startRow=29, endRow=30, total=30, pages=8, list=Page{count=true, pageNum=8, pageSize=4, startRow=28, endRow=32, total=30, pages=8, reasonable=false, pageSizeZero=false}, prePage=7, nextPage=0, isFirstPage=false, isLastPage=true, hasPreviousPage=true, hasNextPage=false, navigatePages=5, navigateFirstPage4, navigateLastPage8, navigatepageNums=[4, 5, 6, 7, 8] }*

MyBatis是如何分页的?

MyBatis使用RowBounds对象进行分页,它是针对ResultSet结果集执行的内存分页,而非物理分页。可以在sql内直接书写带有物理分页的参数来完成物理分页功能,也可以使用分页插件来完成物理分页。

分页插件的原理是什么?

  • 分页插件的基本原理是使用Mybatis提供的插件接口,实现自定义插件,拦截Executor的query方法
  • 在执行查询的时候,拦截待执行的sql,然后重写sql,根据dialect方言,添加对应的物理分页语句和物理分页参数。
  • 举例:select * from student,拦截sql后重写为:select t.* from (select * from student) t limit 0, 10