• 依赖：JDK1.8
• JDBC Driver 下载：点击下载驱动

1. 加载 EMR Serverless Presto JDBC 驱动 。

Class.forName("com.facebook.presto.jdbc.PrestoDriver");

2. 创建 EMR Serverless Presto Connection。

// las_queue_name 默认值为 public-queue-presto 即 Presto 公共队列
String url = "jdbc:presto://${endpoint}:8080/${Catalog}/${Schema}?region=cn-beijing&sessionProperties=presto_queue_name:${your-queue-name};compute_group_name:${your-compute-group-name}" 

Properties properties = new Properties();
properties.setProperty("user", ${User});
properties.setProperty("password", ${Password});
Connection connection = DriverManager.getConnection(url, properties);

3. JDBC 连接串参数说明。

4. 查询数据完整代码示例。

import com.facebook.presto.jdbc.PrestoStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.util.Properties;
 
public void demo() {
    try {
        Class.forName("com.facebook.presto.jdbc.PrestoDriver");
    } catch (ClassNotFoundException e) {
        System.out.println("Failed to load Presto JDCB driver...");
        return;
    }

    final String ak = "火山引擎 API 密钥管理中的 Access Key ID";
    final String sk = "火山引擎 API 密钥管理中的 Secret Access Key";
    final String jdbcUrl = "jdbc:presto://${endpoint}:8080/hive/serverless_presto_schema?region=cn-beijing";
    Properties properties = new Properties();
    properties.setProperty("user", ak);
    properties.setProperty("password", sk);
    try (PrestoConnection connection = (PrestoConnection) DriverManager.getConnection(url, properties)) {
        ResultSet resultSet = connection.createStatement().executeQuery("select name from serverless_presto_table");
        while (resultSet.next()) {
            System.out.println(resultSet.getString(1));
        }
    }
    catch (Exception e) {
        e.printStackTrace();
    }
}

5. 编译执行代码。