用Java代码连接hive
时间: 2023-12-21 17:46:27 浏览: 32
要使用Java连接Hive,您需要首先安装Hive并启动HiveServer2。然后,您可以使用JDBC API连接到Hive。
以下是连接到Hive的Java代码示例:
```java
import java.sql.*;
public class HiveConnection {
private static String driverName = "org.apache.hive.jdbc.HiveDriver";
public static void main(String[] args) throws SQLException {
try {
Class.forName(driverName);
} catch (ClassNotFoundException e) {
e.printStackTrace();
System.exit(1);
}
Connection con = DriverManager.getConnection("jdbc:hive2://localhost:10000/default", "", "");
Statement stmt = con.createStatement();
String tableName = "example_table";
stmt.executeQuery("CREATE TABLE " + tableName + " (id int, name string)");
ResultSet res = stmt.executeQuery("SELECT * FROM " + tableName);
while (res.next()) {
System.out.println(res.getInt(1) + "\t" + res.getString(2));
}
con.close();
}
}
```
请确保在代码中使用正确的JDBC驱动程序和HiveServer2 URL。如果您使用其他版本的Hive,则可能需要使用不同的JDBC驱动程序和URL。
此代码示例使用JDBC API创建一个名为“example_table”的Hive表,并从该表中检索数据。您可以根据需要修改代码以执行其他查询和操作。
相关推荐
![zip](https://img-home.csdnimg.cn/images/20210720083736.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)