Apache Tajo - JDBC接口

Apache Tajo JDBC接口 - 从简单和简单的步骤学习Apache Tajo，从基本到高级概念，包括简介，体系结构，安装，配置设置，Shell命令，数据类型，操作符，SQL函数，数学函数，字符串函数，日期时间函数，JSON函数，数据库创建，表管理，SQL语句，聚合和窗口函数，SQL查询，存储插件，与HBase集成，与Hive集成，OpenStack Swift集成，JDBC接口，自定义函数。

Apache Tajo提供JDBC接口来连接和执行查询.我们可以使用相同的JDBC接口从我们基于Java的应用程序连接Tajo.现在让我们了解如何在本节中使用JDBC接口连接Tajo并在我们的示例Java应用程序中执行命令.

下载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

连接到Tajo

Apache Tajo提供JDBC驱动程序作为单个jar文件，它可用 @/path/to/tajo/share/jdbc-dist/tajo -jdbc-0.11.3.jar .

连接Apache Tajo的连接字符串格式如下 :

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

这里，

主持人 : TajoMaster的主机名.
port : 服务器正在侦听的端口号.默认端口号为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

结果

以上命令将生成以下结果 :

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