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