Mybatis入门源码二：sql执行

本文介绍: mybatis 的 sql 执行操作方法在 SqlSession 中，SqlSession 是 mybatis 的执行入口XxxMapper 是一个接口，mybatis 基于 jdk 动态代理机制会生成一个代理对象，其 InvocationHandler（具体类为 MapperProxy）的 invoker(…) 方法会获取 mapper.xml 定义的 sql 并执行。

后面开始分析sql执行的源码流程
也就是这一部分

重点关注configuration.newExecutor这个方法，获取事务处理器比较简单，就是获取一个jdbc的事务管理器。

执行完成之后最后生成了一个DefaultSqlSession，有关DefaultSqlSession，特别要注意一点，它是一个非线程安全的类。

�

关于knownMappers前面讲过：是一个map，里面存放的是mapper的类型和MapperProxyFactory类。

后面就是调用mapperProxyFactory.newInstance(sqlSession)进行mapper接口的实例化。

最终会拿着mapper接口、代理方法缓存生成InvokeHandler（用来生成Jdk代理必须要的类，当调用被代理的方法的时候，会调用到InvokeHandler的invokde方法）
最终返回的代理对象就是下图所示：

public class MapperMethod {

  // todo 存放sql的一些信息，其中name属性存放的是“包名、类名、方法名”
  private final SqlCommand command;
  // todo 方法的签名，主要存放方法的一些信息
  private final MethodSignature method;

  public MapperMethod(Class<?> mapperInterface, Method method, Configuration config) {
    this.command = new SqlCommand(config, mapperInterface, method);
    this.method = new MethodSignature(config, mapperInterface, method);
  }

  public Object execute(SqlSession sqlSession, Object[] args) {
    Object result;
    switch (command.getType()) {
      case INSERT: {
        Object param = method.convertArgsToSqlCommandParam(args);
        result = rowCountResult(sqlSession.insert(command.getName(), param));
        break;
      }
      case UPDATE: {
        Object param = method.convertArgsToSqlCommandParam(args);
        result = rowCountResult(sqlSession.update(command.getName(), param));
        break;
      }
      case DELETE: {
        Object param = method.convertArgsToSqlCommandParam(args);
        result = rowCountResult(sqlSession.delete(command.getName(), param));
        break;
      }
      case SELECT:
        // todo 处理查询操作
        if (method.returnsVoid() && method.hasResultHandler()) {
          executeWithResultHandler(sqlSession, args);
          result = null;
        } else if (method.returnsMany()) {
          // todo 返回多行记录
          result = executeForMany(sqlSession, args);
        } else if (method.returnsMap()) {
          result = executeForMap(sqlSession, args);
        } else if (method.returnsCursor()) {
          result = executeForCursor(sqlSession, args);
        } else {
          Object param = method.convertArgsToSqlCommandParam(args);
          result = sqlSession.selectOne(command.getName(), param);
          if (method.returnsOptional()
              && (result == null || !method.getReturnType().equals(result.getClass()))) {
            result = Optional.ofNullable(result);
          }
        }
        break;
      case FLUSH:
        result = sqlSession.flushStatements();
        break;
      default:
        throw new BindingException("Unknown execution method for: " + command.getName());
    }
    if (result == null && method.getReturnType().isPrimitive() && !method.returnsVoid()) {
      throw new BindingException("Mapper method '" + command.getName()
          + " attempted to return null from a method with a primitive return type (" + method.getReturnType() + ").");
    }
    return result;
  }