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 ...])
Rename To… 語句
下面是查詢重命名錶，把 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.
Change 語句
下表包含employee表的字段，它顯示的字段要被更改（粗體）。
字段名
從數據類型轉換
更改字段名稱
轉換爲數據類型
eid
int
eid
int
name
String
ename
String
salary
Float
salary
Double
designation
String
designation
String
下面查詢重命名使用上述數據的列名和列數據類型：
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在employee表。
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
輸出
Add column successful.
REPLACE語句
以下從employee表中查詢刪除的所有列，並使用emp替換列：
hive> ALTER TABLE employee REPLACE COLUMNS ( > eid INT empid Int, > ename STRING name String);
JDBC 程序
下面給出的是JDBC程序使用empid代替eid列，name代替ename列。
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.