jdbc - 在 Java 代码中执行查询以连接到 Presto 时出错

Question

我们正在尝试使用 Java 代码连接到 Presto 并执行一些查询。我们使用的目录是 MySQL。

• Presto 安装在 Linux 服务器上。Presto CLI 在 Linux 上运行良好。在 Linux 中启动 Presto。
• MySQL 也安装在 Linux 机器上。我们可以使用 DbVisualizer 在 Windows 中访问 MySQL。
• 我为 Presto 创建了一个 MySQL 连接器目录。我成功地使用 Presto CLI 查询 MySQL 的数据presto --server localhost:8080 --catalog mysql --schema tutorials。

在 Windows 机器上执行 Java 代码，我可以访问 MySQL 并执行查询，但我们无法查询数据。当我们尝试从 Presto 运行查询时，它给我们错误执行查询。在下面的示例中，我使用了Trinosql的 jar

package testdbPresto;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

public class PrestoJdbc {

  public static void main(String args[]) throws SQLException, ClassNotFoundException {
      
      try{ 
      //connect mysql server tutorials database here 
      Class.forName("com.facebook.presto.jdbc.PrestoDriver");  
      String url = "jdbc:trino://35.173.241.37:8080/mysql/tutorials";
      Properties properties = new Properties();
      properties.setProperty("user", "root");
      properties.setProperty("password", "Redcar88!");
      properties.setProperty("SSL", "true");
      Connection connection = DriverManager.getConnection(url, properties);

      Statement statement = null;  
      statement = connection.createStatement();
      //select mysql table author table two columns  
      String sql;  
      sql = "select auth_id, auth_name from mysql.tutorials.author"; 
     
      ResultSet resultSet = statement.executeQuery(sql);  

      //Extract data from result set
      while (resultSet.next()) {
        //Retrieve by column name
        String name = resultSet.getString("auth_name");
        //Display values
        System.out.println("name : " + name);
      }
      //Clean-up environment
      resultSet.close();
      statement.close();
      connection.close();
      }catch(Exception e){ e.printStackTrace();}  
    
    }
  }

输出：

    java.sql.SQLException: Error executing query
        at io.trino.jdbc.TrinoStatement.internalExecute(TrinoStatement.java:274)
        at io.trino.jdbc.TrinoStatement.execute(TrinoStatement.java:227)
        at io.trino.jdbc.TrinoStatement.executeQuery(TrinoStatement.java:76)
        at testdbPresto.PrestoJdbc.main(PrestoJdbc.java:29)
    Caused by: java.io.UncheckedIOException: javax.net.ssl.SSLException: Unsupported or unrecognized SSL message
        at io.trino.jdbc.$internal.client.JsonResponse.execute(JsonResponse.java:154)
        at io.trino.jdbc.$internal.client.StatementClientV1.<init>(StatementClientV1.java:110)
        at io.trino.jdbc.$internal.client.StatementClientFactory.newStatementClient(StatementClientFactory.java:24)
        at io.trino.jdbc.QueryExecutor.startQuery(QueryExecutor.java:46)
        at io.trino.jdbc.TrinoConnection.startQuery(TrinoConnection.java:728)
        at io.trino.jdbc.TrinoStatement.internalExecute(TrinoStatement.java:239)
        ... 3 more
    Caused by: javax.net.ssl.SSLException: Unsupported or unrecognized SSL message
        at sun.security.ssl.SSLSocketInputRecord.handleUnknownRecord(SSLSocketInputRecord.java:448)
        at sun.security.ssl.SSLSocketInputRecord.decode(SSLSocketInputRecord.java:174)
        at sun.security.ssl.SSLTransport.decode(SSLTransport.java:110)
        at sun.security.ssl.SSLSocketImpl.decode(SSLSocketImpl.java:1279)
        at sun.security.ssl.SSLSocketImpl.readHandshakeRecord(SSLSocketImpl.java:1188)
        at sun.security.ssl.SSLSocketImpl.startHandshake(SSLSocketImpl.java:401)
        at sun.security.ssl.SSLSocketImpl.startHandshake(SSLSocketImpl.java:373)
        at io.trino.jdbc.$internal.okhttp3.internal.connection.RealConnection.connectTls(RealConnection.java:299)
        at io.trino.jdbc.$internal.okhttp3.internal.connection.RealConnection.establishProtocol(RealConnection.java:268)
        at io.trino.jdbc.$internal.okhttp3.internal.connection.RealConnection.connect(RealConnection.java:160)
        at io.trino.jdbc.$internal.okhttp3.internal.connection.StreamAllocation.findConnection(StreamAllocation.java:256)
        at io.trino.jdbc.$internal.okhttp3.internal.connection.StreamAllocation.findHealthyConnection(StreamAllocation.java:134)
        at io.trino.jdbc.$internal.okhttp3.internal.connection.StreamAllocation.newStream(StreamAllocation.java:113)
        at io.trino.jdbc.$internal.okhttp3.internal.connection.ConnectInterceptor.intercept(ConnectInterceptor.java:42)
        at io.trino.jdbc.$internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
        at io.trino.jdbc.$internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
        at io.trino.jdbc.$internal.okhttp3.internal.cache.CacheInterceptor.intercept(CacheInterceptor.java:93)
        at io.trino.jdbc.$internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
        at io.trino.jdbc.$internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
        at io.trino.jdbc.$internal.okhttp3.internal.http.BridgeInterceptor.intercept(BridgeInterceptor.java:93)
        at io.trino.jdbc.$internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
        at io.trino.jdbc.$internal.okhttp3.internal.http.RetryAndFollowUpInterceptor.intercept(RetryAndFollowUpInterceptor.java:125)
        at io.trino.jdbc.$internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
        at io.trino.jdbc.$internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
        at io.trino.jdbc.$internal.client.OkHttpUtil.lambda$basicAuth$1(OkHttpUtil.java:85)
        at io.trino.jdbc.$internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
        at io.trino.jdbc.$internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
        at io.trino.jdbc.$internal.client.OkHttpUtil.lambda$userAgent$0(OkHttpUtil.java:71)
        at io.trino.jdbc.$internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
        at io.trino.jdbc.$internal.okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
        at io.trino.jdbc.$internal.okhttp3.RealCall.getResponseWithInterceptorChain(RealCall.java:200)
        at io.trino.jdbc.$internal.okhttp3.RealCall.execute(RealCall.java:77)
        at io.trino.jdbc.$internal.client.JsonResponse.execute(JsonResponse.java:131)
        ... 8 more

标签： jdbcprestotrino