MyBatis SQL 执行流程源码详解 —— 从调用到数据库的完整流程

public interface DesignWorkHourFillDao extends BaseMapper<DesignWorkHourFill> {    List<DeptYearHour> getDeptYearHour();    List<ShipHour> getAllByProjectIds(@Param("projectIds") List<String> projectIds);    IPage<CostPredictDesignHourDto> pageHour(IPage<CostPredictDesignHourDto> page,@Param("year")int year);    List<CostPredictDesignHourDto> listHour(@Param("year")int year);    List<CostPredictDesignHourDto> actualHour(@Param("year")int year);    List<ProjectNoName> noNameMap();    List<YearHour> yearHour(int year);}

List<ProjectNoName>projectNoNames=mapper.noNameMap();

// MapperProxy.invoke()public Object invoke(Object proxy, Method method, Object[] args) {    // 1. 如果是 Object 的方法（toString 等），直接执行    if (Object.class.equals(method.getDeclaringClass())) {        return method.invoke(this, args);    }    // 2. 从缓存中获取 MapperMethod    MapperMethod mapperMethod = cachedMapperMethod(method);    // 3. 委托给 MapperMethod 执行    return mapperMethod.execute(sqlSession, args);}

// DefaultSqlSession.selectList()public <E> List<E> selectList(String statement, Object parameter) {    // 从 Configuration 中获取 MappedStatement    MappedStatement ms = configuration.getMappedStatement(statement);    // 委托给 Executor 执行    return executor.query(ms, wrapCollection(parameter),                           RowBounds.DEFAULT, Executor.NO_RESULT_HANDLER);}

