当前位置：首页 > 行业动态 > 正文

hive中数据库语句

Hive中数据库操作语句包括： CREATE DATABASE（创建库）、 DROP DATABASE（删除库）、 USE（切换当前库）、 SHOW DATABASES（查看所有库），语法与SQL类似，支持指定参数（如位置、描述），默认库为 default，操作

数据库基础操作

创建数据库

Hive中的数据库用于组织和管理表,语法如下：

CREATE (DATABASE|SCHEMA) [IF NOT EXISTS] database_name
[COMMENT 'description']
[LOCATION hdfs_path]
[WITH DBPROPERTIES ('key'='value')];

关键参数说明：

  • IF NOT EXISTS：若数据库已存在则不报错。
  • COMMENT：添加描述信息。
  • LOCATION：指定数据库在HDFS中的存储路径（需提前创建目录）。
  • DBPROPERTIES：设置数据库属性（如所有者、权限等）。

示例：

CREATE DATABASE IF NOT EXISTS sales_db
COMMENT 'Store sales-related tables'
LOCATION '/user/hive/warehouse/sales_db';

切换数据库

使用USE命令切换当前操作的数据库：

USE database_name;

未指定数据库时，默认使用default数据库。

查看数据库

  • 列出所有数据库： 
    SHOW DATABASES;
  • 查看当前数据库： 
    SELECT current_database();
  • 查看数据库详情（需配合DESCRIBE扩展）： 
    DESCRIBE DATABASE EXTENDED sales_db;

删除数据库

DROP (DATABASE|SCHEMA) [IF EXISTS] database_name
[CASCADE | RESTRICT];
  • CASCADE：删除数据库及其所有表（需谨慎）。
  • RESTRICT：仅当数据库为空时允许删除（默认行为）。

注意：Hive默认不允许直接删除非空数据库，需添加CASCADE。

表管理操作

创建表

Hive表分为内部表（Managed Table）和外部表（External Table）,区别在于删除表时是否删除数据。

CREATE TABLE [IF NOT EXISTS] table_name (
  column1 data_type [COMMENT 'desc'],
  column2 data_type [COMMENT 'desc'],
  ...
)
[COMMENT 'table description']
[PARTITIONED BY (partition_column data_type)]
[CLUSTERED BY (cluster_column) INTO num_buckets BUCKETS]
[STORED AS file_format]
[LOCATION hdfs_path]
[AS select_query];

关键参数：

  • PARTITIONED BY：定义分区列（静态分区）。
  • CLUSTERED BY：定义桶（动态分区需结合NUMBUCKET）。
  • STORED AS：指定存储格式（如TEXTFILE、ORC、PARQUET）。
  • LOCATION：外部表必填,指向数据存储路径。
  • AS select_query：通过查询结果创建表。

示例1：内部表：

CREATE TABLE user_info (
  user_id INT,
  name STRING,
  age INT
)
COMMENT 'User basic information'
STORED AS ORC;

示例2：外部表：

CREATE EXTERNAL TABLE log_data (
  timestamp STRING,
  level STRING,
  message STRING
)
LOCATION '/data/logs/';

修改表结构

ALTER TABLE table_name
[ADD COLUMNS (column_name data_type)]
[DROP COLUMN column_name]
[RENAME COLUMN old_name TO new_name]
[CHANGE COLUMN old_name new_name data_type]
[PARTITION columns_spec] -仅适用于分区表；

示例：

-添加新列
ALTER TABLE user_info ADD COLUMNS (email STRING);
-重命名列
ALTER TABLE user_info RENAME COLUMN age TO user_age;

删除表

DROP TABLE [IF EXISTS] table_name;
  • 内部表删除时,元数据和数据均被移除。
  • 外部表仅删除元数据,数据保留。

数据加载与查询

加载数据到表

  • 从本地文件系统加载： 
    LOAD DATA [LOCAL] INPATH '/path/to/file' INTO TABLE table_name;
  • 从HDFS加载： 
    LOAD DATA INPATH '/hdfs/path/file' INTO TABLE table_name;
  • 插入查询结果： 
    INSERT INTO TABLE target_table
SELECT  FROM source_table WHERE condition;

动态分区加载

SET hive.exec.dynamic.partition = true;
SET hive.exec.dynamic.partition.mode = nonstrict;
INSERT INTO TABLE partitioned_table
PARTITION (year, month)
SELECT col1, col2, year, month FROM source_table;

注意：需开启动态分区并设置模式（nonstrict允许部分分区不存在）。

权限管理

Hive支持基于角色的权限控制（RBAC）,常用语句包括：

  • 授权： 
    GRANT [ALL|privileges] ON [DATABASE|TABLE] object_name TO USER|ROLE entity;

    示例：

    GRANT SELECT ON TABLE user_info TO USER alice;
  • 收回权限： 
    REVOKE [privileges] ON [DATABASE|TABLE] object_name FROM USER|ROLE entity;
  • 显示权限： 
    SHOW GRANTS FOR USER alice;

常见问题对比

操作 内部表 外部表
数据所有权 Hive管理数据生命周期 数据由外部系统管理
删除表时数据影响 数据被删除 仅删除元数据，数据保留
典型用途 长期存储且由Hive完全管理的数据 临时数据或共享数据源
分区类型 静态分区 动态分区
定义方式 建表时指定PARTITIONED BY 插入数据时指定PARTITION子句
适用场景 分区值固定 分区值动态生成（如按日期）
性能优势 适合小范围分区 适合大规模数据自动分配

FAQs

Q1: 如何删除包含表的数据库？

A：需添加CASCADE关键字，

DROP DATABASE IF EXISTS sales_db CASCADE;

此操作会删除数据库及其所有表,请谨慎使用。

Q2: 如何修复损坏的表元数据？

A：若表的元数据（如SerDe、分区信息）损坏,可通过以下步骤修复：

  1. 导出表结构： 
    SHOW CREATE TABLE user_info;
  2. 删除原表： 
    DROP TABLE user_info;
  3. 根据导出语句重新
DDL语句HiveQL
0

相关文章