Apache Tajo proporciona una interfaz JDBC para conectarse y realizar solicitudes. Podemos usar la misma interfaz JDBC para conectar Tajo desde nuestra aplicación Java. Ahora entendamos cómo conectar Tajo y ejecutar los comandos en nuestra aplicación Java de muestra usando la interfaz JDBC en esta sección.
Descargue el controlador JDBC siguiendo el siguiente enlace: http://apache.org/dyn/closer.cgi/tajo/tajo-0.11.3/tajo-jdbc-0.11.3.jar…
El archivo «tajo-jdbc-0.11.3.jar» ya se ha descargado en su computadora.
Para usar el controlador JDBC en su programa, configure la ruta de clase de la siguiente manera:
CLASSPATH = path/to/tajo-jdbc-0.11.3.jar:$CLASSPATH
Apache Tajo proporciona el controlador JDBC como un solo archivo jar y está disponible @ /path/to/tajo/share/jdbc-dist/tajo-jdbc-0.11.3.jar…
La cadena de conexión para la conexión Apache Tajo tiene el siguiente formato:
jdbc:tajo://host/ jdbc:tajo://host/database jdbc:tajo://host:port/ jdbc:tajo://host:port/database
Aquí,
Maestro – Nombre de host de TajoMaster.
Puerto – El número de puerto en el que escucha el servidor. El número de puerto predeterminado es 26002.
base de datos – Nombre de la base de datos. El nombre de la base de datos predeterminado es predeterminado.
Echemos un vistazo a una aplicación Java ahora.
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(); } } }
La aplicación se puede compilar y ejecutar con los siguientes comandos.
javac -cp /path/to/tajo-jdbc-0.11.3.jar:. TajoJdbcSample.java
java -cp /path/to/tajo-jdbc-0.11.3.jar:. TajoJdbcSample
Los comandos anteriores generarán la siguiente salida:
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
🚫