E-MapReduce:TrinoへのJDBC接続

EMRクラスターのバージョンに基づいて、PrestoまたはTrino JDBCドライバーの必要な依存関係をpom.xmlファイルに追加できます。

<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>

JDBCドライバーはさまざまなパラメーターをサポートしています。次のいずれかの方法を使用して、パラメーターをDriverManagerに渡すことができます。

• プロパティとしてパラメーターをDriverManagerに渡します。

  • V3.38.0以降のマイナーバージョン、またはV5.5.0以降のマイナーバージョンのEMRクラスター

    String url = "jdbc:trino://<Name of the master node>:9090/hive/default";
    Properties properties = new Properties();
    properties.setProperty("user", "hadoop");
    Connection connection = DriverManager.getConnection(url, properties);
    // ...... データベースに対する操作を実行します。

  • 別のバージョンのEMRクラスター

    String url = "jdbc:presto://<Name of the master node>:9090/hive/default";
    Properties properties = new Properties();
    properties.setProperty("user", "hadoop");
    Connection connection = DriverManager.getConnection(url, properties);
    // ...... データベースに対する操作を実行します。

• URLパラメーターとしてパラメーターを渡します。

  • V3.38.0以降のマイナーバージョン、またはV5.5.0以降のマイナーバージョンのEMRクラスター

    String url = "jdbc:trino://<Name of the master node>:9090/hive/default?user=hadoop";
    Connection connection = DriverManager.getConnection(url);
    // ...... データベースに対する操作を実行します。

  • 別のバージョンのEMRクラスター

    String url = "jdbc:presto://<Name of the master node>:9090/hive/default?user=hadoop";
    Connection connection = DriverManager.getConnection(url);
    // ...... データベースに対する操作を実行します。

次の表は、一般的なパラメーターについて説明しています。

次のコードは、JDBCドライバーを使用してデータベースに接続する方法を示しています。

.....
Connection connection = null;
Statement statement = null;
try {
    // コンポーネントのJDBC URL。
    String url = "jdbc:<trino/presto>://<Name of the master node>:9090/hive/default";
    Properties properties = new Properties();
    properties.setProperty("user", "hadoop");
    // 接続オブジェクトを作成します。
    connection = DriverManager.getConnection(url, properties);
    // ステートメントオブジェクトを作成します。
    statement = connection.createStatement();
    // クエリステートメントを実行します。
    ResultSet rs = statement.executeQuery("select * from t1");
    // 結果を返します。
    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("例外がスローされました。", e);
} finally {
  // ステートメントオブジェクトを破棄します。
  if (statement != null) {
      try {
        statement.close();
    } catch(Throwable t) {
        // No-ops
    }
  }
  // 接続を閉じます。
  if (connection != null) {
      try {
        connection.close();
    } catch(Throwable t) {
        // No-ops
    }
  }
}