Hive 创建表
本章解释了如何创建表以及如何向其中插入数据。在HIVE中创建表的约定与使用SQL创建表非常相似。
创建表语句
Create Table 是用于在 Hive 中创建表的语句。语法和示例如下：
语法
CREATE [TEMPORARY] [EXTERNAL] TABLE [if NOT EXISTS] [db_name.] table_name
[(col_name data_type [COMMENT col_comment], ...)]
[COMMENT table_comment]
[ROW FORMAT row_format]
[STORED AS file_format]
示例
假设您需要使用
CREATE TABLE 语句创建一个名为
employee 的表。下表列出了员工表中的字段及其数据类型：
| 字段名称 |
数据类型 |
| Eid |
int |
| Name |
String |
| Salary |
Float |
| Designation |
string |
以下数据为注释、行格式字段，例如字段终止符、行终止符和存储文件类型。
COMMENT ‘Employee details’
FIELDS TERMINATED BY ‘\t’
LINES TERMINATED BY ‘\n’
STORED IN TEXT FILE
以下查询使用上述数据创建一个名为
employee 的表。
hive> CREATE TABLE if NOT EXISTS employee ( eid int, name String,
salary String, destination String)
COMMENT ‘Employee details’
ROW FORMAT DELIMITED
FIELDS TERMINATED BY ‘\t’
LINES TERMINATED BY ‘\n’
STORED AS TEXTFILE;
如果添加选项 IF NOT EXISTS，Hive 会在表已存在的情况下忽略该语句。
成功创建表后，您会看到以下响应：
OK
Time taken: 5.905 seconds
hive>
JDBC 程序
以JDBC程序创建表为例。
import java.sql.SQLException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.sql.DriverManager;
public class HiveCreateTable {
private static String driverName = "org.apache.hadoop.hive.jdbc.HiveDriver";
public static void main(String[] args) throws SQLException {
// Register driver and create driver instance
Class.forName(driverName);
// get connection
Connection con = DriverManager.getConnection("jdbc:hive://localhost:10000/userdb", "", "");
// create statement
Statement stmt = con.createStatement();
// execute statement
stmt.executeQuery("CREATE TABLE if NOT EXISTS "
+" employee ( eid int, name String, "
+" salary String, destignation String)"
+" COMMENT ‘Employee details’"
+" ROW FORMAT DELIMITED"
+" FIELDS TERMINATED BY ‘\t’"
+" LINES TERMINATED BY ‘\n’"
+" STORED AS TEXTFILE;");
System.out.println(“ Table employee created.”);
con.close();
}
}
将程序保存在名为 HiveCreateDb.java 的文件中。以下命令用于编译和执行该程序。
$ javac HiveCreateDb.java
$ java HiveCreateDb
输出
加载数据语句
一般情况下，在SQL中创建表后，我们可以使用Insert语句插入数据。但是在 Hive 中，我们可以使用 LOAD DATA 语句插入数据。
在向 Hive 中插入数据时，最好使用 LOAD DATA 来存储批量记录。加载数据有两种方式：一种是本地文件系统加载，一种是Hadoop文件系统加载。
语法
加载数据的语法如下：
LOAD DATA [LOCAL] INPATH 'filepath' [OVERWRITE] INTO TABLE tablename
[PARTITION (partcol1=val1, partcol2=val2 ...)]
LOCAL 是指定本地路径的标识符。它是可选的。
OVERWRITE 是可选的，用于覆盖表中的数据。
PARTITION 是可选的。
示例
我们将下面的数据插入到表中。它是
/home/user 目录中名为
sample.txt 的文本文件。
1201 Gopal 45000 Technical manager
1202 Manisha 45000 Proof reader
1203 Masthanvali 40000 Technical writer
1204 Kiran 40000 Hr Admin
1205 Kranthi 30000 Op Admin
以下查询将给定的文本加载到表中。
hive> LOAD DATA LOCAL INPATH '/home/user/sample.txt'
OVERWRITE INTO TABLE employee;
成功下载后，您会看到以下响应：
OK
Time taken: 15.905 seconds
hive>
JDBC 程序
下面给出的是将给定数据加载到表中的 JDBC 程序。
import java.sql.SQLException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.sql.DriverManager;
public class HiveLoadData {
private static String driverName = "org.apache.hadoop.hive.jdbc.HiveDriver";
public static void main(String[] args) throws SQLException {
// Register driver and create driver instance
Class.forName(driverName);
// get connection
Connection con = DriverManager.getConnection("jdbc:hive://localhost:10000/userdb", "", "");
// create statement
Statement stmt = con.createStatement();
// execute statement
stmt.executeQuery("LOAD DATA LOCAL INPATH '/home/user/sample.txt'" + "OVERWRITE INTO TABLE employee;");
System.out.println("Load Data into employee successful");
con.close();
}
}
将程序保存在名为 HiveLoadData.java 的文件中。使用以下命令编译并执行该程序。
$ javac HiveLoadData.java
$ java HiveLoadData
输出：
Load Data into employee successful
