KnowForge/Apache Kyuubi 1.9.1
JDBC Drivers

Trino JDBC Driver

师成师成· 更新于 2026-09-29· 阅读 4 分钟· 0 次阅读
登录后可跨设备保存划线和私人笔记登录

Instructions

Kyuubi currently supports the Trino connection protocol, so we can use Trino-JDBC to connect to the kyuubi server and submit SQL to Spark, Trino and other engines for execution.

Start Kyuubi Trino Server

First we should configure the trino protocol and the service port in the kyuubi.conf

kyuubi.frontend.protocols TRINO
kyuubi.frontend.trino.bind.port 10999 #default port

Install Trino JDBC

Download trino-jdbc-411.jar and add it to the classpath of your Java application.

The driver is also available from Maven Central:

<dependency>
    <groupId>io.trino</groupId>
    <artifactId>trino-jdbc</artifactId>
    <version>411</version>
</dependency>

JDBC URL

When your driver is loaded, registered and configured, you are ready to connect to Trino from your application. The following JDBC URL formats are supported:

jdbc:trino://host:port

Trino JDBC example

String trinoHost = "localhost";
String trinoPort = "10999";
String trinoUser = "default";
String trinoPassword = null;
Connection connection = null;
ResultSet rs = null;

try {
    // Create the connection using the JDBC URL
    connection = DriverManager.getConnection("jdbc:trino://" + trinoHost + ":" + trinoPort, trinoUser, trinoPassword);

    // Do whatever you need to do with the connection
    Statement stmt = connection.createStatement();
    rs = stmt.executeQuery("SELECT 1");

    while (rs.next()) {
    // retrieve data from the ResultSet
    }

} catch (Exception e) {
    e.printStackTrace();
} finally {
    try {
        // Close the connection when you're done with it
        if (rs != null) rs.close();
        if (connection != null) connection.close();
    } catch (Exception e) {
        e.printStackTrace();
    }
}

The configuration of the connection parameters can be found in the official trino documentation at: https://trino.io/docs/current/client/jdbc.html#connection-parameters

评论

登录后参与评论

正在加载评论…