E-MapReduce:Use JDBC to connect to Trino

Prerequisites

Before you begin, ensure that you have:

• An EMR cluster with the Trino service installed

• Network access to the EMR cluster from the machine running your Java application (same VPC)

• Maven (if using Maven to manage dependencies)

Add the JDBC driver dependency

Add the correct JDBC driver dependency to pom.xml based on your EMR cluster version.

Example: EMR V3.38.0 and later, or V5.5.0 and later

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

Example: EMR V3.25.0–V3.37.X, V4.3.0–V4.9.0, or V5.2.1–V5.4.3

<dependency>
    <groupId>io.prestosql</groupId>
    <artifactId>presto-jdbc</artifactId>
    <version>3XX</version>
</dependency>

Example: Other EMR versions

<dependency>
    <groupId>com.facebook.presto</groupId>
    <artifactId>presto-jdbc</artifactId>
    <version>0.2XX</version>
</dependency>

Pass connection parameters

Pass parameters to DriverManager using either a Properties object or URL query parameters.

// Method 1: Properties object
String url = "jdbc:trino://master-1-1:9090/hive/default";
Properties properties = new Properties();
properties.setProperty("user", "hadoop");
properties.setProperty("SSL", "true");
Connection connection = DriverManager.getConnection(url, properties);

// Method 2: URL parameters
String url = "jdbc:trino://master-1-1:9090/hive/default?user=hadoop&SSL=true";
Connection connection = DriverManager.getConnection(url);

For EMR versions that use the jdbc:presto scheme, replace jdbc:trino with jdbc:presto in the examples above.

Example

The following code connects to Trino, runs a query, and prints the results:

Connection connection = null;
Statement statement = null;
try {
    // JDBC URL — use jdbc:trino for EMR V3.38.0+/V5.5.0+, or jdbc:presto for other versions
    String url = "jdbc:trino://master-1-1:9090/hive/default";
    Properties properties = new Properties();
    properties.setProperty("user", "hadoop");

    // Create a connection
    connection = DriverManager.getConnection(url, properties);

    // Create a statement and run a query
    statement = connection.createStatement();
    ResultSet rs = statement.executeQuery("select * from t1");

    // Print results
    int columnNum = rs.getMetaData().getColumnCount();
    int rowIndex = 0;
    while (rs.next()) {
        rowIndex++;
        for (int i = 1; i <= columnNum; i++) {
            System.out.println("Row " + rowIndex + ", Column " + i + ": " + rs.getInt(i));
        }
    }
} catch (SQLException e) {
    LOG.ERROR("Exception thrown.", e);
} finally {
    // Release resources
    if (statement != null) {
        try {
            statement.close();
        } catch (Throwable t) {
            // No-ops
        }
    }
    if (connection != null) {
        try {
            connection.close();
        } catch (Throwable t) {
            // No-ops
        }
    }
}

FAQ

When connecting via JDBC, I get the error `Authentication failed: Basic authentication or X-Trino-User must be sent`. What should I do?

This error occurs when the JDBC driver version does not match the Trino version running on your cluster. Use the driver that corresponds to your EMR cluster version — refer to the dependency table to select the correct groupId, artifactId, and version.

What's next

For simple, ad hoc queries, connect to Trino using the CLI instead. See Use the CLI to connect to Trino.