转载

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.

正文到此结束

所属分类： Hive教程

本文标签： Hadoop 编译 apache value java 数据 sql ip db tab
版权声明： 本文为互联网转载文章，出处已在文章中说明(部分除外)。如果侵权，请联系本站长删除，谢谢。
本文海报： 生成海报一生成海报二

其他链接

关于本站

本站定位：个人技术类博客

本站作用：写博客、记日志、闲聊扯淡鼓捣技术。

问题交流

Hive修改表

Alter Table 语句

语法

Rename To… 语句

JDBC 程序

输出

Change 语句

JDBC 程序

输出

添加列语句

JDBC 程序

输出

REPLACE语句

JDBC 程序

输出：

热门推荐

相关文章

Hive教程

说给你听

本文目录

随机标签

书籍教程

近期评论

网站信息

其他链接

关于本站

问题交流