需要手动导入mysql驱动包： 将对应版本驱动包mysql-connector-java-5.1.40-bin.jar导入到sqoop-1.4.6/lib/目录

普通导入

代码

  1. sqoop import \
  2. --connect jdbc:mysql://hadoop02:3306/mysql \
  3. --username root \
  4. --password root \
  5. --table help_keyword \
  6. -m 1

数据存储目录

/user/hadoop/help_keyword/part-m-00000

查看数据

hdfs dfs -cat /user/hadoop/help_keyword/part-m-00000

指定分隔符和目录

代码

sqoop import \
--connect jdbc:mysql://hadoop02:3306/mysql \
--username root \
--password root \
--table help_keyword \
--target-dir /help_keyword \
--fields-terminated-by '\t' \
-m 1

数据存储目录

/help_keyword/part-m-00000

查看数据

hdfs dfs -cat /help_keyword/part-m-00000

过滤条件

代码

sqoop import \
--connect jdbc:mysql://hadoop02:3306/mysql \
--username root \
--password root \
--table help_keyword \
--where "name='STRING'" \
--target-dir /help_keyword_01 \
-m 1

数据存储目录

/user/hadoop/help_keyword/part-m-00000

查看数据

hdfs dfs -cat /user/hadoop/help_keyword/part-m-00000

验证数据

select * from help_keyword where name='STRING';

支持写SQL语句

代码

sqoop import \
--connect jdbc:mysql://hadoop02:3306/mysql \
--username root \
--password root \
--query "select * from help_keyword where name='STRING' and $CONDITIONS" \
--target-dir /help_keyword_02 \
-m 1

数据存储目录

/user/hadoop/help_keyword/part-m-00000

查看数据

hdfs dfs -cat /user/hadoop/help_keyword/part-m-00000