【Hive入门】Hive基础操作与SQL语法：DDL操作全面指南

CREATE DATABASE [IF NOT EXISTS] database_name
[COMMENT database_comment]
[LOCATION hdfs_path]
[WITH DBPROPERTIES (property_name=property_value, ...)];

• 示例

CREATE DATABASE IF NOT EXISTS sales_db
COMMENT 'Sales department database'
LOCATION '/user/hive/warehouse/sales.db'
WITH DBPROPERTIES ('creator'='John', 'date'='2025-04-20');

• 常用命令

-- 列出所有数据库
SHOW DATABASES;-- 使用正则表达式过滤
SHOW DATABASES LIKE 'sales*';-- 查看数据库详细信息
DESCRIBE DATABASE sales_db;-- 查看扩展属性
DESCRIBE DATABASE EXTENDED sales_db;

-- 切换当前数据库
USE sales_db;-- 查看当前使用的数据库
SELECT current_database();

-- 修改数据库属性
ALTER DATABASE sales_db SET DBPROPERTIES ('edited-by'='Mary');-- 修改数据库位置(注意：Hive 4.0+支持)
ALTER DATABASE sales_db SET LOCATION 'hdfs://new/path';

-- 基本删除
DROP DATABASE sales_db;-- 安全删除(数据库为空时)
DROP DATABASE IF EXISTS sales_db;-- 强制删除(删除非空数据库)
DROP DATABASE IF EXISTS sales_db CASCADE;

• 基本语法

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, ...) [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];

• 示例

CREATE EXTERNAL TABLE IF NOT EXISTS sales_records (order_id BIGINT COMMENT 'Unique order identifier',customer_id STRING,amount DOUBLE
)
COMMENT 'Sales records from all regions'
PARTITIONED BY (sale_date STRING, region STRING)
ROW FORMAT DELIMITED
FIELDS TERMINATED BY ','
STORED AS ORC
LOCATION '/user/hive/warehouse/sales.db/records'
TBLPROPERTIES ('orc.compress'='SNAPPY');

-- 列出所有表
SHOW TABLES;-- 查看表结构
DESCRIBE FORMATTED sales_records;-- 查看表分区
SHOW PARTITIONS sales_records;-- 查看建表语句
SHOW CREATE TABLE sales_records;

• 常用修改操作

-- 重命名表
ALTER TABLE sales_records RENAME TO sales_data;-- 添加列
ALTER TABLE sales_data ADD COLUMNS (payment_method STRING COMMENT 'Credit card or cash',discount DOUBLE COMMENT 'Applied discount amount'
);-- 修改列
ALTER TABLE sales_data CHANGE COLUMN amount total_amount DOUBLE;-- 修改表属性
ALTER TABLE sales_data SET TBLPROPERTIES ('notes'='Updated schema 2025');-- 添加分区
ALTER TABLE sales_data ADD PARTITION (sale_date='2025-04-20', region='EAST');

-- 删除内部表(同时删除数据)
DROP TABLE sales_data;-- 删除外部表(仅删除元数据)
DROP TABLE sales_data;-- 有条件删除
DROP TABLE IF EXISTS sales_data;-- 清空表数据(保留结构)
TRUNCATE TABLE sales_data;

• 分区管理命令

-- 添加单个分区
ALTER TABLE sales_data ADD PARTITION (sale_date='2025-04-20');-- 添加多个分区
ALTER TABLE sales_data ADD PARTITION (sale_date='2023-01-02')PARTITION (sale_date='2023-01-03');-- 删除分区
ALTER TABLE sales_data DROP PARTITION (sale_date='2025-04-20');-- 修复分区(元数据与HDFS不一致时)
MSCK REPAIR TABLE sales_data;

-- 创建分桶表
CREATE TABLE bucketed_users (id INT,name STRING
)
CLUSTERED BY (id) INTO 4 BUCKETS;