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.