文章目錄
- @[toc] 目錄:
- 1、簡介
- 2、sqoop安裝
- 2.1、下載并解壓
- 2.2、修改配置文件
- 2.3、加入mysql或oracle的jdbc驅動包
- 2.4、驗證啟動
- 3、Sqoop的原理
- 3.1、代碼定制
目錄:
文章目錄
- @[toc] 目錄:
- 1、簡介
- 2、sqoop安裝
- 2.1、下載并解壓
- 2.2、修改配置文件
- 2.3、加入mysql或oracle的jdbc驅動包
- 2.4、驗證啟動
- 3、Sqoop的原理
- 3.1、代碼定制
1、簡介
sqoop是apache旗下一款“Hadoop和關系數據庫服務器之間傳送數據”的工具。
導入數據:MySQL,Oracle導入數據到Hadoop的HDFS、HIVE、HBASE等數據存儲系統;
導出數據:從Hadoop的文件系統中導出數據到關系數據庫。
2、sqoop安裝
安裝sqoop的前提是已經具備java和hadoop的環境
2.1、下載并解壓
下載地址:http://archive.apache.org/dist/sqoop/
2.2、修改配置文件
$ cd $SQOOP_HOME/conf
$ mv sqoop-env-template.sh sqoop-env.sh
打開sqoop-env.sh并編輯下面幾行:
export HADOOP_COMMON_HOME=/home/hadoop/apps/hadoop-2.6.1/
export HADOOP_MAPRED_HOME=/home/hadoop/apps/hadoop-2.6.1/
export HIVE_HOME=/home/hadoop/apps/hive-1.2.1
2.3、加入mysql或oracle的jdbc驅動包
cp ~/app/hive/lib/mysql-connector-java-5.1.28.jar $SQOOP_HOME/lib/
2.4、驗證啟動
$ cd $SQOOP_HOME/bin
$ sqoop-version
預期的輸出:
15/12/17 14:52:32 INFO sqoop.Sqoop: Running Sqoop version: 1.4.6
Sqoop 1.4.6 git commit id 5b34accaca7de251fc91161733f906af2eddbe83
Compiled by abe on Fri Aug 1 11:19:26 PDT 2015
到這里,整個Sqoop安裝工作完成。
3、Sqoop的原理
Sqoop的原理其實就是將導入導出命令轉化為mapreduce程序來執行,sqoop在接收到命令后,都要生成mapreduce程序。在翻譯出的mapreduce中主要是對inputformat和outputformat進行定制。
使用sqoop的代碼生成工具可以方便查看到sqoop所生成的java代碼,并可在此基礎之上進行深入定制開發。
3.1、代碼定制
以下是Sqoop代碼生成命令的語法:
$ sqoop-codegen (generic-args) (codegen-args)
$ sqoop-codegen (generic-args) (codegen-args)
示例:以USERDB數據庫中的表emp來生成Java代碼為例。
下面的命令用來生成導入
$ sqoop-codegen \
--import
--connect jdbc:mysql://localhost/userdb \
--username root \
--table emp
如果命令成功執行,那么它就會產生如下的輸出。
14/12/23 02:34:40 INFO sqoop.Sqoop: Running Sqoop version: 1.4.5
14/12/23 02:34:41 INFO tool.CodeGenTool: Beginning code generation
……………….
14/12/23 02:34:42 INFO orm.CompilationManager: HADOOP_MAPRED_HOME is /usr/local/hadoop
Note: /tmp/sqoop-hadoop/compile/9a300a1f94899df4a9b10f9935ed9f91/emp.java uses or overrides a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
14/12/23 02:34:47 INFO orm.CompilationManager: Writing jar file: /tmp/sqoop-hadoop/compile/9a300a1f94899df4a9b10f9935ed9f91/emp.jar
驗證: 查看輸出目錄下的文件
$ cd /tmp/sqoop-hadoop/compile/9a300a1f94899df4a9b10f9935ed9f91/
$ ls
emp.class
emp.jar
emp.java
如果想做深入定制導出,則可修改上述代碼文件