zoukankan      html  css  js  c++  java
  • Sqoop 导入及导出表数据子集命令详解

    Sqoop命令详解

           1、import命令

    案例1:将mysql表test中的数据导入hive的hivetest表,hive的hivetest表不存在。

          


    sqoop import --connect jdbc:mysql://hadoop-001:3306/test --username root --password 123456 --table my_user --hive-table hivetest --hive-import -m 1


     

    案例2在案例1的基础上,分别进行overwrite(覆盖)导入和into(直接加入)导入。  

           into: 命令同案例1   


      overwrite:

                  sqoop import --connect jdbc:mysql://hadoop-001:3306/test --username root --password 123456 --table test --hive-table hivetest --hive-import -m 1 --hive-overwrite


     

    案例3:在案例2的基础上,通过增加mysql的test表数据,增量导入到hive表中。


        sqoop import --connect jdbc:mysql://hadoop-001:3306/test --username root --password 123456 --table test --where "id>9" --hive-table hivetest --hive-import -m 1

           或者

           sqoop import --connect jdbc:mysql://hadoop-001:3306/test --username root --password 123456 --table test --query "select id,name from test where id>9" --hive-table hivetest --hive-import -m 1


     

    案例4:将test表中的数据导出到使用','分割字段的hive表(hivetest2)中。


        创建表: create table hivetest2(id int,name string) row format delimited fields terminated by ',';

           sqoop:

                  sqoop import --connect jdbc:mysql://hadoop-001:3306/test --username root --password 123456 --table test --hive-table hivetest2 --hive-import -m 1 --fields-terminated-by ","


     

    案例5将PARTITIONS表的数据导入到hdfs中。

        


       sqoop import --connect jdbc:mysql://hadoop-001:3306/metastore --username root --password 123456 --table  PARTITIONS --target-dir /wordcount -m 1


    可以看到hdfs有生成文件

    cat一下

    案例6在案例5的基础上,增量导入数据到hdfs中。

         


      sqoop import --connect jdbc:mysql://hadoop-001:3306/test --username root --password 123456 --table test --target-dir /test -m 1 --check-column id --incremental append --last-value 11


     

           2、export命令

    案例1:将hdfs上的文件导出到关系型数据库test2表中。

          


    ./sqoop export --connect jdbc:mysql://hadoop-001:3306/test --username root --password 123456 --table tb_dept --export-dir /test/dept.txt


     

    案例2将hive表(hivetest)数据导出到关系型数据库test2表中(使用insertOrUpdate方法导入)。

           hivetest表只留id为1,2,3,4,5的数据,其他数据删除。

           hivetest表分隔方式是'u0001',但是export命令默认使用','分隔数据

          


    sqoop export --connect jdbc:mysql://hadoop-001:3306/test --username root --password hive --table test2 --export-dir /hive/hivetest --input-fields-terminated-by "\01" --update-mode

    allowinsert --update-key id 


      3.其他命令

    list-databases命令


    sqoop list-databases --connect jdbc:mysql://hadoop-001:3306 --username root --password 123456


    list-tables


    sqoop list-tables --connect jdbc:mysql://hadoop-001:3306/default --username root --password 123456


    create-hive-table命令


    sqoop create-hive-table --connect jdbc:mysql://hadoop-001:3306/test --username root --password 123456--table test --hive-table hivetest


     help命令


    1. sqoop help
    2. sqoop help list-tables


     

  • 相关阅读:
    一文让你明白Redis持久化
    spring-data-redis 2.0 的使用
    中间自适应布局的5种解法
    php实现只需要一个QQ号就可以获得用户信息
    基于LINUX下的进程管理问题
    【初码干货】记一次分布式B站爬虫任务系统的完整设计和实施
    初码-爬虫系列-文章目录
    初码-阿里云系列-文章目录
    初码-Azure系列-存储队列的使用与一个Azure小工具(蓝天助手)
    初码-Azure系列-记一次MySQL数据库向Azure的迁移
  • 原文地址:https://www.cnblogs.com/Transkai/p/10556255.html
Copyright © 2011-2022 走看看