本文主要是介绍利用 Sqoop 对关系型数据库 与 非关系型数据库,分布式等数据库之间进行数据迁移,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
基本流程图如下:
命令如下:
Mysql导入Hive
1
1.1.表不存在则创建,并且加了where条件
sqoop import --connect jdbc:mysql://ip:port/db_name --username user_name --password password -m 4 --table mysql_table_name --hive-import --hive-table hive_db.hive_table --create-hive-table --where dt='20181201'
2.Oracle导入HIve
将用sqoop导入Oracle数据到HDFS
./sqoop import --connect jdbc:oracle:thin:@192.168.146.128:1521:orcal -- username scoot --passwd tiger --table emp --columns 'empno, ename, job, sal, deptno' -m 1 --target -dir '/sqoop/emp'使用sqoop导入oracle数据到hive中,
./sqoop import --hive-import --connect jdbc:oracle:thin@192.168.146.128:1521:orcl --username scott --password t
这篇关于利用 Sqoop 对关系型数据库 与 非关系型数据库,分布式等数据库之间进行数据迁移的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!