利用Sqoop从MySQL数据源向Hive中导入数据

1、执行导入的操作命令：在Sqoop的安装目录下bin目录下执行命令

sqoop import --driver com.mysql.jdbc.Driver --connect jdbc:mysql://数据库主机ip:3306/数据库名?useUnicode=true&characterEncoding=utf-8 --username root --password 密码 --hive-table hive表名 --table 数据库表名称 --hive-import -m 1;

如：

sqoop import --driver com.mysql.jdbc.Driver --connect "jdbc:mysql://192.168.2.73:3306/student?useUnicode=true&characterEncoding=utf-8" --username root --password cecgw --hive-table stu_ttt --table stu --hive-import -m 1;

执行成功：

2、hive本地文件导入
1）hive建表：
hive>create table tb_emp_info(id int,name string,age int,tel string)ROW FORMAT DELIMITEDFIELDS TERMINATED BY '|'STORED AS TEXTFILE;  

注意分隔符为'|'。

2）本地文件导入

先构造数据文件ba.txt

1|name1|25|13188888888888
2|name2|30|13888888888888
3|name3|3|147896221
4|name4|56|899314121
5|name5|12|899314121
6|name6|9|899314121
7|name7|32|899314121
8|name8|42|158964
9|name9|86|899314121
10|name10|45|789541

hive>LOAD DATA LOCAL INPATH '/home/bigdata/ba.txt' INTO TABLE tb_emp_info;
3）查看导入记录

hive>select * from t_evninfo2 limit 10;