📅 最后修改于: 2020-12-02 06:10:11 🧑 作者: Mango
Apache Tajo提供JDBC接口来连接和执行查询。我们可以使用相同的JDBC接口从基于Java的应用程序连接Tajo。现在让我们了解如何在本节中使用JDBC接口连接Tajo并在示例Java应用程序中执行命令。
通过访问以下链接下载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的主机名。
port-服务器正在侦听的端口号。默认端口号是26002。
database-数据库名称。默认数据库名称为default。
现在让我们了解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