MyBatis(十一):MyBatis架构流程浅析

  1. 架构分层

    我们将MyBatis架构分为三层,分别为接口层、数据处理层和框架支撑层

    • 接口层:提供外部接口调用的API,使用端通过这些API来操作数据库,接口层收到请求后会调用数据处理层完成具体的数据处理

      使用端可以通过两种方式调用接口层:MyBatis提供的API、Mapper动态代理

    • 数据处理层:负责具体的SQL查找、解析、执行与执行结果映射处理,主要负责根据具体的请求完成数据库操作

    • 框架支撑层:负责基础的功能支撑,主要功能有连接管理、事务管理、配置加载和缓存管理

  2. 主要组件及关系

    组件 功能描述
    Configuration 接收使用端配置的MyBatis XML核心配置文件
    MappedStatement 接收使用端配置的XxMapper.xml文件
    SqlSession 负责与数据库交互的会话,主要封装了代理对象、增删改查、获取数据库连接
    Executor 执行器,MyBatis的核心调度器,主要负责动态语句的生成、事务管理及缓存操作
    StatementHandler 封装了诸多类,调度参数映射、SQL执行与结果集映射,主要负责 操作JDBC Statement对象执行SQL,
    ParameterHandler 负责将使用端传递的参数转换成JDBC Statement所需要的参数
    ResultSetHandler 负责将JDBC返回的ResultSet结果集对象转换成List类型的集合
    TypeHandler 主要负责JDBC对象与Java对象之间进行相互转换
    BoundSql 处理SQL中的#{} ${},进行替换处理,转换为数据库可执行的SQL
    RowBounds MyBatis提供的逻辑分页类,从结果集中进行过滤分页数据
  3. 执行流程

    1、读取Mybatis主配置文件信息

    2、获取SqlSessionFactory

    ​ a、使用XMLMappperBuilder解析Mybatis配置文件,封装成Environment对象,再把Environment对象设置给Configuration对象;

    ​ b.、调用ConfigurationElement函数,最终执行addMappedStatement方法,将mapper配置文件中的每一条SQL语句封装成mappedStatement对象,作为value保存在HashMap集合中;

    ​ c.、进入addLoaderResource方法,使用HashSet集合存放mybatis的mapper.xml 映射文件路径地址;

    ​ d.、进入bindMapperForNamespace()方法,通过namespace使用Java反射机制找到mapper接口,再调用addMapper()方法,判断是否是接口类型,是否注册过(注册过则抛出异常)其中mapperRegistry通过HashMap保存mapper接口,【key:接口;value:MapperProxyFactory】

    3、获取SqlSession对象

    ​ a、进入openSession()方法,执行newExecutor()方法创建执行器;

    ​ b、先创建 SimpleExecutor简单执行器,再判断是否开启了二级缓存,默认是开启的(使用时需要配置条件),就会去创建CacheExecutor缓存执行器

    ​ c、执行interceptorChain.pluginAll()方法,责任链设计模式,底层使用动态代理技术,使开发者可以自定义插件开发,只需要实现Interceptor接口,并指定想要拦截的方法签名即可,最后返回执行器;

    4、操作mapper接口

    ​ a、调用getMapper()方法,最终执行mapperProxyFactory.newInstance(sqlSession)方法创建代理类MapperProxy;

    ​ b、当我们调用mapper,getUser()方法的时候,就会去执行MapperProxy代理类的invoke()方法;

    ​ c、判断mapper接口是否有实现类,显然我们没有实现类,则调用cacheMapperMethod()方法去缓存中获取要代理的方法method;

    ​ d、进入cacheMapperMethod()方法先去查找缓存中有没有,没有的话将mapper配置文件中配置的SQL语句和对应的mapper接口方法进行关联并放入map缓存中,后期直接走缓存了,最后执行execute()方法;

    ​ e、执行execute()方法,最终调用selectOne()方法;

    ​ f、进入selectOne()方法,底层还是查询所有的,但是取第一个,查询多个的话会抛出异常;

    ​ g、进入selectList()方法,调用getMapperStatement()方法获取对应的SQL语句;

    ​ h、执行query()方法进行查询,判断如果开启了二级缓存并且配置了二级缓存存储介质(Redis,EhCache..)则先走二级缓存中查询数据,第一次查询是没有缓存数据的,则刷新缓存配置,清除缓存。

    ​ i、二级缓存(sessionFactory)中没有查询到数据,就回去执行BaseExecutor去查询 HashMap一级缓存中(sqlSession)是否有缓存数据,一级缓存(PerpetualCache)存放在内存中的,同理也是没有的,最后查询数据库DB

    ​ j、将从数据库查询出来的数据缓存到一级缓存中,再把一级缓存中的数据同步到二级缓存,添加到二级缓存之前先添加到getTransactionalCache的entritiesToAddOnCommit的map集合中临时缓存起来;

    ​ k、调用executor.close()方法循环迭代TransactionCache,最后将临时map缓存数据提交到二级缓存中,如果事务回滚,则会将缓存数据清除掉

    ​ l、再次查询的话,就有缓存了,会直接查询到缓存数据返回,不会去查询数据库DB
    [执行流程]: “//www.douban.com/note/749318390/

Tags: