MyBatis 原理浅析 3 ——数据操作

前言

在前文《MyBatis 原理浅析——基本原理》一文中简单分析了 MyBatis 的实现原理，MyBatis 的数据库操作是通过 Executor 执行的。Executor 是一个接口，有三个实现类，分别是 SimpleExecutor、ReuseExecutor 和 BatchExecutor。

查询数据的流程

查询数据是通过 SqlSession 的方法实现的，SqlSession 封装了 Executor 的相关操作。以 select 为例，首先根据 SQL 语句关联的 statement 从 configuration 中获取 MappedStatement 对象，然后调用 Executor 的 query 方法执行查询操作。statement 的格式是命名空间+ID，ID 即是 XML 中 select 标签的 id 属性。MappedStatement 对象存储了 XML 中的 SQL 配置，如 ParameterMap、ResultMap 等。

@Override
public void select(String statement, Object parameter, RowBounds rowBounds, ResultHandler handler) {
    try {
        MappedStatement ms = configuration.getMappedStatement(statement);
        executor.query(ms, wrapCollection(parameter), rowBounds, handler);
    } catch (Exception e) {
        throwExceptionFactory.wrapException("Error querying database.  Cause: " + e, e);
    } finally {
        ErrorContext.instance().reset();
    }
}

默认情况下，使用 Executor 接口的 SimpleExecutor 实现。SimpleExecutor 继承了抽象类 BaseExecutor。BaseExecutor 实现了 Executor 接口的方法，实现了缓存机制，可以从缓存中直接返回查询结果，但更具体的数据库操作交给子类 SimpleExecutor 实现。在 SimpleExecutor  类中执行查询的 doQuery 方法如下所示。首先从 Configuration 中创建 StatementHandler 接口实例，默认使用 RoutingStatementHandler 实现。然后在 prepareStatement 方法中获取数据库连接、初始化 Statement、设置参数等。再调用 StatementHandler 的 query 方法，执行数据查询，查询结果交给 resultHandler 处理。最后关闭 Statement。

@Override
public List doQuery(MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler, BoundSql boundSql) throwsSQLException {
    Statement stmt = null;
    try {
        Configuration configuration = ms.getConfiguration();
        StatementHandler handler = configuration.newStatementHandler(wrapper, ms, parameter, rowBounds, resultHandler, boundSql);
        stmt = prepareStatement(handler, ms.getStatementLog());
        returnhandler.query(stmt, resultHandler);
    } finally {
        closeStatement(stmt);
    }
}

在 RoutingStatementHandler 中会根据配置选择一个 StatementHandler 的实现用于进一步的数据处理，默认是 PreparedStatementHandler 类。在该类的 query 方法中会执行 Statement 数据查询请求，请求完成后调用 ResultSetHandler 对查询结果进行处理和封装。ResultSetHandler 接口定义了对返回结果集进行处理的方法，默认使用的实现类是 DefaultResultSetHandler，在 handleResultSets 方法中完成结果集到 Java Bean 的映射。

@Override
public List query(Statement statement, ResultHandler resultHandler) throwsSQLException {
    PreparedStatement ps = (PreparedStatement) statement;
    ps.execute();
    returnresultSetHandler.handleResultSets(ps);
}

查询结果的缓存

MyBatis 支持对查询结果进行缓存，以减少数据库操作提高效率，默认情况下执行 insert、update、delete 等操作会清理缓存。执行查询操作前，首先创建 CacheKey 对象，根据 SQL 语句、id、offset、limit 和参数更新 CacheKey 对象，CacheKey 对象会记录这些数据并更新 hashcode、checksum、count 几个整数，这些数据都用于判断 CacheKey 对象是否相等。

public void update(Object object) {
    intbaseHashCode = object == null ? 1 : ArrayUtil.hashCode(object);
    count++;
    checksum += baseHashCode;
    baseHashCode *= count;
    hashcode = multiplier * hashcode + baseHashCode;
    updateList.add(object);
}

select 语句的查询结果以 Map 形式存放在 PerpetualCache 类中，Map 的 key 是 CacheKey 对象，Map 的 value 是查询结果。

更新数据的流程

DefaultSqlSession 的 insert、delete 操作都是复用 update 操作实现的，update 的操作流程与 select 类似，不做过多阐述。所不同的是，执行 update 操作前需要先清理缓存，在 update 操作完成以后，还需要返回受影响的行数和 KeyGenerator 配置的自增值。

事务提交与回滚

DefaultSqlSession 的 commit 和 rollback 操作都是在 BaseExecutor 中实现的，先清除缓存，然后清理 Statement，如果有需要再调用 Transaction 的相关方法。如果要求强制执行，或者不自动提交且有脏数据，就会执行 Transaction 的 commit 或 rollback 操作。