Учебники

Apache Tajo — интерфейс JDBC

Октябрь 8, 2018

Apache Tajo предоставляет интерфейс JDBC для подключения и выполнения запросов. Мы можем использовать тот же интерфейс JDBC для подключения Tajo из нашего Java-приложения. Давайте теперь поймем, как подключить Tajo и выполнить команды в нашем примере Java-приложения с использованием интерфейса JDBC в этом разделе.

Скачать драйвер JDBC

Загрузите драйвер 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

Подключиться к Тахо

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.

  • порт — номер порта, который слушает сервер. Номер порта по умолчанию — 26002.

  • база данных — имя базы данных. Имя базы данных по умолчанию — по умолчанию.

host — имя хоста TajoMaster.

порт — номер порта, который слушает сервер. Номер порта по умолчанию — 26002.

база данных — имя базы данных. Имя базы данных по умолчанию — по умолчанию.

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

Результат

Приведенные выше команды будут генерировать следующий результат —

35
Share: