SQLASTOutputVisitor格式化有bug只拼了一半单引号导致生成的SQL语法不对

[lizongbo]

我继承StatFilter将sql做了采样分析，采样的时候将sql进行格式化只会再次参数化处理，结果生产遇到问题
然后发现SQLASTOutputVisitor在拼sql的时候针对Reader等类型只拼了前半截单引号，没有后半截单引号就return了。

https://github.com/alibaba/druid/blob/master/src/main/java/com/alibaba/druid/sql/visitor/SQLASTOutputVisitor.java#L2310

我的代码如下：

private static List<Object> getSqlParamObjetList(StatementProxy statement) {
        List<Object> parameters = null;
        int parametersSize = statement.getParametersSize();
        if (parametersSize > 0) {
            parameters = new ArrayList<>(parametersSize);
            for (int i = 0; i < parametersSize; ++i) {
                JdbcParameter jdbcParam = statement.getParameter(i);
                Object param = jdbcParam != null ? jdbcParam.getValue() : null;
                if (param instanceof String) {
                    String str = (String) param;
                    if (str.length() > 300) {// 超长文本做截取
                        param = str.subSequence(0, 300) + ".........";
                    }
                }
//以下是为了兼容druid SQLASTOutputVisitor的bug,返回指定字符串
                if (param instanceof InputStream) {
                    param = ("< InputStream >");
                }
                if (param instanceof Reader) {
                    param = ("< Reader >");
                }
                if (param instanceof Blob) {
                    param = ("< Blob >");
                }
                if (param instanceof NClob) {
                    param = ("< NClob >");
                }

                if (param instanceof Clob) {
                    param = ("< Clob >");
                }
                parameters.add(param);
            }
        }
        return parameters;
    }
 private void trySamplingSql(String method, StatementProxy statement, String sql) {
        String dbType = statement.getConnectionProxy().getDirectDataSource().getDbType();
        List<Object> parameters = getSqlParamObjetList(statement);

  String formattedSql = SQLUtils.format(sql, dbType, parameters);
        String mergedSql = null;
        try {
//parameters里有Reader等类型就会出错了。
            mergedSql = ParameterizedOutputVisitorUtils.parameterize(formattedSql, "mysql");
        } catch (Exception e) {
            if (LOG.isWarnEnabled()) {
                String msg = "doAsyncSqlSampling|buterr|" + (formattedSql);
                LOG.warn(msg, e);
            }
            return;
        }
//以mergedSql为基准每调采样10次。
}

[wenshao]

你这个是什么版本？

[wenshao]

问题已修复，请用新版本 https://github.com/alibaba/druid/releases/tag/1.1.14

[wenshao]

问题已修复，请用新版本 https://github.com/alibaba/druid/releases/tag/1.1.14

[lizongbo]

👍