Apache Tajo - Antarmuka JDBC

Apache Tajo menyediakan antarmuka JDBC untuk menghubungkan dan menjalankan kueri. Kita dapat menggunakan antarmuka JDBC yang sama untuk menghubungkan Tajo dari aplikasi berbasis Java kita. Sekarang mari kita memahami cara menghubungkan Tajo dan menjalankan perintah di aplikasi Java contoh kita menggunakan antarmuka JDBC di bagian ini.

Unduh JDBC Driver

Unduh driver JDBC dengan mengunjungi tautan berikut - http://apache.org/dyn/closer.cgi/tajo/tajo-0.11.3/tajo-jdbc-0.11.3.jar.

Sekarang, file "tajo-jdbc-0.11.3.jar" telah didownload di komputer Anda.

Atur Jalur Kelas

Untuk menggunakan driver JDBC dalam program Anda, setel jalur kelas sebagai berikut -

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

Hubungkan ke Tajo

Apache Tajo menyediakan driver JDBC sebagai file jar tunggal dan tersedia @ /path/to/tajo/share/jdbc-dist/tajo-jdbc-0.11.3.jar.

String koneksi untuk menghubungkan Apache Tajo dalam format berikut -

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

Sini,

host - Nama host dari TajoMaster.
port- Nomor port yang didengarkan server. Nomor port default adalah 26002.
database- Nama database. Nama database default adalah default.

Aplikasi Java

Mari kita sekarang memahami aplikasi Java.

Pengodean

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

Aplikasi dapat dikompilasi dan dijalankan dengan menggunakan perintah berikut.

Kompilasi

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

Eksekusi

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

Hasil

Perintah di atas akan menghasilkan hasil sebagai berikut -

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