Sqoop命令

注意:需要将mysql的jar包放在lib文件夹下

大数据-Sqoop命令
大数据-Sqoop命令

一、Import命令

Sqoop-MySQL导入到HDFS

sqoop import 
--connect jdbc:mysql://hadoop1:3306/data 
--username root 
--password root 
--table test 
--target-dir /sqoop/test 
--num-mappers 1 
--fields-terminated-by "\t"

大数据-Sqoop命令
大数据-Sqoop命令

Sqoop-query过滤数据

# query过滤
sqoop import 
--connect jdbc:mysql://hadoop1:3306/data 
--username root 
--password root 
--target-dir /sqoop/test 
--num-mappers 1 
--fields-terminated-by "\t" 
--query 'select * from test where id <= 1 and $CONDITIONS'

大数据-Sqoop命令
大数据-Sqoop命令

Sqoop-columns过滤字段

sqoop import 
--connect jdbc:mysql://hadoop1:3306/data 
--username root 
--password root 
--table test 
--target-dir /sqoop/data --num-mappers 1 
--columns name

大数据-Sqoop命令
大数据-Sqoop命令

Sqoop-MySQL导入到Hive

sqoop import 
--connect jdbc:mysql://hadoop1:3306/data 
--username root 
--password root 
--table test 
--num-mappers 1 
--hive-import 
--fields-terminated-by '\t' 
--hive-overwrite 
--hive-table test

大数据-Sqoop命令
大数据-Sqoop命令

二、export命令

Hive导出到Sqoop-MySQL

# 清空test表的数据
truncate table test;
sqoop export 
--connect jdbc:mysql://hadoop1:3306/data 
--username root 
--password root 
--table test 
--num-mappers 1 
--export-dir /user/hive/warehouse/test 
--input-fields-terminated-by "\t"

大数据-Sqoop命令
大数据-Sqoop命令

相关文章: