zoukankan      html  css  js  c++  java
  • sqoop应用

    1.导入数据(将mysql(rdbms)的表的数据导入到hdfs)

    1.1.全部导入(注意空格)

    sqoop import 
    --connect jdbc:mysql://192.168.159.110:3306/stu    (stu数据库名称 写自己的ip)
    --username root 
    --password 123456 
    --table students 
    --target-dir /user/test3    (导入到hdfs位置,会自动创建,如果存在,会自动删除在创建)
    --delete-target-dir 
    --m 1 
    --fields-terminated-by "	";  (分割符)

    1.2.查询导入

    sqoop import 
    --connect jdbc:mysql://192.168.159.110:3306/stu 
    --username root 
    --password 123456 
    --target-dir /user/test4 
    --delete-target-dir 
    --m 1 
    --fields-terminated-by "	" 
    --query 'select id,name from students where id <=1 and $CONDITIONS';

    注意:sql语句的末尾必须加上$CONDITIONS

    1.3.导入指定的列

    sqoop import 
    --connect jdbc:mysql://hadoop01:3306/stu  (既可以写名称也可以写ip)
    --username root 
    --password 123456 
    --target-dir /user/test5 
    --delete-target-dir 
    --m 1 
    --fields-terminated-by "	" 
    --columns id 
    --table students;

    提示::columns中如果涉及到多列时,用逗号分割,分割时不要添加空格

    1.4.使用sqoop关键字筛选查询导入数据

    sqoop import 
    --connect jdbc:mysql://hadoop01:3306/stu 
    --username root 
    --password 123456 
    --target-dir /user/test6 
    --delete-target-dir 
    --m 1 
    --fields-terminated-by "	" 
    -table students 
    --where "id=2";
  • 相关阅读:
    web前端之 CSS
    web前端之 HTML标签详细介绍
    web前端之 HTML介绍
    c++之 scanf 接收用户输入内容
    JQ 全选、全不选
    java 除法向上,向下取整
    Java使用占位符拼接字符串
    eclipse远程debug
    阿里 drds 分布式数据库分节点查询
    Mysql 修改字段长度、修改列名、新增列、修改自增主键起始值
  • 原文地址:https://www.cnblogs.com/wangshuang123/p/10986791.html
Copyright © 2011-2022 走看看