其他问题已提出/回答,但没有人能回答我以下的问题:
我只是将有限的行范围(例如,“其中的_ID在107和307之间")从MySQL表导入到hdfs。考虑到MySQL查询本身是有效的,我希望查询能够工作,但是我得到了一个MySQL语法错误。或者,我可以使用上限和下限导入,然后在以后合并文件,这很长,我不想这样做。
以下是查询:
sqoop import \
--connect jdbc:mysql://localhost/test \
--username=username \
--password=password \
--query 'select * from PURCHASE where purchase_id between 107 and 307 where $CONDITIONS' \
--target-dir /testpurchase \
--split-by purchase_id 请问,我在查询中遗漏了什么吗,谢谢?
发布于 2018-11-28 00:41:13
我发现有两个模棱两可的WHERE clauses,所以把最后一个WHERE $CONDITIONS改为AND $CONDITIONS就成功了。
sqoop import \
--connect jdbc:mysql://localhost/test \
--username=username \
--password=password \
--query 'select * from PURCHASE WHERE purchase_id between 107 and 307 AND $CONDITIONS' \
--target-dir /testpurchase \
--split-by purchase_id而一个边界查询和表也可以完成这项工作。
sqoop import \
--connect jdbc:mysql://localhost/test \
--username=username \
--password=password \
--boundary-query 'Select 107,307 from purchase' \
--table purchase\
--target-dir /testpurchase \https://stackoverflow.com/questions/53264753
复制相似问题