本次博主为大家带来的是Hive的基本操作。

一. 创建数据库与创建数据库表

1.1 创建数据库

• 1. 创建数据库

//用户可以用 IF NOT EXISTS 选项来忽略这个异常。
 create database [ if not exists ] myhive ;

  

 

  
1
  
2
 

说明：hive的表存放位置模式是由hive-site.xml当中的一个属性指定的

<name>hive.metastore.warehouse.dir</name>
<value>/user/hive/warehouse</value>


  

 

  
1
  
2
  
3
 

• 2. 创建数据库并指定hdfs存储位置

create database myhive2 location '/myhive2';

  

 

  
1
 

• 3. 修改数据库
  可以使用alter database 命令来修改数据库的一些属性。但是数据库的元数据信息是不可更改的，包括数据库的名称以及数据库所在的位置

alter  database  myhive2  set  dbproperties('createtime'='202004090');

  

 

  
1
 

• 4. 查看数据库详细信息

①查看数据库基本信息

desc  database  myhive2;

  

 

  
1
 

②查看数据库更多详细信息

desc database extended  myhive2;  

  

 

  
1
 

• 5. 删除数据库

① 删除一个空数据库，如果数据库下面有数据表，那么就会报错

drop  database  myhive2;

  

 

  
1
 

②强制删除数据库，包含数据库下面的表一起删除

drop  database  myhive  cascade; 

  

 

  
1
 

包含数据库下面的表一起删除; 不要执行,危险动作

• 6. 数据库切换

 use myhive(自己的数据库名称);

  

 

  
1
 

二. Hive建表时候的字段类型

https://cwiki.apache.org/confluence/display/Hive/LanguageManual+Types

三. 数据库表的基本操作

3.1 内部表

• 创建基本数据表(内部表):

create table tableName(字段名称 字段类型，字段名称 字段类型)
ROW FORMAT DELIMITED IELDS TERMINATED BY char(char分隔符)
指定数据中字段与字段的分隔符 ‘\t’ 或 ‘,’ 或 ‘|’ 或其他

  

 

  
1
  
2
  
3
 

• 1. 创建表并指定字段之间的分隔符

create  table if not exists stu2(id int ,name string) row format delimited fields terminated by '\t' stored as textfile location '/user/stu2';

  

 

  
1
 

• 2. 根据查询结果创建表

create table stu3 as select * from stu2;

  

 

  
1
 

• 3. 根据已经存在的表结构创建表

create table stu4 like stu2;

  

 

  
1
 

• 4. 查询表的类型

desc formatted  stu2;

  

 

  
1
 

3.2 创建外部数据表

1. 外部表说明

  外部表因为是指定其他的hdfs路径的数据加载到表当中来，所以hive表会认为自己不完全独占这份数据，所以删除hive表的时候，数据仍然存放在hdfs当中，不会删掉。

2. 管理表和外部表的使用场景

  每天将收集到的网站日志定期流入HDFS文本文件。在外部表（原始日志表）的基础上做大量的统计分析，用到的中间表、结果表使用内部表存储，数据通过SELECT+INSERT进入内部表。

3. 操作实例

• 1. 分别创建老师与学生表外部表，并向表中加载数据
  create EXTERNAL table tableName(字段名称 字段类型，字段名称 字段类型)
  建外部表需要指定数据的存储路径。通过LOCATION进行指定。

①创建老师表：

create external table techer (t_id string,t_name string) row format delimited fields terminated by '\t';

  

 

  
1
 

②创建学生表：

create external table student (s_id string,s_name string,s_birth string , s_sex string ) row format delimited fields terminated by '\t';

  

 

  
1
 

• 2. 从本地文件系统向表中加载数据

load data local inpath ‘文件路径’ into table 表名;

  

 

  
1
 

• 3. 加载数据并覆盖已有数据

load data local inpath ‘文件路径’ overwrite into table 表名;

  

 

  
1
 

• 4. 从hdfs文件系统向表中加载数据（需要提前将数据上传到hdfs文件系统，其实就是一个移动文件的操作）

cd /export/servers/hivedatas
hdfs dfs -mkdir -p /hivedatas
hdfs dfs -put techer.csv /hivedatas/
load data inpath '/hivedatas/techer.csv' into table techer;


  

 

  
1
  
2
  
3
  
4
  
5
 

如果删掉student表，hdfs的数据仍然存在，并且重新创建表之后，表中就直接存在数据了,因为我们的student表使用的是外部表，drop table之后，表当中的数据依然保留在hdfs上面了

