mybatis第6 章：MapperProxy

分享未结  0  921

李延 LV6 2021-06-06

悬赏：20积分

# 作用

这是一个java动态代理类。我们的mapper接口最后就是执行它的invoke方法

# invoke

在我们调用所有的mappe方法是执行这个方法。

```java
@Override
  public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
    try {
      if (Object.class.equals(method.getDeclaringClass())) {
        return method.invoke(this, args);
      } else if (isDefaultMethod(method)) {
        return invokeDefaultMethod(proxy, method, args);
      }
    } catch (Throwable t) {
      throw ExceptionUtil.unwrapThrowable(t);
    }
    final MapperMethod mapperMethod = cachedMapperMethod(method);
    return mapperMethod.execute(sqlSession, args);
  }

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对象的execute去执行。

我们跟进

# MapperMethod

## 构造方法

```java
public MapperMethod(Class<?> mapperInterface, Method method, Configuration config) {
    // sql 相关信息
    this.command = new SqlCommand(config, mapperInterface, method);
    // 方法相关信息
    this.method = new MethodSignature(config, mapperInterface, method);
  }

```

这里有两个对象，一个用于获取sql相关形象，一个用于获取方法相关形象

## execute

```java
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:
        if (method.returnsVoid() && method.hasResultHandler()) {
          executeWithResultHandler(sqlSession, args);
          result = null;
        } else if (method.returnsMany()) {
          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);
        }
        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;
  }

```

这里我们看到有2个主要步骤
- 跟进不同的sql类型进行不同的处理
- 基本上每个都是先进行参数处理通过ParamNameResolver对象
- 最后都是调用了SqlSession对象，根据前面不同的sql类型，调用不同的方法

这里我们的SqlSession对象是SqlSessionTemplate对象。

## SqlSessionTemplate

我们看一下它的构造方法

```java
  public SqlSessionTemplate(SqlSessionFactory sqlSessionFactory, ExecutorType executorType,
      PersistenceExceptionTranslator exceptionTranslator) {

notNull(sqlSessionFactory, "Property 'sqlSessionFactory' is required");
    notNull(executorType, "Property 'executorType' is required");

this.sqlSessionFactory = sqlSessionFactory;
    this.executorType = executorType;
    this.exceptionTranslator = exceptionTranslator;
    this.sqlSessionProxy = (SqlSession) newProxyInstance(
        SqlSessionFactory.class.getClassLoader(),
        new Class[] { SqlSession.class },
        new SqlSessionInterceptor());
  }

```

在最后一步创建了sqlSessionProxy对象，而这一步也就是通过SqlSessionFactory对象的openSessionFromDataSource方法创建了DefaultSqlSession

而具体的执行方法也就交给了DefaultSqlSession对象

回帖

消灭零回复