Hive 更改表
本章介绍如何更改表的属性，例如更改表名、更改列名、添加列以及删除或替换列。
Alter Table 语句
用于修改 Hive 中的表。
语法
该语句根据我们希望在表中修改的属性采用以下任何一种语法。
ALTER TABLE name RENAME TO new_name
ALTER TABLE name ADD COLUMNS (col_spec[, col_spec ...])
ALTER TABLE name DROP [COLUMN] column_name
ALTER TABLE name CHANGE column_name new_name new_type
ALTER TABLE name REPLACE COLUMNS (col_spec[, col_spec ...])
重命名为…声明
以下查询将表从
employee 重命名为
emp。
hive> ALTER TABLE employee RENAME TO emp;
JDBC 程序
重命名表的JDBC程序如下。
import java.sql.SQLException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.sql.DriverManager;
public class HiveAlterRenameTo {
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("ALTER TABLE employee RENAME TO emp;");
System.out.println("Table Renamed Successfully");
con.close();
}
}
将程序保存在名为 HiveAlterRenameTo.java 的文件中。使用以下命令编译并执行该程序。
$ javac HiveAlterRenameTo.java
$ java HiveAlterRenameTo
输出：
Table renamed successfully.
变更声明
下表包含
employee表的字段，并显示了要更改的字段（以粗体显示）。
| 字段名称 |
从数据类型转换 |
更改字段名称 |
转换为数据类型 |
| 开斋节 |
内部 |
开斋节 |
内部 |
| 名字 |
字符串 |
ename |
字符串 |
| 工资 |
浮动 |
工资 |
双人 |
| 指定 |
字符串 |
指定 |
字符串 |
以下查询使用上述数据重命名列名和列数据类型：
hive> ALTER TABLE employee CHANGE name ename String;
hive> ALTER TABLE employee CHANGE salary salary Double;
JDBC 程序
下面给出的是改变列的 JDBC 程序。
import java.sql.SQLException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.sql.DriverManager;
public class HiveAlterChangeColumn {
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("ALTER TABLE employee CHANGE name ename String;");
stmt.executeQuery("ALTER TABLE employee CHANGE salary salary Double;");
System.out.println("Change column successful.");
con.close();
}
}
将程序保存在名为 HiveAlterChangeColumn.java 的文件中。使用以下命令编译并执行该程序。
$ javac HiveAlterChangeColumn.java
$ java HiveAlterChangeColumn
输出：
Change column successful.
添加列语句
以下查询将名为 dept 的列添加到员工表中。
hive> ALTER TABLE employee ADD COLUMNS (
dept STRING COMMENT 'Department name');
JDBC 程序
下面给出了向表中添加列的 JDBC 程序。
import java.sql.SQLException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.sql.DriverManager;
public class HiveAlterAddColumn {
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("ALTER TABLE employee ADD COLUMNS " + " (dept STRING COMMENT 'Department name');");
System.out.prinln("Add column successful.");
con.close();
}
}
将程序保存在名为 HiveAlterAddColumn.java 的文件中。使用以下命令编译并执行该程序。
$ javac HiveAlterAddColumn.java
$ java HiveAlterAddColumn
输出：
替换声明
以下查询删除
employee 表中的所有列并将其替换为
emp 和
name 列：
hive> ALTER TABLE employee REPLACE COLUMNS (
eid int empid Int,
ename STRING name String);
JDBC 程序
下面给出的是用
empid 替换
eid 列和用
name 替换
ename 列的 JDBC 程序。
import java.sql.SQLException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.sql.DriverManager;
public class HiveAlterReplaceColumn {
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("ALTER TABLE employee REPLACE COLUMNS "
+" (eid int empid Int,"
+" ename STRING name String);");
System.out.println(" Replace column successful");
con.close();
}
}
将程序保存在名为 HiveAlterReplaceColumn.java 的文件中。使用以下命令编译并执行该程序。
$ javac HiveAlterReplaceColumn.java
$ java HiveAlterReplaceColumn
输出：
Replace column successful.
