【手撕MyBatis源码】JDBC处理器StatementHandler

news/2024/11/24 4:27:41/

文章目录

  • 回顾MyBatis的执行流程
  • StatementHandler定义与结构
  • PreparedStatementHandler执行流程
  • 参数处理
    • 参数转换
    • 参数映射
    • 参数赋值
  • 结果集处理

回顾MyBatis的执行流程

MyBatis是一个基于JDBC的Dao框架,但前面我们提到的会话、执行器完全没有提到JDBC,原因是MyBatis把所有跟JDBC相关的操作全部都放到了StatementHandler中。

一个SQL请求会经过会话,然后是执行器,最由StatementHandler执行JDBC最终到达数据库。其关系如下图:

在这里插入图片描述

注意:我们前面说过在一次会话中SqlSession、Executer、StatementHandler的比例是1:1:N(这里的N取决于通过会话调用了多少次Sql)。即使在可重用执行器的情况下这个比例也是成立的,因为我们只要执行一次SQL就会对应一个StatementHandler。但是如果走了缓存就会影响,因为我们压根就不会走数据库操作!

StatementHandler定义与结构

StatementHandler定义:

JDBC处理器,基于JDBC构建JDBC Statement,并设置参数,然后执行Sql。每调用会话当中一次SQL,都会有与之相对应的且唯一的Statement实例

StatementHandler结构

在这里插入图片描述

​ StatementHandler接口定义了JDBC操作的相关方法如下:

// 基于JDBC 声明Statement
Statement prepare(Connection connection, Integer transactionTimeout)throws SQLException;
// 为Statement 设置方法参数
void parameterize(Statement statement)throws SQLException;
// 添加批处理(并非执行)
void batch(Statement statement)throws SQLException;
// 执行update操作
int update(Statement statement)throws SQLException;
// 执行query操作
<E> List<E> query(Statement statement, ResultHandler resultHandler)throws SQLException;

StatementHandler 有三个子类:

  • SimpleStatementHandler
  • PreparedStatementHandler
  • CallableStatementHandler

分别对应JDBC中的Statement、PreparedStatement、CallableStatement。

与三类执行器的频繁使用不同,这里的三种我们绝大多数情况下使用的都是PreparedStatementHandler。

PreparedStatement 有以下几个主要特点:

  1. 预编译 SQL 语句。PreparedStatement 对象代表一条预编译过的 SQL 语句。SQL 语句在被发送到数据库执行之前,先被编译。这样可以提高语句的执行效率。
  2. 实现参数设置。PreparedStatement 允许你通过 setXXX() 方法设置参数,然后执行这条 SQL 语句。这样可以防止 SQL 注入,提高安全性。
  3. 重复使用语句。PreparedStatement 可以安全地被重复执行。它会优化数据库资源,并有效地执行语句。
  4. 批量更新。PreparedStatement 支持通过 addBatch() 方法添加多条 SQL 命令,然后通过 executeBatch() 方法批量执行。这大大提高了更新/插入/删除记录的速度。

下面是一个 PreparedStatement 的示例:

String sql = "INSERT INTO EMP(ID, NAME) VALUES (?, ?)";
PreparedStatement pstmt = conn.prepareStatement(sql);pstmt.setInt(1, 101);    // 为第一个参数设置 int 类型的值 101  
pstmt.setString(2, "John"); // 为第二个参数设置 String 类型的值 "John"
pstmt.addBatch();pstmt.setInt(1, 102);   
pstmt.setString(2, "Tom");
pstmt.addBatch();  pstmt.executeBatch(); // 批量执行命令

这个示例中:

  1. 我们首先预编译一条 SQL 语句,这个语句使用了两个参数。
  2. 然后我们为这两个参数设置具体的值,添加到批处理中。
  3. 最后通过 executeBatch() 方法执行批处理,插入两条记录。

所以,总结来说,PreparedStatement 的主要特点有:

  1. 预编译 SQL 语句,提高执行效率。
  2. 实现参数设置,防止 SQL 注入。
  3. 可以安全重复执行,优化数据库资源。
  4. 支持批量更新,大大提高更新/插入/删除记录的速度。

PreparedStatement 是 JDBC 访问数据库的重要实现,它通过预编译和参数设置等特性,使得数据库访问更加高效和安全。

这三种StatementHandler有如下的共性:

  • 添加批处理参数
  • 设置返回的行数

在这里插入图片描述

所以这个时候我们会抽象出一个BaseStatementHandler来处理这些共性

PreparedStatementHandler执行流程

在这里插入图片描述

我们在上一篇文章中说过,查询数据的本质方法是doQuery(),他被query方法包了一层来处理缓存相关的业务。

