MyBatis执行阶段

清疚 2024-04-18 19:16 67阅读 0赞

### 一、关键类 ###

下面按照程序的顺序简要介绍MyBatis执行阶段的关键类和必要的类，它们按照Executor类搭建了MyBatis的执行组件。

（1）SqlSession：MyBatis的核心执行入口。默认实现为DefaultSqlSession，其他实现有SqlSessionManager、SqlSessionTemplate（MyBatis-spring）等，该接口提供了大量的SQL调用方法。

（2）Configuration：保存构建阶段的结果，也负责在执行阶段初始化需要的变量。

（3）MappedStatement：配置好的映射SQL语句。

（4）BoundSql：SQL的抽象，存放执行SQL的内容。

（5）Executor：执行器，方法更加抽象，只有select（DQL）和update（DML）。虚类BaseExecutor有BatchExecutor、ClosedExecutor、ReuseExecutor、SimpleExecutor等多种子类实现。

（6）StatementHandler：处理SQL语句的管理器接口。

（7）ResultSetHandler：处理结果集的管理器接口。

### 二、关键接口及默认实现初始化 ###

**（1）SqlSession及其关联类的构建过程**

SqlSession是公认的MyBatis的接口层，封装了selectOne()、selectList()、selectMap()、selectCursor()、select()的DQL语句，insert()、update()、delete()的DML语句，以及commit()、rollback()的TPL语句。

MyBatis核心提供的SqlSession实例化方式主要用到了工厂SqlSessionFactory。DefaultSqlSessionFactory是SqlSessionFactory中的一个子类，也是SqlSessionFactory默认的实现类，是构建阶段SqlSessionFactoryBuilder的产物。

另一个子类SqlSessionManager利用ThreadLocal和代理拦截，保障了线程安全的、支持自动重连的SqlSession，这个类没有具体的生产使用，因此这里不深入研究。

DefaultSqlSessionFactory只用于构造SqlSession的默认子类DefaultSqlSession对象。DefaultSqlSession有3个主要属性：configuration、executor和autoCommit(autoCommit参数虽然在声明变量时没有默认值，但DefaultSqlSession和DefaultSqlFactory会把它赋值成默认值“false”)。

Configuration的Transaction transaction, ExecutorType executorType构造executor对象。ExecutorType有三种BATCH、REUSE和SIMPLE（默认值）。分别对应BatchExecutor、ReuseExecutor、SimpleExecutor。

public Executor newExecutor(Transaction transaction, ExecutorType executorType) {
        executorType = executorType == null ? defaultExecutorType : executorType;
        executorType = executorType == null ? ExecutorType.SIMPLE : executorType;
        Executor executor;
        if (ExecutorType.BATCH == executorType) {
          executor = new BatchExecutor(this, transaction);
        } else if (ExecutorType.REUSE == executorType) {
          executor = new ReuseExecutor(this, transaction);
        } else {
          executor = new SimpleExecutor(this, transaction);
        }
        if (cacheEnabled) {
          executor = new CachingExecutor(executor);
        }
        executor = (Executor) interceptorChain.pluginAll(executor);
        return executor;
      }

至此SqlSession及其重要属性executor和configuration都已构造完成，应用程序可以通过SqlSession执行自己定义好的SQL。

**（2）StatementHandler语句处理器**

** **   StatementHandler的构建是executor对象在执行具体sql时，通过Configuration类的newStatementHandler()触发的。

public StatementHandler newStatementHandler(Executor executor, MappedStatement mappedStatement, Object parameterObject, RowBounds rowBounds, ResultHandler resultHandler, BoundSql boundSql) {
        StatementHandler statementHandler = new RoutingStatementHandler(executor, mappedStatement, parameterObject, rowBounds, resultHandler, boundSql);
        statementHandler = (StatementHandler) interceptorChain.pluginAll(statementHandler);
        return statementHandler;
      }

