Hive 修改表

本章介绍如何修改表的属性，例如更改表的名称、更改列名称、添加列以及删除或替换列。

阅读更多：Hive 教程

修改表语句

这个命令用于修改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 {

      // 注册驱动程序并创建驱动程序实例
      Class.forName(driverName);

      // 获取连接
      Connection con = DriverManager.getConnection("jdbc:hive://localhost:10000/userdb", "", "");

      // 创建声明
      Statement stmt = con.createStatement();

      // 执行声明
      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 表的字段，显示要更改的字段（用粗体表示）。

以下查询使用上述数据更改列名称和列数据类型：

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 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.

添加列语句

以下查询向employee表中添加名为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 {

      // 注册驱动程序并创建驱动程序实例
      Class.forName(driverName);

      // 获取连接
      Connection con = DriverManager.getConnection("jdbc:hive://localhost:10000/userdb", "", "");

      // 创建声明
      Statement stmt = con.createStatement();

      // 执行声明
      stmt.executeQuery("ALTER TABLE employee ADD COLUMNS " + " (dept STRING COMMENT 'Department name');");
      System.out.prinln("添加列成功。");

      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程序

以下是替换 eid 列为 empid 和 ename 列为 name 的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 {

      // 注册驱动程序并创建驱动实例
      Class.forName(driverName);

      // 获取连接
      Connection con = DriverManager.getConnection("jdbc:hive://localhost:10000/userdb", "", "");

      // 创建语句对象
      Statement stmt = con.createStatement();

      // 执行语句
      stmt.executeQuery("ALTER TABLE employee REPLACE COLUMNS "
         +" (eid INT empid Int,"
         +" ename STRING name String);");

      System.out.println("替换列成功");
      con.close();
   }
}

将程序保存到名为HiveAlterReplaceColumn.java的文件中。使用以下命令编译和执行此程序。

$ javac HiveAlterReplaceColumn.java
$ java HiveAlterReplaceColumn

输出：

替换列成功