在这里插入图片描述

查询数据库的执行过程分为三个阶段:

  • 预处理:这里预处理不仅仅是通过Connection创建Statement,还包括设置参数。
    SimpleExecuter类中:
    在这里插入图片描述

  • 执行:包含执行SQL获取结果集和处理结果映射(后面会说)两部分。
    在这里插入图片描述
    在这里插入图片描述

    我们可以看到获取结果集后,使用ResultSetWrapper包装了一下。

  • 关闭:直接关闭Statement。

参数处理和结果集封装,涉及数据库字段和JavaBean之间的相互映射,相对复杂。所以分别使用ParameterHandler与ResultSetHandler两个专门的组件实现。接下来就一起了解一下参数处理与结果集封装的处理流程。

在 MyBatis 中,PreparedStatementHandler 的执行流程如下:

  1. 调用 Connection.prepareStatement(sql) 创建一个 PreparedStatement 对象。sql 是映射文件中配置的 SQL 语句,可能包含参数 #{property}。
  2. 对SQL语句中的参数进行解析和值设置。
    • 解析 #{property} 获得参数名称和参数值。参数值来源于传入的 Java 对象的属性值。
    • 根据参数类型调用 PreparedStatement 的 setXxx() 方法设置参数值。如 setInt() 设置整数,setString() 设置字符串等。
  3. 调用 PreparedStatement 的 executeUpdate() 执行插入、更新、删除操作,或 executeQuery() 执行查询操作。
  4. 如果执行查询操作,还需要调用 ResultSetHandler 处理结果集。
    • DefaultResultSetHandler 会将 ResultSet 封装为 List 并返回。
    • BeanResultSetHandler 会将 ResultSet 封装为 JavaBean 对象并返回。
  5. 调用 PreparedStatement.close() 和 ResultSet.close() 释放资源。

参数处理

对应下面这一部分:
在这里插入图片描述

参数处理即将Java Bean转换成数据类型。总共要经历过三个步骤:

  • 参数转换
  • 参数映射
  • 参数赋值

参数转换

在MyBatis中参数转换逻辑均在ParamNameResolver中实现

参数转换就是将JAVA 方法中的普通参数,封装转换成Map,以便map中的key和sql的参数引用相对应。

@Select({"select * from users where name=#{name} or age=#{user.age}"})
@Options
User selectByNameOrAge(@Param("name") String name, @Param("user") User user);
  • 单个参数的情况下且没有设置@param注解会直接转换,忽略SQL中的引用名称。
  • 多个参数情况:优先采用@Param中设置的名称,如果没有则用参数序号代替 即"param1、param2…"(作为key)
    • 在JDK1.8之后支持直接通过反射获取变量名称作为key,前提javac编译时设置了 -parameters 编译参数,如果没有设置则转换成arg0,arg1

例如:
在这里插入图片描述

在这里插入图片描述
过程如下:

在这里插入图片描述

参数映射

映射是指Map中的key如何与SQL中绑定的参数相对应。以下这几种情况

  • 单个原始类型:直接映射,勿略SQL中引用名称
  • Map类型:基于Map key映射
  • Object:基于属性名称映射,支持嵌套对象属性访问

在Object类型中,支持通过“.”方式映射属中的属性。如:user.age

@Select({"select * from users where name=#{name} or age=#{param2.age}"})
@Options
User selectByNameOrAge(@Param("name") String name, @Param("user") User user);

参数赋值

通过TypeHandler 为PrepareStatement设置值,通常情况下一般的数据类型MyBatis都有与之相对应的TypeHandler

在这里插入图片描述

结果集处理

在这里插入图片描述

指读取ResultSet数据,并将每一行转换成相对应的对象。用户可在转换的过程当中可以通过ResultContext来控制是否要继续转换。转换后的对象都会暂存在ResultHandler中最后统一封装成list返回给调用方

在这里插入图片描述

