Apache Tajo - อินเทอร์เฟซ JDBC

Apache Tajo มีอินเทอร์เฟซ JDBC เพื่อเชื่อมต่อและดำเนินการสืบค้น เราสามารถใช้อินเทอร์เฟซ JDBC เดียวกันเพื่อเชื่อมต่อ Tajo จากแอปพลิเคชันที่ใช้ Java ของเรา ตอนนี้ให้เราเข้าใจวิธีเชื่อมต่อ Tajo และดำเนินการคำสั่งในแอปพลิเคชัน Java ตัวอย่างของเราโดยใช้อินเทอร์เฟซ JDBC ในส่วนนี้

ดาวน์โหลด JDBC Driver

ดาวน์โหลดไดรเวอร์ JDBC โดยไปที่ลิงค์ต่อไปนี้ - http://apache.org/dyn/closer.cgi/tajo/tajo-0.11.3/tajo-jdbc-0.11.3.jar.

ตอนนี้ไฟล์“ tajo-jdbc-0.11.3.jar” ถูกดาวน์โหลดบนเครื่องของคุณแล้ว

ตั้งค่าเส้นทางคลาส

ในการใช้ไดรเวอร์ JDBC ในโปรแกรมของคุณให้ตั้งค่าพา ธ คลาสดังนี้ -

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

เชื่อมต่อกับ Tajo

Apache Tajo จัดเตรียมไดรเวอร์ JDBC เป็นไฟล์ jar เดียวและพร้อมใช้งาน @ /path/to/tajo/share/jdbc-dist/tajo-jdbc-0.11.3.jar.

สตริงการเชื่อมต่อเพื่อเชื่อมต่อ Apache Tajo มีรูปแบบต่อไปนี้ -

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

ที่นี่

• host - ชื่อโฮสต์ของ TajoMaster

• port- หมายเลขพอร์ตที่เซิร์ฟเวอร์กำลังรับฟัง หมายเลขพอร์ตเริ่มต้นคือ 26002

• database- ชื่อฐานข้อมูล ชื่อฐานข้อมูลดีฟอลต์เป็นค่าเริ่มต้น

แอปพลิเคชัน Java

ตอนนี้ให้เราเข้าใจแอปพลิเคชัน Java

การเข้ารหัส

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(); 
      } 
   } 
}

แอปพลิเคชันสามารถคอมไพล์และรันโดยใช้คำสั่งต่อไปนี้

การรวบรวม

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

การดำเนินการ

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

ผลลัพธ์

คำสั่งข้างต้นจะสร้างผลลัพธ์ต่อไปนี้ -

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