导入表数据子集
我们可以导入表的使用Sqoop导入工具&＃xff0c;"where"子句的一个子集。它执行在各自的数据库服务器相应的SQL查询&＃xff0c;并将结果存储在HDFS的目标目录。
where子句的语法如下。
| --where |
按照条件进行查找&＃xff0c;通过—where参数来查找表emp_add当中city字段的值为sec-bad的所有数据导入到hdfs上面去
bin/sqoop import \
--connect jdbc:mysql://172.16.43.67:3306/userdb \
--username root --password admin --table emp_add \
--target-dir /sqoop/emp_add -m 1 --delete-target-dir \
--where "city &＃61; &＃39;sec-bad&＃39;"
sql语句查找导入hdfs
我们还可以通过 –query参数来指定我们的sql语句&＃xff0c;通过sql语句来过滤我们的数据进行导入
bin/sqoop import \
--connect jdbc:mysql://172.16.43.67:3306/userdb --username root --password admin \
--delete-target-dir -m 1 \
--query &＃39;select phno from emp_conn where 1&＃61;1 and $CONDITIONS&＃39;[a1] \
--target-dir /sqoop/emp_conn
查看hdfs数据内容
hdfs dfs -text /sqoop/emp_conn/part*
[a1]使用sql语句来进行查找是不能加参数--table
并且必须要添加where条件&＃xff0c;
并且where条件后面必须带一个$CONDITIONS 这个字符串&＃xff0c;
并且这个sql语句必须用单引号&＃xff0c;不能用双引号
京公网安备 11010802041100号