MyBatis 原理解析之Mapper 接口没有实现类SQL 执行过程_Java

使用 mybatis 时，我们通常只需要定义一个 mapper 接口：

public interface usermapper {
    user selectbyid(long id);
}

然后直接调用：

user user = usermapper.selectbyid(1l);

整个过程中，没有写实现类，没有手动创建 connection、preparedstatement，甚至没有在 java 代码里写 sql。那么这个接口方法到底是谁实现的？sql 又是在什么时候执行的？

mybatis 内部通过一套分层架构完成 sql 解析和执行，mapper 接口通过动态代理生成运行时实现类。

mybatis 整体架构

mybatis 可以分为三层：

接口层

接口层是开发者直接接触的部分，主要是 sqlsession 和 mapper 接口。

两种调用方式最终都会进入 mybatis 内部执行流程：

// 方式一：通过 sqlsession 直接调用
sqlsession.selectone("com.demo.usermapper.selectbyid", 1l);
// 方式二：通过 mapper 接口调用
usermapper.selectbyid(1l);

核心处理层

核心处理层负责 sql 的整个生命周期，主要组件：

configuration 负责保存 mybatis 的配置：mapper 信息、sql 映射关系、数据源配置。

executor 负责真正执行查询，处理一级缓存、二级缓存，调用 statementhandler。

statementhandler 负责和 jdbc 交互：创建 preparedstatement、设置参数、执行 sql。

resultsethandler 负责处理数据库返回的数据，把 resultset 转成 java 对象。

基础支撑层

这一层提供底层能力：数据源管理、事务管理、缓存、类型转换。比如数据库连接不会每次查询都重新创建，而是通过连接池进行复用。

一次查询的完整链路

假设有一个 mapper：

user user = usermapper.selectbyid(1);

实际调用链：

usermapper.selectbyid(1)
        │
        ▼
mapperproxy.invoke()
        │
        ▼
mappermethod.execute()
        │
        ▼
sqlsession.selectone()
        │
        ▼
executor.query()
        │
        ▼
statementhandler.query()
        │
        ▼
resultsethandler
        │
        ▼
返回 user 对象

前半部分解决 mapper 接口方法如何找到对应 sql，后半部分解决 sql 如何通过 jdbc 执行并转换成 java 对象。后半部分涉及的 executor、statementhandler、resultsethandler 是更底层的组件，后续文章再展开。

mapper 接口为什么可以直接调用

java 接口本身不能创建对象：

usermapper mapper = new usermapper();  // 编译报错

但 mybatis 返回给你的：

usermapper mapper = sqlsession.getmapper(usermapper.class);

实际上不是 usermapper 的实现类，而是一个 jdk 动态代理对象。可以理解为：

usermapper 接口
      │
      ▼
jdk proxy 生成代理对象
      │
      ▼
mapperproxy 处理方法调用
      │
      ▼
执行对应 sql

mapper 代理是怎么创建的

核心代码：

public class mapperproxyfactory<t> {
    private final class<t> mapperinterface;  // 比如 usermapper.class
    public t newinstance(sqlsession sqlsession) {
        mapperproxy<t> mapperproxy = new mapperproxy<>(
            sqlsession,
            mapperinterface,
            methodcache  // 缓存每个方法对应的 mappermethod
        );
        return (t) proxy.newproxyinstance(
            mapperinterface.getclassloader(),
            new class[]{mapperinterface},
            mapperproxy  // 所有方法调用都会被它拦截
        );
    }
}

proxy.newproxyinstance 是 jdk 自带的动态代理 api，创建的对象实现了 usermapper 接口，但方法调用不会进入接口，而是进入 mapperproxy.invoke()。

mapperproxy 做了什么

核心代码：

public class mapperproxy<t> implements invocationhandler {
    private final sqlsession sqlsession;
    private final class<t> mapperinterface;
    private final map<method, mappermethod> methodcache;
    @override
    public object invoke(object proxy, method method, object[] args)
            throws throwable {
        // object 类的方法直接放行
        if (object.class.equals(method.getdeclaringclass())) {
            return method.invoke(this, args);
        }
        // 找到当前方法对应的 mappermethod
        mappermethod mappermethod = methodcache.computeifabsent(
            method,
            m -> new mappermethod(mapperinterface, m, sqlsession.getconfiguration())
        );
        // 执行 sql
        return mappermethod.execute(sqlsession, args);
    }
}

主要做两件事。

第一，找到当前方法对应的 mappermethod。 比如调用 usermapper.selectbyid(1)，mybatis 会找到 usermapper.selectbyid 对应的 sql 配置。

第二，调用 sqlsession 执行。 mappermethod.execute() 根据 sql 类型（select/insert/update/delete）调用对应的 sqlsession 方法：

public object execute(sqlsession sqlsession, object[] args) {
    object result;
    switch (command.gettype()) {
        case insert:
            result = sqlsession.insert(command.getname(), args);
            break;
        case update:
            result = sqlsession.update(command.getname(), args);
            break;
        case delete:
            result = sqlsession.delete(command.getname(), args);
            break;
        case select:
            if (method.returnsmany()) {
                result = sqlsession.selectlist(command.getname(), args);
            } else {
                result = sqlsession.selectone(command.getname(), args);
            }
            break;
        default:
            throw new bindingexception("未知的 sql 类型");
    }
    return result;
}

command.getname() 是 sql 的唯一标识，格式是 namespace + id，比如 com.example.mapper.usermapper.selectbyid。mybatis 靠这个标识找到对应的 sql 语句。

最终进入 sqlsession → executor → statementhandler → jdbc 执行。

和 jdbc 的对比

jdbc 查询同一条数据：

connection conn = null;
preparedstatement ps = null;
resultset rs = null;
user user = null;
try {
    conn = drivermanager.getconnection(url, username, password);
    string sql = "select * from user where id = ?";
    ps = conn.preparestatement(sql);
    ps.setlong(1, id);
    rs = ps.executequery();
    if (rs.next()) {
        user = new user();
        user.setid(rs.getlong("id"));
        user.setname(rs.getstring("name"));
    }
} catch (sqlexception e) {
    e.printstacktrace();
} finally {
    try { if (rs != null) rs.close(); } catch (sqlexception e) {}
    try { if (ps != null) ps.close(); } catch (sqlexception e) {}
    try { if (conn != null) conn.close(); } catch (sqlexception e) {}
}

mybatis 做同样的事：

user user = usermapper.selectbyid(1l);

mybatis 实际封装的工作：

jdbc 工作	mybatis 负责
获取连接	数据源管理
创建 statement	statementhandler
设置参数	参数映射
执行 sql	executor
resultset 转换	resultsethandler
资源释放	框架管理

小结

mybatis 的 mapper 接口之所以没有实现类，是因为运行时通过 proxy.newproxyinstance 生成了动态代理对象。

一次 mapper 调用经过的路径：

接口方法 → mapperproxy → mappermethod → sqlsession → executor → jdbc

动态代理解决了接口调用问题，执行器体系解决了 sql 执行问题。开发者看到的是 usermapper.selectbyid(1)，而 mybatis 背后完成的是解析方法、定位 sql、创建 statement、执行查询、映射对象、返回结果。这也是 mybatis 能够让开发者只关注 sql，而不用关心 jdbc 细节的原因。

到此这篇关于mybatis 原理解析之mapper 接口没有实现类sql 执行过程的文章就介绍到这了,更多相关mybatis mapper 接口内容请搜索代码网以前的文章或继续浏览下面的相关文章希望大家以后多多支持代码网！