hive操作数据表之DML操作

hive操作数据表之DML操作

hive的很多操作方式是与sql是一样的，这里先说一下DML操作的语句

数据库操作

数据库列表

hive (default)> show databases;

创建数据库

-- 完整语法
CREATE DATABASE [IF NOT EXISTS] database_name
-- 注释
[COMMENT database_comment]
-- 数据库的hdfs存放路径
[LOCATION hdfs_path]
-- 参数
[WITH DBPROPERTIES (property_name=property_value, ...)];

# CREATE DATABASE [IF NOT EXISTS] database_name;
CREATE DATABASE IF NOT EXISTS study_hive;

查看数据库详细信息

hive (default)> desc database study_hive;
OK
db_name    comment    location    owner_name    owner_type    parameters
study_hive        hdfs://localhost:9000/user/hive/warehouse/study_hive.db    zhanghe    USER

# 也可以使用
desc database extended study_hive;

这里默认是存储在hdfs://localhost:9000/user/hive/warehouse/下，目录名为数据库名.db

可以在创建数据库的时候进行设置

如 CREATE DATABASE IF NOT EXISTS study_hive location ‘/11’;

删除数据库

# 注意：只能删除空数据库，如果不是空数据库会报错FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.DDLTask. InvalidOperationException(message:Database study_hive1 is not empty. One or more tables exist.)
hive (study_hive)> drop database study_hive1;
# 删除非空的数据库
hive (study_hive)> drop database study_hive1 cascade;

数据表操作

创建表

-- 完整语法
-- EXTERNAL表示外部表
CREATE [EXTERNAL] TABLE [IF NOT EXISTS] table_name
-- 列名和类型
[(col_name data_type [COMMENT col_comment], ...)]
-- 注释
[COMMENT table_comment]
-- 分区，用于创建分区表
[PARTITIONED BY (col_name data_type [COMMENT col_comment], ...)]
-- 用于创建分桶表
[CLUSTERED BY (col_name, col_name, ...)
 -- 分桶表的配置
[SORTED BY (col_name [ASC|DESC], ...)] INTO num_buckets BUCKETS]
-- 行的格式
[ROW FORMAT row_format]
-- 文件类型
[STORED AS file_format]
-- 表的存储位置
[LOCATION hdfs_path]
-- 额外属性
[TBLPROPERTIES (property_name=property_value, ...)]
-- 根据查询语句创建表
[AS select_statement]

删除表

drop table `user`;

修改表名

ALTER TABLE `user` RENAME TO `user1`

修改表中列

-- ALTER TABLE table_name CHANGE [COLUMN] col_old_name col_new_name column_type
ALTER TABLE `user` CHANGE COLUMN id user_id int;

增加表中列

-- ALTER TABLE table_name ADD COLUMNS (col_name data_type [COMMENT col_comment], ...)
ALTER TABLE `user` ADD COLUMNS (user_name string);