Apache Presto 简明教程
Apache Presto - JDBC Interface
Presto 的 JDBC 接口用于访问 Java 应用程序。
Presto’s JDBC interface is used to access Java application.
Prerequisites
安装 presto-jdbc-0.150.jar
Install presto-jdbc-0.150.jar
你可以通过访问以下链接下载 JDBC jar 文件,
You can download the JDBC jar file by visiting the following link,
下载 jar 文件后,将其添加到 Java 应用程序的类路径中。
After the jar file has been downloaded, add it to the class path of your Java application.
Create a Simple Application
让我们使用 JDBC 接口创建一个简单的 java 应用程序。
Let’s create a simple java application using JDBC interface.
编码 - PrestoJdbcSample.java
Coding − PrestoJdbcSample.java
import java.sql.*;
import com.facebook.presto.jdbc.PrestoDriver;
//import presto jdbc driver packages here.
public class PrestoJdbcSample {
public static void main(String[] args) {
Connection connection = null;
Statement statement = null;
try {
Class.forName("com.facebook.presto.jdbc.PrestoDriver");
connection = DriverManager.getConnection(
"jdbc:presto://localhost:8080/mysql/tutorials", "tutorials", “");
//connect mysql server tutorials database here
statement = connection.createStatement();
String sql;
sql = "select auth_id, auth_name from mysql.tutorials.author”;
//select mysql table author table two columns
ResultSet resultSet = statement.executeQuery(sql);
while(resultSet.next()){
int id = resultSet.getInt("auth_id");
String name = resultSet.getString(“auth_name");
System.out.print("ID: " + id + ";\nName: " + name + "\n");
}
resultSet.close();
statement.close();
connection.close();
}catch(SQLException sqlException){
sqlException.printStackTrace();
}catch(Exception exception){
exception.printStackTrace();
}
}
}
保存文件并退出应用程序。现在,在一个终端中启动 Presto 服务器,并打开一个新终端来编译和执行结果。以下是步骤:
Save the file and quit the application. Now, start Presto server in one terminal and open a new terminal to compile and execute the result. Following are the steps −