Mybatis|SqlSession四大对象（二）

---

1. SqlSession中四大神器之ParameterHandler

1.1 ParameterHandler介绍

参数处理器负责为ParameterHandler的sql语句参数动态赋值。

/**
 * A parameter handler sets the parameters of the {@code PreparedStatement}
 *
 * @author Clinton Begin
 */
public interface ParameterHandler {

  Object getParameterObject();

  void setParameters(PreparedStatement ps)
      throws SQLException;

}

这个接口中只有两个方法：
getParameterObject 方法用于读取参数。
setParameters用于对ParameterHandler的参数赋值。

1.2 ParameterHandler对象创建

参数处理器对象时在创建StatementHandler对象时同时被创建的，由configuration对象负责创建。

protected BaseStatementHandler(Executor executor, MappedStatement mappedStatement, Object parameterObject, RowBounds rowBounds, ResultHandler resultHandler, BoundSql boundSql) {
    this.configuration = mappedStatement.getConfiguration();
    this.executor = executor;
    this.mappedStatement = mappedStatement;
    this.rowBounds = rowBounds;

    this.typeHandlerRegistry = configuration.getTypeHandlerRegistry();
    this.objectFactory = configuration.getObjectFactory();

    if (boundSql == null) { // issue #435, get the key before calculating the statement
      generateKeys(parameterObject);
      boundSql = mappedStatement.getBoundSql(parameterObject);
    }

    this.boundSql = boundSql;

    this.parameterHandler = configuration.newParameterHandler(mappedStatement, parameterObject, boundSql);
    this.resultSetHandler = configuration.newResultSetHandler(executor, mappedStatement, rowBounds, parameterHandler, resultHandler, boundSql);
  }

创建时传入三个对象：mappedStatement（执行SQL对应的配置信息）、parameterObject、boundSql。

注意：一个BoundSql对象，代表了SQL语句的一次执行，而SqlSource对象的责任就是根据传入的参数对象动态计算出这个BoundSql，也就是说Mapper文件中的节点的计算是由SqlSource对象完成的。SqlSource最常用是实现类是DynamicSqlSource。

1.3 ParameterHandler中的参数从何而来？

 @Test
     public void Test01(){
            DeptDao dao =  session.getMapper(DeptDao.class);
            Dept dept = dao.findByDeptNo(10);
            System.out.println(dept.getDname());
     }

看看上述的实参10是如何添加到对应的SQL语句中的

 <select id="findByDeptNo" resultType="dept">
        <include refid="DeptFindSql"></include>
        where deptno = #{deptNo}
   </select>

在MyBatis中，使用动态代理模式，当dao.findByDeptNo(10)将要执行的时候，会被JVM进行拦截交给MyBatis中的代理实现类MapperProxy中的invoke方法。

@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);
  }

最后交给ParameterHandler中setParameter方法,将参数交给对应占位符。

 @Override
  public Object getParameterObject() {
    return parameterObject;
  }

@Override
  public void setParameters(PreparedStatement ps) {
    ErrorContext.instance().activity("setting parameters").object(mappedStatement.getParameterMap().getId());
    //parameterMappings  是对#{}里面的参数的封装，
    List<ParameterMapping> parameterMappings = boundSql.getParameterMappings();
    //如果是参数化sql（sql语句中带占位符？）便要设置参数   
    if (parameterMappings != null) {
      for (int i = 0; i < parameterMappings.size(); i++) {
        ParameterMapping parameterMapping = parameterMappings.get(i);
        if (parameterMapping.getMode() != ParameterMode.OUT) {
          Object value;
          String propertyName = parameterMapping.getProperty();
          if (boundSql.hasAdditionalParameter(propertyName)) { // issue #448 ask first for additional params
            value = boundSql.getAdditionalParameter(propertyName);
          } else if (parameterObject == null) {
            value = null;
          } else if (typeHandlerRegistry.hasTypeHandler(parameterObject.getClass())) {
            value = parameterObject;
          } else {
            MetaObject metaObject = configuration.newMetaObject(parameterObject);
            value = metaObject.getValue(propertyName);
          }
          TypeHandler typeHandler = parameterMapping.getTypeHandler();
          JdbcType jdbcType = parameterMapping.getJdbcType();
          if (value == null && jdbcType == null) {
            jdbcType = configuration.getJdbcTypeForNull();
          }
          try {
            typeHandler.setParameter(ps, i + 1, value, jdbcType);
          } catch (TypeException e) {
            throw new TypeException("Could not set parameters for mapping: " + parameterMapping + ". Cause: " + e, e);
          } catch (SQLException e) {
            throw new TypeException("Could not set parameters for mapping: " + parameterMapping + ". Cause: " + e, e);
          }
        }
      }
    }
  }

读取ParameterObject参数对象，然后用typeHandler对参数进行设置，而typeHandler里面需要对jdbcType和javaType进行处理，设置参数。所以使用TypeHandler的时候完全可以控制如何设置SQL参数。

2. Sqlsession四大神器之ResultSetHandler

2.1 ResultSetHandler介绍

ResultSetHandler接口主要负责两件事：

• 处理Statement执行后产生的结果集，生成结果列表。
• 处理存储过程执行后的输出参数 。

/**
 * @author Clinton Begin
 */
public interface ResultSetHandler {

  <E> List<E> handleResultSets(Statement stmt) throws SQLException;

  <E> Cursor<E> handleCursorResultSets(Statement stmt) throws SQLException;

  void handleOutputParameters(CallableStatement cs) throws SQLException;

}