MyBatis 源码深度拆解(六):#{} 与 ${} 底层解析 & SQL 预编译

SELECT * FROM user WHERE id = #{id}SELECT * FROM user WHERE name like '%${keyword}%'

// MappedStatementpublic BoundSql getBoundSql(Object parameterObject) {    BoundSql boundSql = sqlSource.getBoundSql(parameterObject);    // 处理 parameterMappings 中可能缺失的参数    return boundSql;}

// DynamicSqlSourcepublic BoundSql getBoundSql(Object parameterObject) {    // 1. 使用 Context 解析动态 SQL，生成最终 SQL 字符串（包含 ${} 的直接拼接和静态文本）    DynamicContext context = new DynamicContext(configuration, parameterObject);    // 在这里，${} 被替换，<if>、<foreach> 等动态标签被处理    rootSqlNode.apply(context);      // rootSqlNode 是动态 SQL 的根节点    // 2. 处理 ${} 替换后，得到包含 #{} 的 SQL    String sql = context.getSql();    // 3. 解析 #{}，生成 ParameterMapping 列表，同时将 #{} 替换为 ?    SqlSourceBuilder sqlSourceParser = new SqlSourceBuilder(configuration);    Class<?> parameterType = parameterObject == null ? Object.class : parameterObject.getClass();    SqlSource sqlSource = sqlSourceParser.parse(sql, parameterType, context.getBindings());    // 4. 获取最终的 BoundSql（此时 sql 已经是带 ? 的）    BoundSql boundSql = sqlSource.getBoundSql(parameterObject);    // 5. 将 DynamicContext 中的额外的参数（如 _parameter）复制到 BoundSql 中    context.getBindings().forEach(boundSql::setAdditionalParameter);    return boundSql;}

// SqlSourceBuilderpublic SqlSource parse(String originalSql, Class<?> parameterType, Map<String, Object> additionalParameters) {    ParameterMappingTokenHandler handler = new ParameterMappingTokenHandler(configuration, parameterType, additionalParameters);    GenericTokenParser parser = new GenericTokenParser("#{", "}", handler);    String sql;    if (configuration.isShrinkWhitespacesInSql()) {        // 可选：压缩多余空白字符，使 SQL 规范化，提高缓存命中率        sql = parser.parse(removeExtraWhitespaces(originalSql));    } else {        sql = parser.parse(originalSql);    }    return new StaticSqlSource(configuration, sql, handler.getParameterMappings());}

// ParameterMappingTokenHandler   将实际内容简单整合了下  看源码时注意下public String handleToken(String content) {    // content 是 #{...} 里面的内容，例如 "id", "user.name", "param1"}    // 1. 解析参数名、javaType、jdbcType、typeHandler 等    ParameterMapping.Builder builder = new ParameterMapping.Builder(configuration, content, parameterType);    // ... 解析属性（javaType, jdbcType, mode, numericScale, resultMapId, typeHandler 等）    ParameterMapping mapping = builder.build();    // 2. 添加到参数映射列表    parameterMappings.add(mapping);    // 3. 替换为 ? 占位符    return "?";}

public String parse(String text) {    if (text == null || text.isEmpty()) return "";    int start = text.indexOf(openToken);    if (start == -1) return text;    char[] src = text.toCharArray();    int offset = 0;    StringBuilder builder = new StringBuilder();    StringBuilder expression = null;    do {        // 1. 检查开放标记前是否有转义符 '\'        if (start > 0 && src[start - 1] == '\\') {            // 遇到转义：去掉反斜杠，原样输出 openToken，继续            builder.append(src, offset, start - offset - 1).append(openToken);            offset = start + openToken.length();        } else {            // 2. 找到有效开放标记            builder.append(src, offset, start - offset);            offset = start + openToken.length();            // 3. 寻找闭合标记，处理转义            int end = text.indexOf(closeToken, offset);            while (end > -1) {                if (src[end - 1] != '\\') {                    // 未转义的闭合标记                    expression.append(src, offset, end - offset);                    break;                }                // 转义的闭合标记：去掉反斜杠，保留 closeToken，继续查找                expression.append(src, offset, end - offset - 1).append(closeToken);                offset = end + closeToken.length();                end = text.indexOf(closeToken, offset);            }            if (end == -1) {                // 闭合标记未找到：将剩余部分原样输出                builder.append(src, start, src.length - start);                offset = src.length;            } else {                // 4. 调用 handler 处理内容，并替换为处理结果                builder.append(handler.handleToken(expression.toString()));                offset = end + closeToken.length();            }        }        start = text.indexOf(openToken, offset);    } while (start > -1);    if (offset < src.length) {        builder.append(src, offset, src.length - offset);    }    return builder.toString();}

// 示例：输入 SQL 中包含转义占位符String sql = "SELECT * FROM user WHERE name = '\\#{value}' AND id = #{id}";// 解析结果：// SELECT * FROM user WHERE name = '#{value}' AND id = ?// 注：\\#{value} 转义后变为 #{value} 字面文本，不会被处理

// TextSqlNodepublic boolean apply(DynamicContext context) {    // 创建 GenericTokenParser，使用 ${} 标记  稍微合并了一下    GenericTokenParser parser = new GenericTokenParser("${", "}", new BindingTokenParser(context, injectionFilter));    context.appendSql(parser.parse(text));    return true;}

// BindingTokenParser@Overridepublic String handleToken(String content) {    Object parameter = context.getBindings().get("_parameter");    if (parameter == null) {        context.getBindings().put("value", null);    } else if (SimpleTypeRegistry.isSimpleType(parameter.getClass())) {        context.getBindings().put("value", parameter);    }    // 使用 OGNL 或反射从参数对象中获取 property 的值    Object value = OgnlCache.getValue(content, context.getBindings());    // 直接返回 value 的字符串形式（null 会转为空字符串）    String srtValue = value == null ? "" : String.valueOf(value);    checkInjection(srtValue);    return srtValue;}

public abstract class BaseStatementHandler implements StatementHandler {    @Override    public Statement prepare(Connection connection, Integer transactionTimeout) throws SQLException {        ErrorContext.instance().sql(boundSql.getSql()); // 记录即将执行的SQL        Statement statement = null;        try {            // 1. 关键步骤：调用子类实现的instantiateStatement()来创建具体的Statement对象            statement = instantiateStatement(connection);            setStatementTimeout(statement, transactionTimeout);            setFetchSize(statement);            return statement;        } catch (SQLException e) {            closeStatement(statement);            throw e;        } catch (Exception e) {            closeStatement(statement);            throw new ExecutorException("Error preparing statement.  Cause: " + e, e);        }    }    // 抽象方法，留给子类去实现，用于创建具体的Statement    protected abstract Statement instantiateStatement(Connection connection) throws SQLException;}

// DefaultParameterHandlerpublic void setParameters(PreparedStatement ps) {    List<ParameterMapping> parameterMappings = boundSql.getParameterMappings();    for (int i = 0; i < parameterMappings.size(); i++) {        ParameterMapping mapping = parameterMappings.get(i);        String propertyName = mapping.getProperty();        Object value = 从参数对象中获取 propertyName 的值;        // 根据 jdbcType 和 typeHandler 设置参数        typeHandler.setParameter(ps, i + 1, value, jdbcType);    }}

<select id="findUser" resultType="User">    SELECT * FROM user WHERE name = '${name}'</select>

SELECT * FROM user WHERE name = 'xxx' OR '1'='1'