如何将HDFS数据导入MySQL数据库？

（1）创建MySQL 表

在MySQL 的sqoop_test 数据库中，创建表“employee_out”，结构与“mysql_employee”一样，也可以在navicat 中直接通过复制“mysql_employee”的方式创建新表。确保“employee_out”表中没有数据。

（2）将HDFS 数据导出到MySQL

通过Sqoop Export 命令将HDFS 目录“/sqoop/mysql_employee”中的所有文件导出到MySQL 的“employee_out”表中。切换到Sqoop 安装目录下的bin 目录，执行命令为：

上述命令中的参数说明如下：

--export-dir /sqoop/mysql_employee：指定待导出的HDFS 数据文件的目录。(www.xing528.com)

--input-fields-terminated-by '\t'：指定HDFS 文件的字段分隔符为“\t”。

--input-lines-terminated-by '\n'：指定HDFS 文件的行分隔符为“\n”。

（3）查看导出结果

查看MySQL 中employee_out 表的结果，如图9.15 所示。

图9.15　Sqoop 导出到HDFS 的结果

从图9.15 可以看出，通过Sqoop Export 将数据从HDFS 导出到MySQL 的操作成功。