首先通过sqoop查看mysql数据库
命令:./sqoop list-databases --connect jdbc:mysql://***.*.:3306/?useSSL=false --username *** --password *******
然后在mysql中创建表
DROP TABLE IF EXISTS `mgmqtest`;
CREATE TABLE `mgmqtest` (
`id` int(10) DEFAULT NULL,
`uid` int(10) DEFAULT NULL,
`title` varchar(100) DEFAULT NULL,
`name` varchar(100) DEFAULT NULL,
`status` int(10) DEFAULT NULL,
`time` timestamp NULL DEFAULT NULL
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
发现我的用户没有插入权限
找一个有数据的表 直接开始抽数据
表名:amount_bk
sqoop运行命令: 期间要走mr的
./sqoop import --connect jdbc:mysql://***.***.**:3306/****?useSSL=false --username **** --password **** --table amount_bk -m 1
查看hdfs上文件:
hdfs dfs -cat /user/root/amount_bk/part-m-00000
版权声明:本文为cz124560原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。