Apache Presto - อินเทอร์เฟซ JDBC
อินเตอร์เฟส JDBC ของ Presto ใช้เพื่อเข้าถึงแอปพลิเคชัน Java
ข้อกำหนดเบื้องต้น
ติดตั้ง presto-jdbc-0.150.jar
คุณสามารถดาวน์โหลดไฟล์ JDBC jar ได้โดยไปที่ลิงค์ต่อไปนี้
https://repo1.maven.org/maven2/com/facebook/presto/presto-jdbc/0.150/
หลังจากดาวน์โหลดไฟล์ jar แล้วให้เพิ่มลงในคลาสพา ธ ของแอ็พพลิเคชัน Java ของคุณ
สร้างแอปพลิเคชันง่ายๆ
มาสร้างแอปพลิเคชัน java อย่างง่ายโดยใช้อินเตอร์เฟส JDBC
การเข้ารหัส - 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 ในเทอร์มินัลเดียวและเปิดเทอร์มินัลใหม่เพื่อรวบรวมและดำเนินการผลลัพธ์ ต่อไปนี้เป็นขั้นตอน -
การรวบรวม
~/Workspace/presto/presto-jdbc $ javac -cp presto-jdbc-0.149.jar PrestoJdbcSample.java
การดำเนินการ
~/Workspace/presto/presto-jdbc $ java -cp .:presto-jdbc-0.149.jar PrestoJdbcSample
เอาต์พุต
INFO: Logging initialized @146ms
ID: 1;
Name: Doug Cutting
ID: 2;
Name: James Gosling
ID: 3;
Name: Dennis Ritchie