RoutingStatementHandler会根据MappedStatement类的对象的statementType值（STATEMENT、PREPARED、CALLABLE）构造不同的StatementHandler子类对象，若没有对应到，则会抛出异常（ExecutorException）。

public RoutingStatementHandler(Executor executor, MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler, BoundSql boundSql) {
    
        switch (ms.getStatementType()) {
          case STATEMENT://普通语句
            delegate = new SimpleStatementHandler(executor, ms, parameter, rowBounds, resultHandler, boundSql);
            break;
          case PREPARED://预编译语句
            delegate = new PreparedStatementHandler(executor, ms, parameter, rowBounds, resultHandler, boundSql);
            break;
          case CALLABLE://存储过程
            delegate = new CallableStatementHandler(executor, ms, parameter, rowBounds, resultHandler, boundSql);
            break;
          default:
            throw new ExecutorException("Unknown statement type: " + ms.getStatementType());
        }
    
      }

### 三、DQL语句是如何执行的 ###

**（1）查询接口**

selectOne():返回单个对象

<T> T selectOne(String statement);
    <T> T selectOne(String statement, Object parameter);

selectList():返回List结果集

<E> List<E> selectList(String statement);
    <E> List<E> selectList(String statement, Object parameter);
    /*
    RowBounds 分页对象 
    不需要在 sql 语句中写 limit，mybatis 会自动拼接 sql ，添加 limit
    最核心的是在 mapper 接口层，传参时传入 RowBounds(int offset, int limit) 对象，即可完成分页
    */
    <E> List<E> selectList(String statement, Object parameter, RowBounds rowBounds);

selectMap():返回Map结果集

/*
    selectMap方法返回指定列为key的map集合或对象，它的value值得类型可以为Object或map，
    在不绑定bean下默认为Map<String,String>类型，即以对象的属性名作为key，
    注意都是key和value都是String类型，
    */
    <K, V> Map<K, V> selectMap(String statement, String mapKey);
    <K, V> Map<K, V> selectMap(String statement, Object parameter, String mapKey);
    <K, V> Map<K, V> selectMap(String statement, Object parameter, String mapKey, RowBounds rowBounds);

selectCursor():返回Cursor结果集。

<T> Cursor<T> selectCursor(String statement);
    <T> Cursor<T> selectCursor(String statement, Object parameter);
    <T> Cursor<T> selectCursor(String statement, Object parameter, RowBounds rowBounds);

select():无返回值但允许传入自定义的ResultSetHandler处理结果集。

void select(String statement, Object parameter, ResultHandler handler);
    void select(String statement, ResultHandler handler);
    void select(String statement, Object parameter, RowBounds rowBounds, ResultHandler handler);

selectOne()、selectMap()是通过调用selectList()实现的。select()与selectList()比起来只是ResultHandler类（注意不是ResultSetHandler）支持自定义，其他都是相同的。

**（2）关键时序**

SqlSession在执行查询操作时，先从configuration对象那里获取配置好的SQL Mapper，之后的工作就交给Executor的query()方法了。Executor类主要依赖StatementHandler和ResultSetHandler来完成查询工作，StatementHandler负责查询，ResultSetHandler负责结果集封装。

### 四、DML语句是如何执行的 ###

**（1）操作接口**

SqlSession支持增删改这三类接口。

insert()：返回影响行数（int类型）。

int insert(String statement);
    int insert(String statement, Object parameter);

update()：返回影响行数（int类型）。

int update(String statement);
    int update(String statement, Object parameter);

delete()：返回影响行数（int类型）。

int delete(String statement);
    int delete(String statement, Object parameter);

三种方法都是由update()包装而来的。

**（2）关键时序**

与DQL语句执行的依赖顺序很相似，DML在插入时会有新的主键产生，这个功能被委托给KeyGenerator类完成。DML对结果集也不敏感，所以不需要ResultSetHandler帮忙处理复杂的结果集。