执行增删改查时获取SQL语句

news2024/11/24 22:47:34

查询为例
查询方法由SqlSessionTemplate中创建DefaultSqlSession，然后执行DefaultSqlSession的selectList方法。
在这里插入图片描述

然后继续执行查询方法
执行executor.query方法，executor为CachingExecutor类型。

在这里插入图片描述

如果引入了pagehelper依赖，这里执行前会进入分页拦截器
在这里插入图片描述
关键方法是这个getBoundsql，就是通过这个方法获取到sql的。

BoundSql

public class BoundSql {
    // 一个完整的 SQL 语句，可能会包含问号 ? 占位符
    private final String sql;
    // 参数映射列表，SQL 中的每个 #{xxx} 占位符都会被解析成相应的 ParameterMapping 对象
    private final List<ParameterMapping> parameterMappings;
    // 运行时参数，即用户传入的参数，比如 Article 对象，或是其他的参数
    private final Object parameterObject;
    // 附加参数集合，用于存储一些额外的信息，比如 datebaseId 等
    private final Map<String, Object> additionalParameters;
    // additionalParameters 的元信息对象
    private final MetaObject metaParameters;
}

getBoundSql方法

  public BoundSql getBoundSql(Object parameterObject) {
  	//获取BoundSql 
    BoundSql boundSql = sqlSource.getBoundSql(parameterObject);
    //获取参数映射
    List<ParameterMapping> parameterMappings = boundSql.getParameterMappings();
    if (parameterMappings == null || parameterMappings.isEmpty()) {
      boundSql = new BoundSql(configuration, boundSql.getSql(), parameterMap.getParameterMappings(), parameterObject);
    }

    // check for nested result maps in parameter mappings (issue #30)
    for (ParameterMapping pm : boundSql.getParameterMappings()) {
      String rmId = pm.getResultMapId();
      if (rmId != null) {
        ResultMap rm = configuration.getResultMap(rmId);
        if (rm != null) {
          hasNestedResultMaps |= rm.hasNestedResultMaps();
        }
      }
    }

    return boundSql;
  }

这里如果参数是${}这样的，就会走DynamicSqlSource类的getBoundSql
在这里插入图片描述
然后执行MixedSqlNode类apply方法把 ${}的内容替换成真实数据
传入的是原始sql

TextSqlNode类的apply方法

GenericTokenParser类的parse方法

关键方法

TextSqlNode类的handleToken方法
从context拿到值，根据传进来的key

这时拿到的sql就是完整的sql了
在这里插入图片描述

如果是#{}
则会走StaticSqlSource类的getBoundSql方法
在这里插入图片描述
执行完参数还是问号？

然后继续执行查询方法，应该是在最终查询时将实际数据传入的。
继续CachingExecutor的query方法

然后执行BaseExecutor类的query方法
没有缓存的话去数据库查询

在这里插入图片描述
继续BaseExecutor类的queryFromDatabase方法
先把key放入缓存，然后继续执行doQuery方法

在这里插入图片描述
SimpleExecutor类的doQuery方法

关键方法 prepareStatement() 方法
SimpleExecutor类的prepareStatement方法

关键方法parameterize
就是这个方法给？赋的值
RoutingStatementHandler类的parameterize方法

DefaultParameterHandler类的setParameters方法

  public void setParameters(PreparedStatement ps) {
    ErrorContext.instance().activity("setting parameters").object(mappedStatement.getParameterMap().getId());
    //从boundSql拿到参数的标识
    List<ParameterMapping> parameterMappings = boundSql.getParameterMappings();
    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 {
          	//parameterObject就是传入的值
            MetaObject metaObject = configuration.newMetaObject(parameterObject);
            //根据key拿到value 这样就拿到了我们传入的值
            value = metaObject.getValue(propertyName);
          }
          TypeHandler typeHandler = parameterMapping.getTypeHandler();
          JdbcType jdbcType = parameterMapping.getJdbcType();
          if (value == null && jdbcType == null) {
            jdbcType = configuration.getJdbcTypeForNull();
          }
          try {
            // 由类型处理器 typeHandler 向 ParameterHandler 设置参数
            typeHandler.setParameter(ps, i + 1, value, jdbcType);
          } catch (TypeException | SQLException e) {
            throw new TypeException("Could not set parameters for mapping: " + parameterMapping + ". Cause: " + e, e);
          }
        }
      }
    }
  }