一:mysql导入到hive
(1)进入mysql:
mysql -uroot -p
输入密码 进入mysql
查看现有的数据库 show databases;
首先创建一个mysql数据库: create database 数据库名;
也可以使用已有数据库: use 数据库名;
创建数据表: create table user(id int,name varchar(10));
查看数据表: show tables;
向表中插入数据: insert into user(id,name) values (1,'a'),(2,'b');
查看表中数据:select * from 表名;
(2)进入hive
先启动hadoop再启动hive
创建数据库:create database hi;
进入数据库:use hi;
创建表:
create table demo (id int,name string)row format delimited fields terminated by ' ';
(3)mysql数据导入hive
sqoop import --connect jdbc:mysql://master:3306/(mysql数据库名) --username root --password (mysql数据库密码)--table (mysql表名) --fields-terminated-by ' '(数据分割方式) --delete-target-dir --target-dir (hive路径) --m 1 --hive-import --hive-database (hive数据库名) --hive-table (hive表名)
导入成功 去hive查询一下
二:hive导入到mysql
(1)创建hive 表
create table demo2 (id int,name string)row format delimited fields terminated by ' ';
(2)添加数据
insert into demo2 values (1,'aa'),(2,'bb');
(3)创建mysql表
create table user2(id int,name varchar(10));
(4)hdfs导入mysql
sqoop export --connect jdbc:mysql://master:3306/m(mysql数据库名) --username root --password (mysql数据库密码) --table (mysql表名)--export-dir /user/hive/warehouse/hi.db/demo2(hive路径) --fields-terminated-by ' ' --m 1
(5)mysql查看数据