Apache Tajo - Interfaccia JDBC

Apache Tajo fornisce l'interfaccia JDBC per connettersi ed eseguire query. Possiamo usare la stessa interfaccia JDBC per connettere Tajo dalla nostra applicazione basata su Java. Vediamo ora come connettere Tajo ed eseguire i comandi nella nostra applicazione Java di esempio utilizzando l'interfaccia JDBC in questa sezione.

Scarica il driver JDBC

Scarica il driver JDBC visitando il seguente collegamento - http://apache.org/dyn/closer.cgi/tajo/tajo-0.11.3/tajo-jdbc-0.11.3.jar.

Ora, il file "tajo-jdbc-0.11.3.jar" è stato scaricato sul tuo computer.

Imposta percorso classe

Per utilizzare il driver JDBC nel programma, impostare il percorso di classe come segue:

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

Connettiti a Tajo

Apache Tajo fornisce un driver JDBC come un singolo file jar ed è disponibile @ /path/to/tajo/share/jdbc-dist/tajo-jdbc-0.11.3.jar.

La stringa di connessione per connettere l'Apache Tajo è del seguente formato:

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

Qui,

  • host - Il nome host del TajoMaster.

  • port- Il numero di porta che il server sta ascoltando. Il numero di porta predefinito è 26002.

  • database- Il nome del database. Il nome del database predefinito è predefinito.

Applicazione Java

Vediamo ora di capire l'applicazione Java.

Codifica

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

L'applicazione può essere compilata ed eseguita utilizzando i seguenti comandi.

Compilazione

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

Esecuzione

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

Risultato

I comandi precedenti genereranno il seguente risultato:

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