HIVE数据分析-处理结果入库

发布时间 2023-09-23 18:21:24作者: YE-

1、navicat远程连接Hive数据库

1、打开navicat里的mysql连接

2、使用SSH隧道

出现上面这个显示连接就是成功

3、设置常规连接

显示成功后点击确定,navicat远程连接Hive数据库成功

问题 4、处理结果入库:

将上述统计分析的结果数据保存到mySQL数据库中。

1、通过Navicat创建表格

create table jichang(
  day_id varchar(255),
  sale_nbr varchar(255),
  cnt varchar(255),
  round varchar(255)
)
create table dailishang(
  day_id varchar(255),
  sale_nbr varchar(255),
  cnt varchar(255),
  round varchar(255)
)
create table dailishang_h(
day_id varchar(255),
sale_nbr varchar(255),
Sale_number int
)


create table daili(
 day_id varchar(255),
 sale_nbr varchar(255),
 incnt int,
 inround int,
 outcnt int,
 outround int,
 lirun int
)

2、通过sqoop将hive的数据导入导mysql

bin/sqoop export \
--connect jdbc:mysql://node1:3306/hive1 \
--username root \
--password 20204112 \
--table jichang \
--num-mappers 1 \
--export-dir /user/hive/warehouse/jichang \
--input-fields-terminated-by ","

bin/sqoop export \
--connect jdbc:mysql://node1:3306/hive1 \
--username root \
--password 20204112 \
--table daili \
--num-mappers 1 \
--export-dir /user/hive/warehouse/daili \
--input-fields-terminated-by ","

bin/sqoop export \
--connect jdbc:mysql://node1:3306/hive1 \
--username root \
--password 20204112 \
--table dailishang \
--num-mappers 1 \
--export-dir /user/hive/warehouse/dailishang \
--input-fields-terminated-by ","

bin/sqoop export \
--connect jdbc:mysql://node1:3306/hive1 \
--username root \
--password 20204112 \
--table dailishang_h \
--num-mappers 1 \
--export-dir /user/hive/warehouse/dailishang_h \
--input-fields-terminated-by ","

3、显示导入成功


参考戈瑾的博客园,感谢紫诺学姐