MyBatis 源码深度拆解(一):整体架构 & 核心执行全流程

// 1. 加载配置文件InputStream in = Resources.getResourceAsStream("mybatis-config.xml");// 2. 构建 SqlSessionFactorySqlSessionFactory factory = new SqlSessionFactoryBuilder().build(in);// 3. 打开 SqlSessionSqlSession session = factory.openSession();// 4. 获取 Mapper 接口的代理对象UserMapper mapper = session.getMapper(UserMapper.class);// 5. 执行查询User user = mapper.selectById(1);// 6. 关闭会话session.close();

public interface UserMapper {    @Select("SELECT * FROM user WHERE id = #{id}")    User selectById(@Param("id")int i);    // User 包含 id  userName password email    @Update("UPDATE user SET user_name = #{userName}, password = #{password}, email = #{email} WHERE id = #{id}")    void update(User user);    @Select("SELECT * FROM user")    List<User> selectAll();}

<?xml version="1.0" encoding="UTF-8" ?><!DOCTYPE configuration        PUBLIC "-//mybatis.org//DTD Config 3.0//EN"        "https://mybatis.org/dtd/mybatis-3-config.dtd"><configuration>    <!-- 1. 外部化配置 -->    <propertiesresource="jdbc.properties"/>    <!-- 2. 全局行为设置 -->    <settings>        <settingname="mapUnderscoreToCamelCase"value="true"/>        <settingname="logImpl"value="STDOUT_LOGGING"/>        <settingname="lazyLoadingEnabled"value="true"/>    </settings>    <!-- 3. 别名 -->    <typeAliases>        <packagename="com.example.entity"/>    </typeAliases>    <!-- 4. 数据库环境 -->    <environmentsdefault="development">        <environmentid="development">            <transactionManagertype="JDBC"/>            <dataSourcetype="POOLED">                <propertyname="driver"value="${jdbc.driver}"/>                <propertyname="url"value="${jdbc.url}"/>                <propertyname="username"value="${jdbc.username}"/>                <propertyname="password"value="${jdbc.password}"/>            </dataSource>        </environment>    </environments>    <!-- 5. Mapper 注册 -->    <mappers>        <packagename="com.example.mapper"/>    </mappers></configuration>

# MySQL 8.x 驱动配置jdbc.driver=com.mysql.cj.jdbc.Driverjdbc.url=jdbc:mysql://localhost:3306/test?useSSL=false&serverTimezone=Asia/Shanghai&characterEncoding=utf8jdbc.username=rootjdbc.password=123456

