如何在Java中执行Hive命令或HiveQL

Java在1.5过后提供了ProcessBuilder根据运行时环境启动一个Process调用执行运行时环境下的命令或应用程序（1.5以前使用Runtime），关于ProcessBuilder请参考Java相关文档。调用代码如下：
String sql="show tables; select * from test_tb limit 10";
List command = new ArrayList();
command.add("hive");
command.add("-e");
command.add(sql);
List results = new ArrayList();
ProcessBuilder hiveProcessBuilder = new ProcessBuilder(command);
hiveProcess = hiveProcessBuilder.start();
BufferedReader br = new BufferedReader(new InputStreamReader(
hiveProcess.getInputStream()));
String data = null;
while ((data = br.readLine()) != null) {
results.add(data);
}
其中command可以是其它Hive命令，不一定是HiveQL。

java client 中hql执行跟数据库jdbc操作基本相同
1. maven工程依赖hive－jdbc相关jar包，其他工程类型参见maven repsository 相关依赖提示.



org.apache.hive

hive-jdbc

2.1.0


2. 书写相关代码，如果有链接池配置相关参数就好，注意链接池和hive-jdbc版本问题，过高的链接池版本配置hive-jdbc较低时，在连接校验时会出现unsupport异常.
// 加载驱动

Class.forName("org.apache.hive.jdbc.HiveDriver ");

// connection 为java.sql.Connection

Connection connection = DriverManager.getConnection("jdbc:hive2://locahost:10000/test");

// TODO:后续操作跟数据库jdbc操作一样,不要忘记关闭数据库连接.