（1）为了演示如何将 MySQL 中指定表的数据导入 HDFS 中，首先我们在 MySQL 中创建一张 user 表：

CREATE TABLE `user` (
  `id` int(10) NOT NULL AUTO_INCREMENT,
  `name` varchar(64) DEFAULT NULL,
  `phone` varchar(64) DEFAULT NULL,
  PRIMARY KEY (`id`)
);

（2）接着在该表中插入 4 条数据：

INSERT INTO user (id, name, phone) VALUES ('1', 'lilei', null);
INSERT INTO user (id, name, phone) VALUES ('2', 'xiaoliu', '888888');
INSERT INTO user (id, name, phone) VALUES ('3', 'hangge', '123456');
INSERT INTO user (id, name, phone) VALUES ('4', 'baidu', null);

2，全表导入样例

（1）下面命令使用 Sqoop 将表 user 中的数据导入 HDFS 中：

sqoop import \
--connect jdbc:mysql://192.168.60.1:3306/hangge?serverTimezone=UTC \
--username root \
--password hangge1234 \
--table user \
--target-dir /out1 \
--delete-target-dir \
--num-mappers 1 \
--fields-terminated-by '\t'

（2）控制台输出如下内容说明任务执行完毕： （3）看到 HDFS 上也创建了对应的目录和文件： （4）打开文件可以看到里面便是从数据库中导出的数据：

3，查询导出样例

sqoop import \
--connect jdbc:mysql://192.168.60.1:3306/hangge?serverTimezone=UTC \
--username root \
--password hangge1234 \
--target-dir /out2 \
--delete-target-dir \
--num-mappers 1 \
--fields-terminated-by '\t' \
--query 'select id,name,phone from user where id >1 and $CONDITIONS;' 

（2）查看 HDFS 上的文件，里面内容只有复合查询条件的数据：

（1）在默认情况下，MySQL 中的 NULL 值（无论字段类型是字符串类型还是数字类型）在使用 Sqoop 导入 HDFS 后会显示为字符串 null。

（2）我们可以通过参数来设置NULL值的替换方式：

注意：

• 这两个参数可以同时设置，这样在做数据导入时，空值字段会被替换为指定的字符串内容。
• 在 --null-string 和 --null-non-string 后面指定字符串时不能使用双引号，只能使用单引号，否则执行会报错，Sqoop 对引号是比较敏感的。

（3）举例来说，假设我们将数据导入 HDFS 后最终是希望在 Hive 中进行查询，那么久可以使用 "\N" 表示 NULL值。因为 Hive 对于NULL 值在底层数据文件中是使用 “\N” 存储的。

sqoop import \
--connect jdbc:mysql://192.168.60.1:3306/hangge?serverTimezone=UTC \
--username root \
--password hangge1234 \
--target-dir /out3 \
--delete-target-dir \
--num-mappers 1 \
--fields-terminated-by '\t' \
--query 'select id,name,phone from user where id >1 and $CONDITIONS;' \
--null-string '\\N' \
--null-non-string '\\N'

（1）在工作中使用 Sqoop 时，建议将 Sqoop 的命令写在 Shell 脚本中，否则无法实现命令重用，并且调用也不方便。比如，我们执行如下命令创建一个在 Shell 脚本：

vi sqoop-import-user.sh

#!/bin/bash
sqoop import \
--connect jdbc:mysql://192.168.60.1:3306/hangge?serverTimezone=UTC \
--username root \
--password hangge1234 \
--target-dir /out3 \
--delete-target-dir \
--num-mappers 1 \
--fields-terminated-by '\t' \
--query 'select id,name,phone from user where id >1 and $CONDITIONS;' \
--null-string '\\N' \
--null-non-string '\\N'

./sqoop-import-user.sh