Vertx JDBC客户端queryWithParams-如何添加列表？

Question

我有SQL查询条件<代码>货币在？我使用vertx JDBC客户端queryRetparams方法，它在JsonArray中接收查询参数。

如何将我可能的货币值列表传递给查询？我尝试了new JsonArray（）. add（new JsonArray（货币）但是得到了异常

组织。postgresql。util。PSQLException:无法推断用于io实例的SQL类型。维特斯。果心json。杰索纳雷。使用带有显式类型值的setObject（）指定要使用的类型。

Answer 1

有两种选择。

如果您想支持多个数据库，您必须自己扩展表达式：

"... currency IN (" + String.join(",", Collections.nCopies(currencies.size(), "?")) + ")"

如果只支持PostreSQL，则可以使用任何运算符：

WHERE currency = ANY(?)

Answer 2

简单的回答是，您不能使用通用VertxJDBC客户端添加List作为查询参数，但是由于您正在使用Postgres，因此您可以使用一个名为vertx-pg-Client的Postgres特定库。我用这段代码实现了大致相同的查询：

List<String> currencies = whatever();
String uri = "your-uri";
String query = "select from table where currency = any($1)";
PgConnection.connect(vertx, uri, connectionResult -> {
    if (connectionResult.failed()) {
        // handle
    } else {
        PgConnection connection = connectionResult.result();
        Tuple params = Tuple.of(currencies);

        doQuery(query, connection, params).setHandler(queryResult -> {
            connection.close();
            msg.reply(queryResult.result());
        });
    }
});

    private Future<String> doQuery(String sql, PgConnection connection, Tuple params) {
        Promise<String> promise = Promise.promise();
        connection.preparedQuery(sql, params, res -> {
            if (res.failed()) {
                // log
                promise.fail(res.cause());
            } else {
                RowSet<Row> rowSet = res.result();
                // do something with the rows and construct a return object (here, a string)
                String result = something;
                promise.complete(result);
            }
        });
        return promise.future();
    }

所有的功劳都归功于在这里帮助我解决同样问题的@tegismont。