上一节我们通过java代码访问了metastore,实际中使用更多的是直接使用jdbc访问hiveserver。
1、前提约束
- 已经完成通过beeline命令访问HiveServer
https://www.jianshu.com/p/e8366a465668
假设HiveServer服务所在机子ip为192.168.100.142,已启动HiveServer服务,且已关闭防火墙
2、操作步骤
- 创建一个maven项目,加入以下依赖:
<dependency>
<groupId>org.apache.hive</groupId>
<artifactId>hive-jdbc</artifactId>
<version>0.14.0</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.47</version>
</dependency>
注意,hive-jdbc的依赖版本取决于服务器上的hive版本,例如作者的hive是0.14.0,所以就去下载0.14.0的hive-jdbc。
- 在src/main/java文件夹下创建TestHiveServer.java
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
public class TestHiveServer {
public static void main(String[] args) throws Exception {
Class.forName("org.apache.hive.jdbc.HiveDriver");
Connection connection = connection = DriverManager.getConnection("jdbc:hive2://192.168.100.142:10000/default", "root", "zhangli");
String sql = "show tables";
Statement statement = connection.createStatement();
ResultSet rs = statement.executeQuery(sql);
while (rs.next()) {
System.out.println(rs.getString(1));
}
}
}
以上就是java访问hiveserver的简单demo。
网友评论