Hive基于Java的API代码编程

Posted 2021-04-29 互联网IT信息

1. 创建连接Connection和Statement

核心类：

Connection ：hive的连接

Statement ：用于调用hive的执行excute的类

核心代码是：

2. 创建hive数据库实例

核心方法：

Statement的execute(“create database hivedb”);

核心代码是：

3. 删除hive数据库实例

核心方法：

Statement的execute(“drop database hivedb”);

核心代码是：

4. 创建hive数据库表实例

核心方法：

Statement的execute

核心代码是：

5. 删除hive数据库表实例

核心方法：

Statement的execute

核心代码是：

6. 显示特定的表是否存在

核心方法：

Statement的executeQuery

核心代码是：

7. 显示表的字段属性

核心方法：

Statement的executeQuery

核心代码是：

8. 通过本地文件，向hive中加载数据

核心方法：

Statement的execute

核心代码是：

9. 查询表中的数据

核心方法：

Statement的executeQuery

核心代码是：

10. hive的聚合函数查询表有多少条记录

核心方法：

Statement的executeQuery

核心代码是：

11. 利用selectWhere,查询表有多少条记录

核心方法：

Statement的executeQuery

核心代码是：

// 利用selectWhere,查询表有多少条记录。

public static void selectWhere(String tableName) throws SQLException {

String sql = "select * FROM "+tableName+" WHERE name = 'mike2'";

ResultSet res = stmt.executeQuery(sql);

            while (res.next()) {

         System.out.println(res.getString(1) + " " + res.getString(2));

      }

}