1. Mapper 代理层执行

Mapper 代理上执行方法调用时，调用被委派给 MapperProxy 来处理。

public class MapperProxy<T> implements InvocationHandler, Serializable {
    private final SqlSession sqlSession;
    private final Class<T> mapperInterface;
    private final Map<Method, MapperMethod> methodCache;

    public MapperProxy(SqlSession sqlSession, Class<T> mapperInterface, Map<Method, MapperMethod> methodCache) {
        this.sqlSession = sqlSession;
        this.mapperInterface = mapperInterface;
        this.methodCache = methodCache;
    }

    public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
        if (Object.class.equals(method.getDeclaringClass())) {
            try {
                return method.invoke(this, args);
            } catch (Throwable t) {
                throw ExceptionUtil.unwrapThrowable(t);
            }
        }
        // 接口里声明的方法，转换为 MapperMethod 来调用
        final MapperMethod mapperMethod = cachedMapperMethod(method);

        // 与 Spring 集成时此处的 sqlSession 仍然 SqlSessionTemplate
        return mapperMethod.execute(sqlSession, args);
    }

    private MapperMethod cachedMapperMethod(Method method) {
        MapperMethod mapperMethod = methodCache.get(method);
        if (mapperMethod == null) {
            mapperMethod = new MapperMethod(mapperInterface, method, sqlSession.getConfiguration());
            methodCache.put(method, mapperMethod);
        }
        return mapperMethod;
    }
}

MapperMethod 根据 mapperInterface.getName() + "." + method.getName() 从 Configuration 对象里找到对应的 MappedStatement，从而得到要执行的 SQL 操作类型（insert/delete/update/select/flush），然后调用传入的 sqlSession 实例上的相应的方法。

public Object execute(SqlSession sqlSession, Object[] args) {
    Object result;
    if (SqlCommandType.INSERT == command.getType()) {
        // 把参数转换为 SqlSession 能处理的格式
        Object param = method.convertArgsToSqlCommandParam(args);

        // 在 sqlSession 上执行并处理结果
        result = rowCountResult(sqlSession.insert(command.getName(), param));
    } else if (SqlCommandType.UPDATE == command.getType()) {
        Object param = method.convertArgsToSqlCommandParam(args);
        result = rowCountResult(sqlSession.update(command.getName(), param));
    ...省略

如果上述方法传入的是 SqlSessionTemplate，那么这些方法调用会被 SqlSessionInterceptor 拦截，加入与 Spring 事务管理机制协作的逻辑，具体可以看这篇文章MyBatis 事务管理，这里不再展开，最终会调用到 DefaultSqlSession 实例上的方法。

2. 会话层的执行过程

SqlSession 里声明的所有方法的第一个参数如果是 String statement，则都是 mapperInterface.getName() + "." + method.getName()，表示要调用的 SQL 语句的标识符。通过它从 configuration 找到 MappedStatement 。

会话层最主要的逻辑是进行参数的包装，获取对应的 MappedStatement，然后调用持有的 Executor 的方法去执行。

继续阅读 →

本文主要关注与 SpringBoot 集成时的初始化过程。

1. 核心组件

• Configuration：MyBatis所有的配置信息都保存在Configuration对象之中，配置文件中的大部分配置都会存储到该类中。
• SqlSession：MyBatis 的顶层 API，表示与数据库交互的会话，完成数据库增删改查操作。
• Executor：执行器是 MyBatis 调度的核心，负责 SQL 语句的生成和查询缓存的维护。
• StatementHandler：封装了 JDBC Statement 操作，如设置参数等。
• ParameterHandler：负责将用户传递的参数转换成 JDBC Statement 所对应的数据类型。
• ResultSetHandler：负责将 JDBC 返回的 ResultSet 结果集转换成 List 类型的集合。
• TypeHandler：负责将 Java 数据类型和 jdbc 数据类型之间的映射与转换。

• MapperFactoryBean：与 Spring 集成时表示一个 Mapper 原型的工厂 bean，用以创建最终的代理。
• MapperProxy：与一个 mapperInterface 对应，维护了 Map<Method, MapperMethod> 映射。
• MapperAnnotationBuilder：基于注解驱动的 MappedStatement 解析器，解析接口类的每个方法，封装成 MappedStatement。
• MappedStatement：维护了一条 <select|update|delete|insert> 节点的封装。
• SqlSource：负责根据用户传递的 parameterObject 动态生成 SQL 语句，将信息封装成 BoundSql 对象。
• BoundSql：表示动态生成的 SQL 语句以及相应的参数信息。

整体架构如下图：

继续阅读 →