3.3 创建分区表

  在大数据中，最常用的一种思想就是分治，我们可以把大的文件切割划分成一个个的小的文件，这样每次操作一个小的文件就会很容易了，同样的道理，在hive当中也是支持这种思想的，就是我们可以把大的数据，按照每天，或者每小时进行切分成一个个的小的文件，这样去操作小的文件就会容易得多了。

  企业常见的分区规则：按天进行分区（一天一个分区）

• 1. 创建分区表语法

create table score(s_id string,c_id string, s_score int) partitioned by (month string) row format delimited fields terminated by '\t';

  

 

  
1
 

• 2. 创建一个表带多个分区

create table score2 (s_id string,c_id string, s_score int) partitioned by (year string,month string,day string) row format delimited fields terminated by '\t';

  

 

  
1
 

• 3. 加载数据到分区表中

load data local inpath '/export/servers/hivedatas/score.csv' into table score partition (month='201806');

  

 

  
1
 

• 4. 加载数据到一个多分区的表中去

load data local inpath '/export/servers/hivedatas/score.csv' into table score2 partition(year='2018',month='06',day='01');

  

 

  
1
 

• 5. 多分区联合查询使用union all来实现

select * from score where month = '201806' union all select * from score where month = '201806';

  

 

  
1
 

• 6. 查看分区

show  partitions  score;

  

 

  
1
 

• 7. 添加一个分区

alter table score add partition(month='201805');

  

 

  
1
 

• 8. 同时添加多个分区

alter table score add partition(month='201804') partition(month = '201803');

  

 

  
1
 

注意：添加分区之后就可以在hdfs文件系统当中看到表下面多了一个文件夹

• 9. 删除分区

alter table score drop partition(month = '201806');

  

 

  
1
 

特别强调:
分区字段绝对不能出现在数据库表已有的字段中!

作用:
将数据按区域划分开，查询时不用扫描无关的数据，加快查询速度。

3.4 创建分桶表

  是在已有的表结构之上新添加了特殊的结构。

  将数据按照指定的字段进行分成多个桶中去，说白了就是将数据按照字段进行划分，可以将数据按照字段划分到多个文件当中去

• 1. 开启hive的桶表功能

set hive.enforce.bucketing=true;

  

 

  
1
 

• 2. 设置reduce的个数

set mapreduce.job.reduces=3;

  

 

  
1
 

• 3. 创建通表

create table course (c_id string,c_name string,t_id string) clustered by(c_id) into 3 buckets row format delimited fields terminated by '\t';

  

 

  
1
 

  桶表的数据加载，由于通标的数据加载通过hdfs dfs -put文件或者通过load data均不好使，只能通过insert overwrite

  创建普通表，并通过insert overwrite的方式将普通表的数据通过查询的方式加载到桶表当中去

• 4. 创建普通表

create table course_common (c_id string,c_name string,t_id string) row format delimited fields terminated by '\t';

  

 

  
1
 

• 5. 普通表中加载数据

load data local inpath '/export/servers/hivedatas/course.csv' into table course_common;

  

 

  
1
 

• 6. 通过insert overwrite给桶表中加载数据

insert overwrite table course select * from course_common cluster by(c_id);

  

 

  
1
 

特别强调:
分桶字段必须是表中的字段。

分桶逻辑:
对分桶字段求哈希值,用哈希值与分桶的数量取余,余几,这个数据就放在哪个桶内。

3.5 修改表

1. 表重命名

	alter  table  old_table_name  rename  to  new_table_name;
	把表score4修改成score5
	alter table score4 rename to score5;


  

 

  
1
  
2
  
3
  
4
 

2. 增加/修改列信息

• 1. 查询表结构

desc score5;

  

 

  
1
 

• 2. 添加列

alter table score5 add columns (mycol string, mysco string);

  

 

  
1
 

• 3. 查询表结构

desc score5;

  

 

  
1
 

• 4. 更新列

alter table score5 change column mysco mysconew int;

  

 

  
1
 

• 5. 查询表结构

desc score5;

  

 

  
1
 

3. 删除表

drop table score5;

  

 

  
1
 

本次的分享就到这里了,

  $看完就赞，养成习惯！！！$^ _ ^ ❤️ ❤️ ❤️
  码字不易，大家的支持就是我坚持下去的动力。点赞后不要忘了关注我哦！

文章来源: buwenbuhuo.blog.csdn.net，作者：不温卜火，版权归原作者所有，如需转载，请联系作者。

原文链接：buwenbuhuo.blog.csdn.net/article/details/105837968