String resource = "mybatis‐config.xml";         Reader reader;         try {             //将XML配置文件构建为Configuration配置类             reader = Resources.getResourceAsReader(resource);             // 通过加载配置文件流构建一个SqlSessionFactory DefaultSqlSessionFactory             SqlSessionFactory sqlFactory = new SqlSessionFactoryBuilder().build(reader);             // 数据源 执行器 DefaultSqlSession             SqlSession session = sqlFactory.openSession();             try {                 // 执行查询 底层执行jdbc                 DesignWorkHourFillDao mapper = session.getMapper(DesignWorkHourFillDao.class);                 System.out.println(mapper.getClass());                 List<ProjectNoName> projectNoNames = mapper.noNameMap();                 for (ProjectNoName projectNoName : projectNoNames) {                     System.out.println(projectNoName);                 }                 } catch (Exception e) {                 e.printStackTrace();                 }finally {                 session.close();                 }             } catch (IOException e) {             e.printStackTrace();             }@Override  public SqlSession openSession() {    return openSessionFromDataSource(configuration.getDefaultExecutorType(), null, false);  }private SqlSession openSessionFromDataSource(ExecutorType execType, TransactionIsolationLevel level, boolean autoCommit) {    Transaction tx = null;    try {      final Environment environment = configuration.getEnvironment();      final TransactionFactory transactionFactory = getTransactionFactoryFromEnvironment(environment);      tx = transactionFactory.newTransaction(environment.getDataSource(), level, autoCommit);        ///获取执行器，这边获得的执行器已经代理拦截器的功能      final Executor executor = configuration.newExecutor(tx, execType);        //根据创建的执行器创建sqlSession      return new DefaultSqlSession(configuration, executor, autoCommit);    } catch (Exception e) {      closeTransaction(tx); // may have fetched a connection so lets call close()      throw ExceptionFactory.wrapException("Error opening session.  Cause: " + e, e);    } finally {      ErrorContext.instance().reset();    }  }

//获取执行器的代码//将最终组装好的 executor（经过了 类型选择 → 缓存装饰 → 插件代理 三个步骤）返回给调用者（通常是 SqlSession）。public Executor newExecutor(Transaction transaction, ExecutorType executorType) {    executorType = executorType == null ? defaultExecutorType : executorType;    executorType = executorType == null ? ExecutorType.SIMPLE : executorType;    Executor executor;    if (ExecutorType.BATCH == executorType) {        //批处理模式 — 如果类型是 BATCH，创建 BatchExecutor。它会攒多条相同 SQL 的 addBatch() 调用，最后一次性 executeBatch() 发送给数据库，适合批量 INSERT/UPDATE/DELETE 场景（JDBC 的  addBatch/executeBatch）。      executor = new BatchExecutor(this, transaction);    } else if (ExecutorType.REUSE == executorType) {        //复用模式 — 如果是 REUSE，创建 ReuseExecutor。它会缓存 PreparedStatement，相同 SQL 不会重复编译（prepareStatement），而是复用之前的 Statement 对象，减少 SQL 预编译开销。      executor = new ReuseExecutor(this, transaction);    } else {        //默认/简单模式 — 其他情况（即 SIMPLE）创建 SimpleExecutor。每次执行都创建新的 Statement，用完即关，行为最直观，适合大多数场景。      executor = new SimpleExecutor(this, transaction);    }    if (cacheEnabled) {      executor = new CachingExecutor(executor);    }    //插件拦截链 — 将配置中的所有 MyBatis 插件（Interceptor）应用到 executor 上。MyBatis 插件的本质是 JDK 动态代理，pluginAll() 会返回一个层层代理包装后的对象。这样用户自定义的拦截器（比如分页插件、SQL日志、读写分离等）就能拦截 Executor 的 query、update、commit 等方法。    executor = (Executor) interceptorChain.pluginAll(executor);    return executor;  }

// 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;  }

public classBoundSql{    /**    解析完成后的纯预处理 SQL    - 所有 `#{xxx}` 全部替换为 JDBC 占位符 `?`	- `${xxx}` 直接替换成对应字符串（直接拼接，无占位符）	- 去掉 XML 中的换行、多余空格，生成可给 `PreparedStatement` 使用的 SQL	如：SELECT id,name,age FROM user WHERE name = ? AND age = ? AND create_time = '2026-07-26'    */  private final String sql;     /**    占位符 `?` 对应的参数元数据列表**	SQL 里有几个`?`，集合里就有几个`ParameterMapping`对象。	每个`ParameterMapping`记录：占位符对应的参数名称、参数类型、是否允许 null 等信息。	ParameterMapping 内部关键属性：		- `property`：参数名（userName /userAge）		- `javaType`：参数 Java 类型（String / Integer）		- `jdbcType`：数据库字段类型（VARCHAR / INT）    */  private final List<ParameterMapping> parameterMappings;    /**    用户传入的主参数对象	就是调用 Mapper 方法时传入的参数，可以是实体类、Map、普通基础类型。    */  private final Object parameterObject;    /**    附加参数容器，存放不属于主 parameterObject 的额外变量	典型来源：1. `<foreach>` 循环变量（item、index）2. `${}` 表达式自定义变量3. MyBatis 内置分页参数、自定义上下文参数    */  private final Map<String, Object> additionalParameters;    /**    additionalParameters的包装工具对象，用于便捷读取 / 修改附加参数 Map`MetaObject` 是 MyBatis 内置反射工具，专门用来：		- 快速 get/set Map、实体对象的属性，不用手动反射		- 统一处理参数取值逻辑，封装反射细节    */  private final MetaObject metaParameters;}

@Intercepts({        @Signature(                type = Executor.class,                method = "query",                args = {MappedStatement.class, Object.class, RowBounds.class, ResultHandler.class}        )})public class PseudoPageInterceptor implements Interceptor {    @Override    public Object intercept(Invocation invocation) throws Throwable {        Object[] args = invocation.getArgs();        MappedStatement ms = (MappedStatement) args[0];        Object parameter = args[1];        RowBounds rowBounds = (RowBounds) args[2];        // 这里写死演示分页参数        int offset = rowBounds.getOffset();        int limit = 10;        // 1. 获取原始 BoundSql（包含 SQL + 参数映射）        BoundSql boundSql = ms.getBoundSql(parameter);        String originalSql = boundSql.getSql();        String pagedSql = originalSql + " LIMIT " + limit + " OFFSET " + offset;        System.out.println("[PseudoPage] ─────────────────────────────");        System.out.println("  原始 SQL : " + originalSql.replaceAll("\\s+", " ").trim());        System.out.println("  分页 SQL : " + pagedSql.replaceAll("\\s+", " ").trim());        System.out.println("  Offset   : " + offset + ", Limit: " + limit);        // ：替换 SqlSource，这样无论谁调 getBoundSql() 都能拿到分页 SQL。        SqlSource newSqlSource = new BoundSqlSqlSource(                ms.getConfiguration(), pagedSql, boundSql.getParameterMappings(), parameter);        replaceSqlSource(ms, newSqlSource);        System.out.println("[PseudoPage] ✅  SqlSource 已替换，分页 SQL 会向下传递");        System.out.println("[PseudoPage] ─────────────────────────────");        // 放行 → 下一个拦截器 → CachingExecutor → BaseExecutor → 数据库        return invocation.proceed();    }    /**     * 通过反射替换 MappedStatement 中的 sqlSource 字段     */    private void replaceSqlSource(MappedStatement ms, SqlSource newSqlSource) {        try {            Field field = MappedStatement.class.getDeclaredField("sqlSource");            field.setAccessible(true);            field.set(ms, newSqlSource);        } catch (Exception e) {            System.err.println("[PseudoPage] 替换 SqlSource 失败: " + e.getMessage());        }    }    /**     * 一个简单的 SqlSource 实现：直接返回指定的 SQL 和参数映射     * 不重新解析，直接用我们构造好的分页 SQL     */    static class BoundSqlSqlSource implements SqlSource {        private final Configuration configuration;        private final String sql;        private final List<ParameterMapping> parameterMappings;        private final Object parameterObject;        BoundSqlSqlSource(Configuration configuration, String sql,                          List<ParameterMapping> parameterMappings, Object parameterObject) {            this.configuration = configuration;            this.sql = sql;            this.parameterMappings = parameterMappings;            this.parameterObject = parameterObject;        }        @Override        public BoundSql getBoundSql(Object parameterObject) {            // 优先用构造时传入的参数（原始 BoundSql 中已解析好的）            Object param = parameterObject != null ? parameterObject : this.parameterObject;            return new BoundSql(configuration, sql, parameterMappings, param);        }    }    @Override    public Object plugin(Object target) {        return Plugin.wrap(target, this);    }    @Override    public void setProperties(Properties properties) {        System.out.println("[PseudoPage] 初始化完成");    }}