 <!-- MyBatis 核心依赖 -->        <dependency>            <groupId>org.mybatis</groupId>            <artifactId>mybatis</artifactId>            <version>3.5.16</version>        </dependency>        <!-- MySQL 驱动依赖 -->        <dependency>            <groupId>mysql</groupId>            <artifactId>mysql-connector-java</artifactId>            <version>8.0.33</version>        </dependency>

// SqlSessionFactoryBuilder 部分源码public SqlSessionFactory build(InputStream inputStream) {    return build(inputStream, null, null);}//把有些内容简化了下哈  如果感观不好，可以去看看源码哈public SqlSessionFactory build(InputStream inputStream, String environment, Properties properties) {    try {        // 1. 创建 XMLConfigBuilder，专门解析 mybatis-config.xml        XMLConfigBuilder parser = new XMLConfigBuilder(inputStream, environment, properties);        // 2. 解析配置文件，返回 Configuration 对象        Configuration config = parser.parse();        // 3. 构建 DefaultSqlSessionFactory        return build(config);    } catch (Exception e) {        throw ExceptionFactory.wrapException("Error building SqlSession.", e);    }}

// DefaultSqlSessionFactory 部分源码  没有百分百还原哈@Overridepublic SqlSession openSession() {    return openSessionFromDataSource(configuration.getDefaultExecutorType(), null, false);}private SqlSession openSessionFromDataSource(ExecutorType execType, TransactionIsolationLevel level, boolean autoCommit) {    Transaction tx = null;    try {        // 1. 从 Configuration 中获取 Environment        Environment environment = configuration.getEnvironment();        // 2. 创建 TransactionFactory 和 Transaction        TransactionFactory transactionFactory = getTransactionFactoryFromEnvironment(environment);        tx = transactionFactory.newTransaction(environment.getDataSource(), level, autoCommit);        // 3. 创建 Executor        Executor executor = configuration.newExecutor(tx, execType);        // 4. 包装成 DefaultSqlSession        return new DefaultSqlSession(configuration, executor, autoCommit);    } catch (Exception e) {        closeTransaction(tx);        throw ExceptionFactory.wrapException("Error opening session.  Cause: " + e, e);    }}

// DefaultSqlSession 部分源码@Overridepublic <T> T getMapper(Class<T> type) {    return configuration.getMapper(type, this);}// Configuration 部分源码public <T> T getMapper(Class<T> type, SqlSession sqlSession) {    return mapperRegistry.getMapper(type, sqlSession);}// MapperRegistry 部分源码public <T> T getMapper(Class<T> type, SqlSession sqlSession) {    // 从 knownMappers 中获取 MapperProxyFactory    final MapperProxyFactory<T> mapperProxyFactory = (MapperProxyFactory<T>) knownMappers.get(type);    if (mapperProxyFactory == null) {        throw new BindingException("Type " + type + " is not known to the MapperRegistry.");    }    try {        // 通过工厂创建动态代理        return mapperProxyFactory.newInstance(sqlSession);    } catch (Exception e) {        throw new BindingException("Error getting mapper instance. Cause: " + e, e);    }}// MapperProxyFactory 部分源码public T newInstance(SqlSession sqlSession) {    // MapperProxy 实现了 InvocationHandler     final MapperProxy<T> mapperProxy = new MapperProxy<>(sqlSession, mapperInterface, methodCache);    return newInstance(mapperProxy);}protected T newInstance(MapperProxy<T> mapperProxy) {    // JDK 动态代理    return (T) Proxy.newProxyInstance(mapperInterface.getClassLoader(), new Class[] { mapperInterface }, mapperProxy);}

// MapperProxy.invoke 核心逻辑（简化版）@Overridepublic Object invoke(Object proxy, Method method, Object[] args) throwsThrowable{    // 如果是 Object 类的方法（toString等）直接执行    if (Object.class.equals(method.getDeclaringClass())) {        return method.invoke(this, args);    }    // 核心：从缓存或新建 MapperMethod，然后执行    return cachedInvoker(method).invoke(proxy, method, args, sqlSession);}

// DefaultSqlSession 部分源码@Overridepublic <E> List<E> selectList(String statement, Object parameter, RowBounds rowBounds) {    return selectList(statement, parameter, rowBounds, Executor.NO_RESULT_HANDLER);}private <E> List<E> selectList(String statement, Object parameter, RowBounds rowBounds, ResultHandler handler) {    try {        // 1. 从 Configuration 中获取 MappedStatement      MappedStatement ms = configuration.getMappedStatement(statement);      dirty |= ms.isDirtySelect();        // 2. 交给 Executor 执行      return executor.query(ms, wrapCollection(parameter), rowBounds, handler);    } catch (Exception e) {      throw ExceptionFactory.wrapException("Error querying database.  Cause: " + e, e);    } finally {      ErrorContext.instance().reset();    }  }

// CachingExecutor 部分源码@Overridepublic <E> List<E> query(MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler) throws SQLException {    // 1. 获取 BoundSql（解析 #{} 后的 SQL，带 ? 占位符）    BoundSql boundSql = ms.getBoundSql(parameter);    // 2. 生成缓存 Key    CacheKey key = createCacheKey(ms, parameter, rowBounds, boundSql);    // 3. 后续深入追踪会继续调用executo的query方法    return query(ms, parameter, rowBounds, resultHandler, key, boundSql);}// 实际执行  BaseExecutor 部分源码@Overridepublic <E> List<E> query(MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler, CacheKey key, BoundSql boundSql) throws SQLException {    // 1. 一级缓存    List<E> list = resultHandler == null ? (List<E>) localCache.getObject(key) : null;    if (list != null) {        // 缓存命中，处理存储过程 OUT 参数        handleLocallyCachedOutputParameters(ms, key, parameter, boundSql);    } else {        // 未命中，从数据库查询        list = queryFromDatabase(ms, parameter, rowBounds, resultHandler, key, boundSql);    }    return list;}private <E> List<E> queryFromDatabase(MappedStatement ms, Object parameter, RowBounds rowBounds,      ResultHandler resultHandler, CacheKey key, BoundSql boundSql) {    List<E> list;    localCache.putObject(key, EXECUTION_PLACEHOLDER);    try {        // 调用 doQuery 真正执行 JDBC        list = doQuery(ms, parameter, rowBounds, resultHandler, boundSql);    } finally {        localCache.removeObject(key);    }    localCache.putObject(key, list);    return list;}

// SimpleExecutor 部分源码@Overridepublic <E> List<E> doQuery(MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler, BoundSql boundSql) throws SQLException {    Statement stmt = null;    try {        Configuration configuration = ms.getConfiguration();        // 1. 创建 StatementHandler        StatementHandler handler = configuration.newStatementHandler(wrapper, ms, parameter, rowBounds, resultHandler, boundSql);        // 2. 预编译 SQL        stmt = prepareStatement(handler, ms.getStatementLog());        // 3. 执行并处理结果集        return handler.query(stmt, resultHandler);    } finally {        closeStatement(stmt);    }}private Statement prepareStatement(StatementHandler handler, Log statementLog) throws SQLException {    Statement stmt;    // 获取数据库连接    Connection connection = getConnection(statementLog);    // 创建 Statement    stmt = handler.prepare(connection, transaction.getTimeout());    // 设置参数（#{} 占位符被替换成 ? 后，这里设置实际参数值）    handler.parameterize(stmt);    return stmt;}

1. 加载 mybatis-config.xml → 生成 Configuration（全局配置）2. SqlSessionFactoryBuilder.build() → 创建 DefaultSqlSessionFactory3. factory.openSession() → 创建 SqlSession（持有 Configuration + Executor）4. session.getMapper() → JDK 动态代理 → MapperProxy5. 调用 mapper 方法 → MapperProxy.invoke() → MapperMethod.execute()6. MapperMethod 调用 SqlSession.selectOne/selectList7. SqlSession 从 Configuration 获取 MappedStatement8. Executor 处理缓存（一级缓存），然后调用 doQuery9. StatementHandler 创建 Statement、预编译 SQL10. ParameterHandler 设置参数11. 执行 SQL (JDBC)12. ResultSetHandler 处理结果集 → 返回 List/对象13. 层层返回，最终拿到结果