将客户端标签添加到 presto jdbc 连接

Question

我正在使用 jdbc 连接到 presto 服务器。

根据文档，我能够连接到服务器和运行查询。 https://prestodb.io/docs/current/installation/jdbc.html

我在 connection/statement 中发送 ClientTags (X-Presto-Client-Tags) 时遇到问题。

这是建立连接和运行查询的函数。

public void test() {
    java.util.Properties info = new java.util.Properties();

    if (PRESTO_USER != null) {
        info.put("user", PRESTO_USER);
    }
    if (PRESTO_PASSWORD != null) {
        info.put("password", PRESTO_PASSWORD);
    }
        info.put("ClientTags", "my,tag");



    try (Connection connection = DriverManager.getConnection(PRESTO_URL, info);
         Statement statement = connection.createStatement()) {
        testBody(connection, statement);
    } catch (Exception ex) {
        ex.printStackTrace();
        fail("Exception occured");
    }
}

然而，它失败了

java.sql.SQLException: Unrecognized connection property 'ClientTags'
    at com.facebook.presto.jdbc.PrestoDriverUri.validateConnectionProperties(PrestoDriverUri.java:316)

对于 pyhive，我能够覆盖会话并传递客户端标签 https://github.com/dropbox/PyHive/issues/283。 jdbc 驱动程序也可以这样做吗？

Answer 1

目前无法在连接上设置 ClientTags URL。请创建一个功能请求@ https://github.com/trinodb/trino/issues/

目前唯一的方法是使用Connection方法：

Connection connection = DriverManager.getConnection("....");
connection.unwrap(PrestoConnection.class)
  .setClientInfo("ClientTags", "one,two,three");

将客户端标签添加到 presto jdbc 连接

Adding client tags to presto jdbc connection

presto

presto-jdbc