1

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

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

我(X-Presto-Client-Tags)在连接/语句中发送 ClientTag 时遇到问题。

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

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驱动程序也可以这样做吗？

4

1 回答 1

3

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

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

Connection connection = DriverManager.getConnection("....");
connection.unwrap(PrestoConnection.class)
  .setClientInfo("ClientTags", "one,two,three");
于 2020-02-13T13:08:42.993 回答