E-MapReduce：Gunakan JDBC untuk terhubung ke Trino

Tambahkan dependensi driver JDBC Presto atau Trino ke file pom.xml sesuai dengan versi kluster EMR Anda.

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

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

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

Driver JDBC mendukung berbagai parameter. Gunakan salah satu metode berikut untuk meneruskan parameter ke DriverManager:

• Teruskan parameter sebagai properti ke DriverManager.

  • Kluster EMR versi V3.38.0 atau lebih baru, atau versi V5.5.0 atau lebih baru:

    String url = "jdbc:trino://<Nama Node master>:9090/hive/default";
    Properties properties = new Properties();
    properties.setProperty("user", "hadoop");
    Connection connection = DriverManager.getConnection(url, properties);
    // ...... Lakukan operasi pada database Anda.

  • Kluster EMR versi lain:

    String url = "jdbc:presto://<Nama Node master>:9090/hive/default";
    Properties properties = new Properties();
    properties.setProperty("user", "hadoop");
    Connection connection = DriverManager.getConnection(url, properties);
    // ...... Lakukan operasi pada database Anda.

• Teruskan parameter sebagai bagian dari URL.

  • Kluster EMR versi V3.38.0 atau lebih baru, atau versi V5.5.0 atau lebih baru:

    String url = "jdbc:trino://<Nama Node master>:9090/hive/default?user=hadoop";
    Connection connection = DriverManager.getConnection(url);
    // ...... Lakukan operasi pada database Anda.

  • Kluster EMR versi lain:

    String url = "jdbc:presto://<Nama Node master>:9090/hive/default?user=hadoop";
    Connection connection = DriverManager.getConnection(url);
    // ...... Lakukan operasi pada database Anda.

Tabel berikut menjelaskan parameter umum:

Kode berikut menunjukkan cara menggunakan driver JDBC untuk terhubung ke database:

.....
Connection connection = null;
Statement statement = null;
try {
    // URL JDBC dari komponen.
    String url = "jdbc:<trino/presto>://<Nama Node master>:9090/hive/default";
    Properties properties = new Properties();
    properties.setProperty("user", "hadoop");
    // Buat objek koneksi.
    connection = DriverManager.getConnection(url, properties);
    // Buat objek pernyataan.
    statement = connection.createStatement();
    // Eksekusi pernyataan kueri.
    ResultSet rs = statement.executeQuery("select * from t1");
    // Kembalikan hasil.
    int columnNum = rs.getMetaData().getColumnCount();
    int rowIndex = 0;
    while (rs.next()) {
        rowIndex++;
        for(int i = 1; i <= columnNum; i++) {
            System.out.println("Baris " + rowIndex + ", Kolom " + i + ": " + rs.getInt(i));
        }
    }
} catch(SQLException e) {
    LOG.ERROR("Pengecualian dilemparkan.", e);
} finally {
  // Hancurkan objek pernyataan.
  if (statement != null) {
      try {
        statement.close();
    } catch(Throwable t) {
        // Tidak ada operasi
    }
  }
  // Tutup koneksi.
  if (connection != null) {
      try {
        connection.close();
    } catch(Throwable t) {
        // Tidak ada operasi
    }
  }
}