Apache Tajo - Giao diện JDBC

Apache Tajo cung cấp giao diện JDBC để kết nối và thực thi các truy vấn. Chúng ta có thể sử dụng cùng một giao diện JDBC để kết nối Tajo từ ứng dụng dựa trên Java của chúng ta. Bây giờ chúng ta hãy hiểu cách kết nối Tajo và thực thi các lệnh trong ứng dụng Java mẫu của chúng ta bằng giao diện JDBC trong phần này.

Tải xuống trình điều khiển JDBC

Tải xuống trình điều khiển JDBC bằng cách truy cập liên kết sau: http://apache.org/dyn/closer.cgi/tajo/tajo-0.11.3/tajo-jdbc-0.11.3.jar.

Bây giờ, tệp “tajo-jdbc-0.11.3.jar” đã được tải xuống máy của bạn.

Đặt đường dẫn lớp

Để sử dụng trình điều khiển JDBC trong chương trình của bạn, hãy đặt đường dẫn lớp như sau:

CLASSPATH = path/to/tajo-jdbc-0.11.3.jar:$CLASSPATH

Kết nối với Tajo

Apache Tajo cung cấp trình điều khiển JDBC dưới dạng một tệp jar duy nhất và nó có sẵn @ /path/to/tajo/share/jdbc-dist/tajo-jdbc-0.11.3.jar.

Chuỗi kết nối để kết nối Apache Tajo có định dạng sau:

jdbc:tajo://host/
jdbc:tajo://host/database
jdbc:tajo://host:port/  
jdbc:tajo://host:port/database

Đây,

host - Tên máy chủ của TajoMaster.
port- Số cổng mà máy chủ đang nghe. Số cổng mặc định là 26002.
database- Tên cơ sở dữ liệu. Tên cơ sở dữ liệu mặc định là mặc định.

Ứng dụng Java

Bây giờ chúng ta hãy hiểu về ứng dụng Java.

Mã hóa

import java.sql.*; 
import org.apache.tajo.jdbc.TajoDriver;  

public class TajoJdbcSample {  
   public static void main(String[] args) {  
      Connection connection = null; 
      Statement statement = null;  
      try {
         Class.forName("org.apache.tajo.jdbc.TajoDriver");  
         connection = DriverManager.getConnection(“jdbc:tajo://localhost/default");
         statement = connection.createStatement(); 
         String sql;  
         sql = "select * from mytable”; 
         // fetch records from mytable.  
         ResultSet resultSet = statement.executeQuery(sql);  
         while(resultSet.next()){  
            int id  = resultSet.getInt("id"); 
            String name = resultSet.getString("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(); 
      } 
   } 
}

Ứng dụng có thể được biên dịch và chạy bằng các lệnh sau.

Tổng hợp

javac -cp /path/to/tajo-jdbc-0.11.3.jar:. TajoJdbcSample.java

Chấp hành

java -cp /path/to/tajo-jdbc-0.11.3.jar:. TajoJdbcSample

Kết quả

Các lệnh trên sẽ tạo ra kết quả sau:

ID: 1; 
Name: Adam  

ID: 2; 
Name: Amit  

ID: 3; 
Name: Bob  

ID: 4; 
Name: David  

ID: 5; 
Name: Esha  

ID: 6; 
Name: Ganga 

ID: 7; 
Name: Jack  

ID: 8; 
Name: Leena  

ID: 9; 
Name: Mary  

ID: 10; 
Name: Peter