江苏龙网

  1. 首页 > 人文 > >

Mybatis是如何执行一条SQL命令的

Mybatis中的Sql命令 ， 在枚举类SqlCommandType中定义的 。
Mybatis是如何执行一条SQL命令的文章插图
下面 ， 我们以Mapper接口中的一个方法作为例子 ， 看看Sql命令的执行完整流程 。
Mybatis是如何执行一条SQL命令的文章插图
参数RowBounds和ResultSetHandler是可选参数 ， 表示分页对象和自定义结果集处理器 ， 一般不需要 。
一个完整的Sql命令 ， 其执行的完整流程图如下：
Mybatis是如何执行一条SQL命令的文章插图
对于上面的流程图 ， 如果看过前面的文章的话 ， 大部分对象我们都比较熟悉了 。 一个图 ， 就完整展示了其执行流程 。
MapperProxy的功能：
1. 因为Mapper接口不能直接实例化 ， MapperProxy的作用 ， 就是使用JDK动态代理功能 ， 间接实例化Mapper的proxy对象 。 可参看系列的第二篇 。
2. 缓存MapperMethod对象 。
private final Map methodCache;
@Override
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);
}
}
// 投鞭断流
final MapperMethod mapperMethod = cachedMapperMethod(method);
return mapperMethod.execute(sqlSession, args);
}
// 缓存MapperMethod
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的功能：
1. 解析Mapper接口的方法 ， 并封装成MapperMethod对象 。
2. 将Sql命令 ， 正确路由到恰当的SqlSession的方法上 。
public class MapperMethod {
// 保存了Sql命令的类型和键id
private final SqlCommand command;
// 保存了Mapper接口方法的解析信息
private final MethodSignature method;
public MapperMethod(Class mapperInterface, Method method, Configuration config) {
this.command = new SqlCommand(config, mapperInterface, method);
this.method = new MethodSignature(config, method);
}
// 根据解析结果 ， 路由到恰当的SqlSession方法上
public Object execute(SqlSession sqlSession, Object[] args) {
Object result;
if (SqlCommandType.INSERT == command.getType()) {
Object param = method.convertArgsToSqlCommandParam(args);
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));
} else if (SqlCommandType.DELETE == command.getType()) {
Object param = method.convertArgsToSqlCommandParam(args);
result = rowCountResult(sqlSession.delete(command.getName(), param));


推荐阅读


上一篇：图文详解并联机器人，你了解吗？

下一篇：HBase你真的了解吗？