[Sqoop]利用sqoop对mysql执行DML操作

执行结果如下：

<code class=" hljs 1c">[pms@yhd-jqhadoop39 /home/pms/workspace/ouyangyewei/data]
$sqoop eval > --connect jdbc:mysql:<span class="hljs-comment">//10.0.2.54:3307/market \</span>
> --username marketuser > --password <span class="hljs-number">123456</span> > --query <span class="hljs-string">"select end_user_id, category_id, score, last_bought_date, days_left, update_time </span>
> from market.PERIOD_RECOMMEND limit <span class="hljs-number">10</span><span class="hljs-string">" </span>
Warning: /usr/lib/sqoop/../accumulo does not exist! Accumulo imports will fail.
Please set $ACCUMULO_HOME to the root of your Accumulo installation.
<span class="hljs-number">15</span>/<span class="hljs-number">06</span>/<span class="hljs-number">09</span> <span class="hljs-number">09</span>:<span class="hljs-number">36</span>:<span class="hljs-number">53</span> INFO sqoop.Sqoop: Running Sqoop version: <span class="hljs-number">1.4</span>.<span class="hljs-number">4</span>-cdh5.<span class="hljs-number">0.2</span>
<span class="hljs-number">15</span>/<span class="hljs-number">06</span>/<span class="hljs-number">09</span> <span class="hljs-number">09</span>:<span class="hljs-number">36</span>:<span class="hljs-number">53</span> WARN tool.BaseSqoopTool: Setting your password on the command-line is insecure. Consider using -P instead.
<span class="hljs-number">15</span>/<span class="hljs-number">06</span>/<span class="hljs-number">09</span> <span class="hljs-number">09</span>:<span class="hljs-number">36</span>:<span class="hljs-number">53</span> INFO manager.MySQLManager: Preparing to use a MySQL streaming resultset.
--------------------------------------------------------------------------------------------------------------
<span class="hljs-string">| END_USER_ID          | CATEGORY_ID          | SCORE                | LAST_BOUGHT_DATE | DAYS_LEFT | UPDATE_TIME         | </span>
--------------------------------------------------------------------------------------------------------------
<span class="hljs-string">| 1020                 | 6639                 | 0.03765381553445836  | 2015-02-26 | 42 | 2015-06-01 10:57:09.0 | </span>
<span class="hljs-string">| 1180                 | 6008                 | 0.49232472007320505  | 2015-05-16 | 5  | 2015-06-01 11:00:30.0 | </span>
<span class="hljs-string">| 1180                 | 6638                 | 0.12863038975524008  | 2015-05-16 | 10 | 2015-06-04 11:04:18.0 | </span>
<span class="hljs-string">| 1180                 | 6641                 | 0.016126884197067093 | 2015-05-16 | 17 | 2015-06-08 11:06:54.0 | </span>
<span class="hljs-string">| 1180                 | 972108               | 0.9059551911095096   | 2015-04-12 | 4  | 2015-06-01 11:00:30.0 | </span>
<span class="hljs-string">| 1580                 | 959307               | 0.015703642709355377 | 2015-04-26 | 29 | 2015-06-07 11:20:13.0 | </span>
<span class="hljs-string">| 1620                 | 5059                 | 0.03979611383975357  | 2015-03-11 | 39 | 2015-06-02 11:24:50.0 | </span>
<span class="hljs-string">| 1680                 | 959307               | 0.21385565120306954  | 2015-05-07 | 11 | 2015-06-04 11:28:21.0 | </span>
<span class="hljs-string">| 2030                 | 6638                 | 0.03160084296270789  | 2015-03-09 | 41 | 2015-06-03 11:35:04.0 | </span>
<span class="hljs-string">| 2110                 | 6641                 | 0.9888130446112331   | 2015-03-14 | -6 | 2015-06-05 11:41:16.0 | </span>
--------------------------------------------------------------------------------------------------------------</code>

删除操作：

<code class=" hljs haml">sqoop eval -<span class="ruby">-connect <span class="hljs-symbol">jdbc:</span><span class="hljs-symbol">mysql:</span>/<span class="hljs-regexp">/127.0.0.1:3306/market</span> </span>-<span class="ruby">-username admin </span>-<span class="ruby">-password <span class="hljs-number">123456</span> </span>-<span class="ruby">-query <span class="hljs-string">"delete from PERIOD_RECOMMEND where update_time < ‘2015-06-01‘"</span> </span></code>

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

[Sqoop]利用sqoop对mysql执行DML操作

标签：