本章將介紹如何修改表的屬性,如,修改表名,修改列名,添加列,并刪除或替換列。
它是在Hive中用來修改的表。
聲明接受任意屬性,我們希望在一個(gè)表中修改以下語法。
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程序重命名表如下。
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(); } }
將該程序保存在一個(gè)名為HiveAlterRenameTo.java文件。使用下面的命令來編譯和執(zhí)行這個(gè)程序。
$ javac HiveAlterRenameTo.java $ java HiveAlterRenameTo
Table renamed successfully.
下表包含employee表的字段,它顯示的字段要被更改(粗體)。
| 字段名 | 從數(shù)據(jù)類型轉(zhuǎn)換 | 更改字段名稱 | 轉(zhuǎn)換為數(shù)據(jù)類型 |
|---|---|---|---|
| eid | int | eid | int |
| name | String | ename | String |
| salary | Float | salary | Double |
| designation | String | designation | String |
下面查詢重命名使用上述數(shù)據(jù)的列名和列數(shù)據(jù)類型:
hive> ALTER TABLE employee CHANGE name ename String; hive> ALTER TABLE employee CHANGE salary salary Double;
下面給出的是使用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 CHAN