惯性聚合 高效追踪和阅读你感兴趣的博客、新闻、科技资讯
阅读原文 在惯性聚合中打开

推荐订阅源

aimingoo的专栏
aimingoo的专栏
Y
Y Combinator Blog
云风的 BLOG
云风的 BLOG
Microsoft Azure Blog
Microsoft Azure Blog
腾讯CDC
T
The Blog of Author Tim Ferriss
P
Proofpoint News Feed
Hugging Face - Blog
Hugging Face - Blog
博客园_首页
小众软件
小众软件
美团技术团队
Martin Fowler
Martin Fowler
爱范儿
爱范儿
有赞技术团队
有赞技术团队
博客园 - 【当耐特】
让小产品的独立变现更简单 - ezindie.com
让小产品的独立变现更简单 - ezindie.com
Microsoft Security Blog
Microsoft Security Blog
宝玉的分享
宝玉的分享
J
Java Code Geeks
B
Blog
V
V2EX
Stack Overflow Blog
Stack Overflow Blog
B
Blog RSS Feed
博客园 - Franky

博客园 - 李阳

Java采用JDBC的方式连接Hive(SparkSQL) ubuntu 升级内核 Ubuntu 13.04设置root用户登录图形界面 ubuntu make menuconfig error Oracle创建用户和表空间脚本 GPL & BSD 许可证 - 李阳 调用WindowsAPI显示帮助提示 SQLServer 存储过程简介与使用方法 SQLServer 游标简介与使用说明 SQLServer 表值函数与标量值函数 定义方式与调用区别 使用Graphics画图的小技巧 灵活使用多线程编程——EventWaitHandle类 灵活使用多线程编程——AutoResetEvent类 [提问] 关于C#自定义控件的问题(请高手帮忙解决) Access数据库连接池问题 软件版本号的详解 安全的ACCESS加密方法 Oracle Hint的用法 Oracle存储过程编写经验和优化措施
Sqoop执行mysql删除语句
李阳 · 2017-10-20 · via 博客园 - 李阳

如果使用Sqoop删除mysql中的数据,并且传递动态日期参数,则使用下方的方法:

创建一个sh文件,内容如下:

#!/bin/sh

## 环境变量生效
. /etc/profile

#【调度删除导入所在月数据量】
deletym=$(date -d last-day +%Y%m)

sqoop eval --connect jdbc:mysql://112.112.10.127:3060/yangyang8848--username root --password yangyang8848--query "delete from yangyang8848 Where ym = '$deletym'"
sqoop eval --connect jdbc:mysql://112.112.10.127:3060/yangyang8848--username root --password yangyang8848--query "delete from yangyang8848 Where ym = '$deletym'"

sqoop export --connect "jdbc:mysql://112.112.10.127:3060/yangyang8848?useUnicode=true&characterEncoding=utf-8"  --username root  --password yangyang8848 --table yangyang8848  -hcatalog-database yangyang8848 --hcatalog-table yangyang8848

sqoop export --connect "jdbc:mysql://112.112.10.127:3060/yangyang8848?useUnicode=true&characterEncoding=utf-8"  --username root  --password yangyang8848 --table yangyang8848  -hcatalog-database yangyang8848 --hcatalog-table yangyang8848

 然后通过命令执行sh文件,可能需要sh文件提权,然后才能执行!