结果集转换中99%的逻辑DefaultResultSetHandler 中实现。整个流程可大致分为以下阶段:

  • 读取结果集

  • 遍历结果集当中的行
    在这里插入图片描述

    • 其本质就是调用resultSet.next()遍历行, 并且基于上下文判断是否要继续往下读取,这也就回应了我们前面所说的ResultContext的作用
      在这里插入图片描述
    • 暂存结果对象就是把我们解析好了的对象放在ResultHandler中
      在这里插入图片描述
  • 创建对象:有四种情况:

  1. 使用构造方法创建对象。MyBatis 会调用无参数的构造方法来创建 bean 实例。
    <resultMap id="UserResultMap" type="User"><constructor><idArg column="id" /></constructor>
    </resultMap>
    
  2. 使用工厂方法创建对象。MyBatis 会调用静态工厂方法来创建 bean 实例。
    <resultMap id="UserResultMap" type="User"><factory><constructor><idArg column="id" /></constructor></factory>  
    </resultMap>
    
  3. 映射到既有的对象。MyBatis 会设置从结果集中获取的字段值到 bean 实例的属性上。
    <resultMap id="UserResultMap" type="User"><id property="id" column="id" /><result property="username" column="username"/>
    </resultMap>
    
  4. 使用映射器接口实现映射。映射器接口是一个简单的接口,只包含获取和设置bean属性值的方法。MyBatis 会创建该接口的一个实现,并使用它来设置结果集的值。
    public interface UserMapper {void setId(Integer id);void setUsername(String username);
    }
    
    <resultMap id="UserResultMap" type="UserMapper"><id property="setId" column="id" /><result property="setUsername" column="username"/>
    </resultMap> 
    
  • 填充属性
    在这里插入图片描述

    • 自动映射
    • 手动映射:基于ResultMapping 获取属性的值

映射方面会在MyBatis映射体系一文中进行说明


http://www.ppmy.cn/news/82623.html

相关文章

SpringBoot【开发实用篇】---- 整合第三方技术(缓存)

SpringBoot【开发实用篇】---- 整合第三方技术&#xff08;缓存&#xff09; SpringBoot内置缓存解决方案手机验证码案例SpringBoot整合Ehcache缓存SpringBoot整合Redis缓存SpringBoot整合Memcached缓存SpringBoot整合jetcache缓存纯远程方案纯本地方案本地远程方案远程方案的数…

车辆合格证怎么转为结构化excel数据?

一、为何要将车辆合格证转为结构化excel&#xff1f; 车辆合格证是在车辆制造完成后&#xff0c;经过各项检测合格的证明。对于车辆行业来说&#xff0c;车辆合格证是一种重要的合规证明&#xff0c;在车辆的生产制造、售后服务、质量管理等各个环节中都有着重要的作用。同时&…

学习SpringBoot入门知识,附带教程源码分享,快速掌握开发技巧-【imooc-java2021】体系课-Java工程师 2022版

学习SpringBoot入门知识&#xff0c;附带教程源码分享&#xff0c;快速掌握开发技巧 目录福利&#xff1a;文末有分享SpringBoot教程及源码哦 一、Spring Boot 是什么二、为什么要使用 Spring Boot三、快速入门3.1 创建 Spring Boot 项目3.1.1 通过 Spring Initializr 来创建1、…

大数据项目实战之数据仓库:电商数据仓库系统——第9章 数仓开发之DWD层

文章目录 第9章 数仓开发之DWD层9.1 交易域加购事务事实表9.2 交易域下单事务事实表9.3 交易域取消订单事务事实表9.4 交易域支付成功事务事实表9.5 交易域退单事务事实表9.6 交易域退款成功事务事实表9.7 交易域购物车周期快照事实表9.8 工具域优惠券领取事务事实表9.9 工具域…

你的数字困境是什么?

导语 随着数字时代的到来&#xff0c;人类社会迎来了前所未有的便利和机遇。然而&#xff0c;随之而来的是个人隐私和信息安全面临的巨大挑战。本文将探讨当前数字时代中的数字困境&#xff0c;并提出一些应对策略&#xff0c;以实现个人隐私和信息安全的平衡。 第一部分&…

explain都不懂?搞什么数据库优化,快进来学习了

文章目录 一、 前言二、MySQL EXPLAIN实战三、mysql EXPLAIN输出结果详解3.1 id详解3.2 select_type3.3 table3.4 partitions3.5 type3.6 possible_keys3.7key3.8 key_len3.9 ref3.10 rows3.11 filtered3.12 Extra 一、 前言 EXPLAIN 想必用过mysql的小伙伴都听过&#xff0c;…

解读kubernetes部署:配置docker私服密钥与SSL证书创建

为k8s配置docker私服密钥 为了kubernetes有权访问您的docker私服&#xff0c;需要在kubernetes的凭证中建立docker私服的密钥&#xff1a; kubectlcreatesecretdocker-registryaliyun-secret--docker-server--docker-username--docker-password--docker-email--namespacens-jav…

直接缓存访问DCA

直接缓存访问DCA&#xff1a;网卡原本DMA写是将接收到的数据帧写入系统内存&#xff0c;DCA机制是网卡DMA写输入的数据能直接发送到属于CPU内部的L2高速缓存中&#xff0c;从而提高网络IO的性能。 设备驱动程序要初始化网卡的DCA功能&#xff0c;将CPU ID号&#xff08;通过获取…