ICode9

精准搜索请尝试: 精确搜索
首页 > 编程语言> 文章详细

Mybatis源码1JDBC->mybatis主要流程->mybatis Excutor简介

2022-08-21 12:00:33  阅读:181  来源: 互联网

标签:语句 映射 Driver Excutor 源码 SQL mybatis 执行


Mybatis源码1JDBC->mybatis主要流程->mybatis Excutor简介

一丶mybatis概述

MyBatis 是一款优秀的持久层框架,它支持自定义 SQL、存储过程以及高级映射。MyBatis 免除了几乎所有的 JDBC 代码以及设置参数和获取结果集的工作。MyBatis 可以通过简单的 XML 或注解来配置和映射原始类型、接口和 Java POJO(Plain Old Java Objects,普通老式 Java 对象)为数据库中的记录。

mybatis – MyBatis 3 | 官方文档

二丶传统JDBC操作

JDBC的全称是Java数据库连接(Java Database connect),它是一套用于执行SQL语句的Java API。应用程序可通过这套API连接到关系数据库,并使用SQL语句来完成对数据库中数据的查询、更新和删除等操作

mybatis让我们重复的jdbc操作中解放开来 ,但是不能被工具的便捷蒙蔽了双眼,让我们从锤子开始

  public List<Student> selectAllStudent() {
        try {
            //注册驱动
            Class.forName("com.mysql.cj.jdbc.Driver");
        } catch (Exception e) {

        }
        ArrayList<Student> list = new ArrayList<>();
        Connection connection = null;
        PreparedStatement statement = null;
        ResultSet resultSet = null;
        try {
            //获取连接
            connection = DriverManager.getConnection("url","username","password");
			//创建statement
            statement = connection.prepareStatement("select * from student");
            //执行查询,得到结果集
            resultSet = statement.executeQuery();
			//结果集到对象的映射
            while (resultSet.next()) {
                int id = resultSet.getInt("id");
                String name = resultSet.getString("name");
                boolean sex = resultSet.getBoolean("sex");
                Student temp = Student.builder()
                        .id(id)
                        .name(name)
                        .sex(sex)
                        .build();
                list.add(temp);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            //关闭资源
            if (resultSet != null) {
                try {
                    resultSet.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if (statement != null) {
                try {
                    statement.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if (connection != null) {
                try {
                    connection.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
        return list;
    }
  1. 注册驱动

    Class.forName,利用反射获取驱动的class,实际执行了Driver的静态代码块内容

    	//将mysql的驱动注册到DriverManager
        static {
            try {
                //把driver加载到 DriverManager的registeredDrivers 集合中去
                java.sql.DriverManager.registerDriver(new Driver());
            } catch (SQLException E) {
                throw new RuntimeException("Can't register driver!");
            }
        }
        /**
         * 空白的构造函数
         * 
         * @throws SQLException
         *             if a database error occurs.
         */
        public Driver() throws SQLException {
            //下面说明了 使用Class.forName 
            // Required for Class.forName().newInstance()
        }
    
  2. 获取连接

    DriverManager.getConnection() 方法用于获得试图建立到指定数据库 URL 的连接。DriverManager 试图从已注册的 JDBC 驱动程序集中选择一个适当的驱动程序(可能存在多个已经注册的连接)

    这里面的逻辑是,调用了

    return (getConnection(url, info, Reflection.getCallerClass()));
    //Reflection.getCallerClass()获取调用方法的类
    //如果当前调用方为null 那么从当前线程获取类加载器
    //Thread.currentThread().getContextClassLoader()
    //遍历每一个驱动,返回第一个合适的驱动
    
  3. 构造Statement

    用于执行静态SQL语句并返回其生成的结果的对象。

    PrepareStatement: 表示预编译的SQL语句的对象,SQL语句已预编译并存储在PreparedStatement对象中。 然后可以使用该对象多次有效地执行此语句

  4. 执行查询,得到结果集,结果集映射到对象

    ResultSet

    表示数据库结果集的数据表,通常通过执行查询数据库的语句生成。

    ResultSet对象保持一个光标指向其当前的数据行。 最初,光标位于第一行之前。 next方法将光标移动到下一行,并且由于在ResultSet对象中没有更多行时返回false ,因此可以在while循环中使用循环来遍历结果集。

  5. 关闭连接

三丶mybatis的简单使用和大致执行流程

//mybatis全局配置
String resource = "com/cuzz/mybatislearn/mybatis.xml";
InputStream inputStream = Resources.getResourceAsStream(resource);
//根据配置拿到sqlSessionFactory 【工厂模式】
SqlSessionFactory sqlSessionFactory = new 
    SqlSessionFactoryBuilder().build(inputStream);
//获取SqlSession 该对象中包含了执行SQL语句的所有方法【门面模式】
SqlSession sqlSession = sqlSessionFactory.openSession();
//获取代理后的mapper
StudentDao mapper = sqlSession.getMapper(StudentDao.class);
//执行
List<Student> students = mapper.listAll();

mybatis.png

(1)读取MyBatis的配置文件。mybatis-config.xml为MyBatis的全局配置文件,用于配置数据库连接信息。

(2)加载映射文件。映射文件即SQL映射文件,该文件中配置了操作数据库的SQL语句,需要在MyBatis配置文件mybatis-config.xml中加载。mybatis-config.xml 文件可以加载多个映射文件,每个文件对应数据库中的一张表。

(3)构造会话工厂。通过MyBatis的环境配置信息构建会话工厂SqlSessionFactory。

(4)创建会话对象。由会话工厂创建SqlSession对象,该对象中包含了执行SQL语句的所有方法。

(5)Executor执行器。MyBatis底层定义了一个Executor接口来操作数据库,它将根据SqlSession传递的参数动态地生成需要执行的SQL语句,同时负责查询缓存的维护。

(6)MappedStatement对象。在Executor接口的执行方法中有一个MappedStatement类型的参数,该参数是对映射信息的封装,用于存储要映射的SQL语句的id、参数等信息。

(7)输入参数映射。输入参数类型可以是Map、List等集合类型,也可以是基本数据类型和POJO类型。输入参数映射过程类似于JDBC对preparedStatement对象设置参数的过程。

(8)输出结果映射。输出结果类型可以是Map、List等集合类型,也可以是基本数据类型和POJO类型。输出结果映射过程类似于JDBC对结果集的解析过程。z

四丶mybatis中的执行器

mybatis的执行器,是mybatis最为关键的地方(相比于扫描mapper得到全局配置)

image-20220227223002574

1.Executor接口

  • 该接口提供了改和查的基本功能(数据库的删除插入本质也是更新,其实对应了statement中的executeUpdate和executeQuery方法)
  • 提交和回滚
  • 缓存相关方法
  • 批处理刷新
  • 执行器关闭
  • 延迟加载

2.BaseExecutor

​ 对Executor中的接口中的大部分方法进行了通用的实现,并且可以通过配置文件,或者手动指定执行器类型来让mybatis使用具体执行器实现(这里说的实现只有BatchExcutor,SimpleExecutor,ReuseExcutor),还提供了三个抽象方法(如下)让子类实现

  • doUpdate
  • doFlushStatements
  • doQuery

3.SimpleExecutor

简单执行器,是 MyBatis 中默认使用的执行器,对BaseExecutor中的方法进行了简单的实现,(根据配置获取连接,根据连接获取Statement,执行sql,结果集映射)每执行一次 update 或 select,就开启一个 Statement 对象,用完就直接关闭 Statement 对象

4.BatchExecutor

主要应对批量更新,插入,删除,一次向数据库发送多个SQL语句从而减少通信开销,从而提高性能。(对查找不生效)

批量处理允许将相关的SQL语句分组到批处理中,并通过对数据库的一次调用来提交它们,一次执行完成与数据库之间的交互。需要注意的是:JDBC中的批处理只支持 insert、update 、delete 等类型的SQL语句,不支持select类型的SQL语句。

5.ReuseExecutor

ReuseExecutor 不同于 SimpleExecutor 的地方在于 ReuseExecutor 维护了 Statement 缓存

ReuseExecutor顾名思义就是重复使用执行,其定义了一个Map<String, Statement>,将执行的sql作为key,将执行的Statement作为value保存,这样执行相同的sql时就可以使用已经存在的Statement,就不需要新创建了,从而避免SimpleExecutor这样多次进行参数拼接生成statement以提高性能

6.CachingExecutor

CachingExecutor没有继承BaseExecutor,CachingExecutor 不具备 Executor 执行器功能,CachingExecutor 是一个装饰器, Mybatis 采用装饰者模式对 Executor 执行器提供了功能增强。CachingExecutor装饰器能够使得被装饰的Executor 具备二级缓存功能

附录

  1. 为什么注册驱动需要使用Class.forName

    Class.forName(String)会加载类,并且并且执行类初始化,会执行driver中的静态代码块,静态代码块中进行了驱动的注册,

  2. Class.forName,和ClassLoader.loadClass的区别

    1. Class.forName(String): 加载类,并且执行类初始化,可以通过Class.forName(String, boolean, ClassLoader)第二个参数来仅仅加载类不执行初始化
    2. ClassLoader.loadClass(String): 仅仅加载类,不执行类初始化
  3. 注册驱动的方式有哪些

    在java 6中,引入了service provider的概念,即可以在配置文件中配置service(可能是一个interface或者abstract class)的provider(即service的实现类)。配置路径是:/META-INF/services/下面。
    而java.sql.DriverManager也添加了对此的支持,因此,在JDK6中,DriverManager的查找Driver的范围为:
    1)system property “jdbc.drivers” 中配置的Driver值;
    2)用户调用Class.forName()注册的Driver
    3)service provider配置文件java.sql.Driver中配置的Driver值。
    因此,在jdk6中,其实是可以不用调用Class.forName来加载mysql驱动的,因为mysql的驱动程序jar包中已经包含了java.sql.Driver配置文件,并在文件中添加了com.mysql.jdbc.Driver.但在JDK6之前版本,还是要调用这个方法。

标签:语句,映射,Driver,Excutor,源码,SQL,mybatis,执行
来源: https://www.cnblogs.com/cuzzz/p/16609738.html

本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享;
2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关;
3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关;
4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除;
5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有