问题描述
我正在尝试使用 PreparedStatement 占位符作为 sql 聚合函数的参数。如果我将 ?
占位符替换为数值并去掉 setDouble
调用,则查询工作正常。
public static String QUERY = """
SELECT DS_GET_QUANTILE(DS_QUANTILES_SKETCH("logins"),?) as "rank"
FROM (SELECT ip,sum("login-counts") AS "attempts"
FROM "my-datasource"
WHERE __time >= CURRENT_TIMESTAMP - INTERVAL '30' DAY
GROUP BY 1)
""";
void queryFails() throws sqlException {
var connection = jdbcTemplate.getJdbcTemplate().getDataSource().getConnection();
var preparedStatement = connection.prepareStatement(QUERY);
preparedStatement.setDouble(1,.75);
var resultSet = preparedStatement.executeQuery();
}
错误是:
org.apache.calcite.avatica.AvaticasqlException: Error -1 (00000) : while preparing sql: SELECT DS_GET_QUANTILE(DS_QUANTILES_SKETCH("attempts"),?) as "rank"
FROM (SELECT ip,sum("login-login_attempts") AS "attempts"
FROM "metrics-default"
WHERE __time >= CURRENT_TIMESTAMP - INTERVAL '30' DAY
GROUP BY 1)
at org.apache.calcite.avatica.Helper.createException(Helper.java:54)
at org.apache.calcite.avatica.Helper.createException(Helper.java:41)
at org.apache.calcite.avatica.AvaticaConnection.prepareStatement(AvaticaConnection.java:358)
at org.apache.calcite.avatica.AvaticaConnection.prepareStatement(AvaticaConnection.java:175)
at com.zaxxer.hikari.pool.ProxyConnection.prepareStatement(ProxyConnection.java:337)
at com.zaxxer.hikari.pool.HikariProxyConnection.prepareStatement(HikariProxyConnection.java)
...
java.lang.RuntimeException: org.apache.calcite.tools.ValidationException: org.apache.calcite.runtime.CalciteContextException: From line 1,column 8 to line 1,column 58: Cannot apply 'DS_GET_QUANTILE' to arguments of type 'DS_GET_QUANTILE(<OTHER>,<ANY>)'. Supported form(s): 'DS_GET_QUANTILE(<ANY>,<NUMERIC>)'
at org.apache.druid.sql.avatica.DruidStatement.closeAndPropagateThrowable(DruidStatement.java:377)
at org.apache.druid.sql.avatica.DruidStatement.prepare(DruidStatement.java:181)
at org.apache.druid.sql.avatica.DruidMeta.prepare(DruidMeta.java:158)
它似乎将 ?
传递给未替换的数据库。
这是 avatica 驱动程序中的错误还是查询的某些区域中不允许使用占位符?
解决方法
鉴于根本原因错误消息:
java.lang.RuntimeException:
org.apache.calcite.tools.ValidationException:
org.apache.calcite.runtime.CalciteContextException:从第 1 行开始,
第 8 列到第 1 行,第 58 列:无法将“DS_GET_QUANTILE”应用于
'DS_GET_QUANTILE(
这是参数类型推断的问题。尝试将参数显式转换为数字类型,例如cast(? as double)
。