业务背景

利用Sqoop对MySQL进行查询、添加、删除等操作。

业务实现

select操作：

sqoop eval \--connect jdbc:mysql://127.0.0.1:3306/market \--username admin \--password 123456 \--query "select end_user_id, category_id, score, last_bought_date, days_left, update_time from market.PERIOD_RECOMMEND limit 10"

 

执行结果如下：

[pms@yhd-jqHadoop39 /home/pms/workspace/ouyangyewei/data]$sqoop eval \> --connect jdbc:mysql://10.0.2.54:3307/market \> --username marketuser \> --password 123456 \> --query "select end_user_id, category_id, score from market.PERIOD_RECOMMEND limit 10" ----------------------------------------------------------------------------------| END_USER_ID  | CATEGORY_ID  | SCORE ----------------------------------------------------------------------------------| 1020         | 6639         |0.03765381553445836| 1180         | 6008         |0.49232472007320505 | 1180         | 6638         |0.12863038975524008 ----------------------------------------------------------------------------------

 

删除操作：

sqoop eval \--connect jdbc:mysql://127.0.0.1:3306/market \--username admin \--password 123456 \--query "delete from PERIOD_RECOMMEND where update_time < '2015-06-01'"

 

其他操作操作：

sqoop eval \--connect jdbc:mysql://127.0.0.1:3306/market \--username admin \--password 123456 \--query "call procedure_clear_aaa()"

 

利用sqoop eval，只需要在参数--query中指定sql语句即可对mysql执行DML操作。