第一步： 将examples目录下的sqoop目录拷贝到oozie-apps目录下
cp -r sqoop /opt/modules/oozie/oozie-apps/
第二步： 将sqopp目录下的db.hsqldb.properties db.hsqldb.script两个文件删除
rm -rf db.hsqldb.properties db.hsqldb.script
第三步： 创建lib目录
mkdir lib
第四步： 拷贝mysql jar包到lib目录下
cp /opt/modules/hive/lib/mysql-connector-java-5.1.48-bin.jar .
第五步： 这里我们测试的是hive表导出到mysql表。需要检查hive表和mysql表，分别是hive表（db_hive.user_info）和mysql表(db_sqoop.user_info_export)
关于hive表导出到mysql表的内容，以及创建表的格式和数据请参考这篇文章的第四节：
https://blog.csdn.net/weixin_45366499/article/details/109403343
第六步： 编写sqoop导出脚本文件export.txt，内容如下：
--connect jdbc:mysql://bigdata-pro-m01:3306/db_sqoop --username root --password 199911 --num-mappers 1 --table user_info_export --input-fields-terminated-by ',' --export-dir /user/hive/warehouse/db_hive.db/user_info
export.txt在/opt/modules/oozie/oozie-apps/sqoop目录下
第七步： 编写job.properties文件，参考官方example，内容如下：
nameNode=hdfs://bigdata-pro-m01:9000 jobTracker=bigdata-pro-m01:8032 queueName=default oozieAppRoot=user/caizhengjie/oozie-apps oozieDataRoot=user/caizhengjie/oozie-datas oozie.use.system.libpath=true oozie.wf.application.path=${nameNode}/${oozieAppRoot}/sqoop EXEC=export.txt
第八步： 编写workflow.xml，内容如下：
<workflow-app xmlns="uri:oozie:workflow:0.5" name="sqoop-wf"> <start to="sqoop-node"/> <action name="sqoop-node"> <sqoop xmlns="uri:oozie:sqoop-action:0.3"> <job-tracker>${jobTracker}</job-tracker> <name-node>${nameNode}</name-node> <configuration> <property> <name>mapred.job.queue.name</name> <value>${queueName}</value> </property> </configuration> <command>export --options-file ${EXEC}</command> <file>${nameNode}/${oozieAppRoot}/sqoop/${EXEC}#${EXEC}</file> </sqoop> <ok to="end"/> <error to="fail"/> </action> <kill name="fail"> <message>Sqoop failed, error message[${wf:errorMessage(wf:lastErrorNode())}]</message> </kill> <end name="end"/> </workflow-app>
第九步： 上传sqoop整个目录到HDFS上
bin/hdfs dfs -put /opt/modules/oozie/oozie-apps/sqoop/ /user/caizhengjie/oozie-apps
第十步： 运行测试
bin/oozie job -oozie http://bigdata-pro-m01:11000/oozie -config oozie-apps/sqoop/job.properties -run
查看测试结果：
查看导出的mysql数据表
mysql> select * from user_info_export; +----+----------+----------+ | id | username | password | +----+----------+----------+ | 1 | admin | admin | | 2 | wang | 111111 | | 3 | zhang | 000000 | | 4 | lili | 000000 | | 5 | henry | 000000 | | 6 | cherry | 000000 | | 7 | ben | 111111 | | 8 | leo | 000000 | | 9 | test | test | | 10 | system | 000000 | | 11 | xiao | 111111 | +----+----------+----------+ 11 rows in set (0.00 sec)
