给我写一段hive jdbc连接代码
时间: 2023-11-09 16:59:50 浏览: 147
好的,以下是Hive JDBC连接代码示例:
```
import java.sql.*;
public class HiveJdbcExample {
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.execute("create table if not exists " + tableName + " (id int, name string)");
// populate sample data
ResultSet res = stmt.executeQuery("select * from " + tableName);
while (res.next()) {
System.out.println(String.valueOf(res.getInt(1)) + "\t" + res.getString(2));
}
stmt.close();
con.close();
}
}
```
以上代码建立了对Hive的JDBC连接,并在其中创建了一个名为“example_table”的表。然后查询该表并输出结果。注意,您需要根据自己的环境更改JDBC连接字符串中的主机名和端口号等参数。
阅读全文