使用sqoop导入导出

一: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查看数据
 
原文地址:https://www.cnblogs.com/nuliyao123/p/14173810.html