设为首页 收藏本站
查看: 743|回复: 0

[经验分享] Using Sqoop2 to import mysql data to HDFS

[复制链接]

尚未签到

发表于 2018-10-1 11:52:11 | 显示全部楼层 |阅读模式
  On Sqoop2 server:
  MySQL JDBC Driver:
  cp mysql-connector-java-5.1.33/mysql-connector-java-5.1.33-bin.jar /var/lib/sqoop2/mysql-connector-java.jar
  Oracle JDBC Driver:
  cp ojdbc6.jar /var/lib/sqoop2/oracle-connector-java.jar
  Microsoft SQL Server JDBC Driver:
  cp sqljdbc_4.0/enu/sqljdbc4.jar /var/lib/sqoop2/
  cd /var/lib/sqoop2
  chown sqoop2:sqoop2 mysql-connector-java.jar oracle-connector-java.jar sqljdbc4.jar
  chmod 755 mysql-connector-java.jar oracle-connector-java.jar sqljdbc4.jar
  restart sqoop2 service
  On Sqoop2 client:
  MySQL JDBC Driver:
  cp mysql-connector-java-5.1.33/mysql-connector-java-5.1.33-bin.jar /var/lib/sqoop2/mysql-connector-java.jar
  Oracle JDBC Driver:
  cp ojdbc6.jar /var/lib/sqoop2/oracle-connector-java.jar
  Microsoft SQL Server JDBC Driver:
  cp sqljdbc_4.0/enu/sqljdbc4.jar /var/lib/sqoop2/
  cd /var/lib/sqoop2
  chown sqoop2:sqoop2 mysql-connector-java.jar oracle-connector-java.jar sqljdbc4.jar
  chmod 755 mysql-connector-java.jar oracle-connector-java.jar sqljdbc4.jar
  (
  For using Sqoop 1 client, you should add sqoop 1 client  service to client node as gateway role, then put JDBC Driver to /var/lib/sqoop
  MySQL JDBC Driver:
  cp mysql-connector-java-5.1.33/mysql-connector-java-5.1.33-bin.jar /var/lib/sqoop/mysql-connector-java.jar
  Oracle JDBC Driver:
  cp ojdbc6.jar /var/lib/sqoop/oracle-connector-java.jar
  Microsoft SQL Server JDBC Driver:
  cp sqljdbc_4.0/enu/sqljdbc4.jar /var/lib/sqoop/
  cd /var/lib/sqoop
  chown sqoop:sqoop mysql-connector-java.jar oracle-connector-java.jar sqljdbc4.jar
  chmod 755 mysql-connector-java.jar oracle-connector-java.jar sqljdbc4.jar
  sudo -u hdfs hadoop fs -mkdir /user/sqoop
  sudo -u hdfs hadoop fs -chown sqoop:sqoop /user/sqoop
  sqoop list-databases --connect jdbc:mysql://mysql-server-ip --username username --password
  sqoop list-tables --connect jdbc:mysql://mysql-server-ip/databasename --username username --password
  )
  sqoop2 (you can also use HUE web UI > sqoop transfer)
  sqoop:000> set server --host sqoop2-server-ip
  sqoop:000> show connector --all
  sqoop:000> create connection --cid 1

  Creating connection for connector with>  Please fill following values to create new connection object
  Name: mysql-conection
  Connection configuration

  JDBC Driver>  JDBC Connection String: jdbc:mysql://remote-mysql-server/dbname
  Username: username
  Password: *******
  JDBC Connection Properties:
  There are currently 0 values in the map:
  entry#

  Security>  Max connections: 10

  New connection was successfully created with validation status FINE and persistent>  sqoop:000> create job --xid 1 --type import

  Creating job for connection with>  Please fill following values to create new job object
  Name: export-job1
  Database configuration
  Schema name: dbname
  Table name: tablename
  Table SQL statement:
  Table column names:
  Partition column name:
  Nulls in partition column:
  Boundary query:
  Output configuration
  Storage type:
  0 : HDFS
  Choose: 0
  Output format:
  0 : TEXT_FILE
  1 : SEQUENCE_FILE
  Choose: 0
  Compression format:
  0 : NONE
  1 : DEFAULT
  2 : DEFLATE
  3 : GZIP
  4 : BZIP2
  5 : LZO
  6 : LZ4
  7 : SNAPPY
  Choose: 0
  Output directory: /user/sqoop2/output
  Throttling resources
  Extractors:
  Loaders:

  New job was successfully created with validation status FINE  and persistent>  sqoop:000> start job --jid 1
  sqoop:000> status job --jid 1

  JDBC Driver>  JDBC Connection String: jdbc:mysql://remote-mysql-server/dbname

  JDBC Driver>  JDBC Connection String: jdbc:sqlserver://remote-mysql-server/dbname

  JDBC Driver>  JDBC Connection String:


运维网声明 1、欢迎大家加入本站运维交流群:群②:261659950 群⑤:202807635 群⑦870801961 群⑧679858003
2、本站所有主题由该帖子作者发表,该帖子作者与运维网享有帖子相关版权
3、所有作品的著作权均归原作者享有,请您和我们一样尊重他人的著作权等合法权益。如果您对作品感到满意,请购买正版
4、禁止制作、复制、发布和传播具有反动、淫秽、色情、暴力、凶杀等内容的信息,一经发现立即删除。若您因此触犯法律,一切后果自负,我们对此不承担任何责任
5、所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其内容的准确性、可靠性、正当性、安全性、合法性等负责,亦不承担任何法律责任
6、所有作品仅供您个人学习、研究或欣赏,不得用于商业或者其他用途,否则,一切后果均由您自己承担,我们对此不承担任何法律责任
7、如涉及侵犯版权等问题,请您及时通知我们,我们将立即采取措施予以解决
8、联系人Email:admin@iyunv.com 网址:www.yunweiku.com

所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其承担任何法律责任,如涉及侵犯版权等问题,请您及时通知我们,我们将立即处理,联系人Email:kefu@iyunv.com,QQ:1061981298 本贴地址:https://www.yunweiku.com/thread-607098-1-1.html 上篇帖子: 清理 zabbix 历史数据, 缩减 mysql 空间 下篇帖子: MySQL之 index merge 走错索引案例
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

扫码加入运维网微信交流群X

扫码加入运维网微信交流群

扫描二维码加入运维网微信交流群,最新一手资源尽在官方微信交流群!快快加入我们吧...

扫描微信二维码查看详情

客服E-mail:kefu@iyunv.com 客服QQ:1061981298


QQ群⑦:运维网交流群⑦ QQ群⑧:运维网交流群⑧ k8s群:运维网kubernetes交流群


提醒:禁止发布任何违反国家法律、法规的言论与图片等内容;本站内容均来自个人观点与网络等信息,非本站认同之观点.


本站大部分资源是网友从网上搜集分享而来,其版权均归原作者及其网站所有,我们尊重他人的合法权益,如有内容侵犯您的合法权益,请及时与我们联系进行核实删除!



合作伙伴: 青云cloud

快速回复 返回顶部 返回列表