1、確定Mysql服務(wù)開啟正常

[victor@node1 ~]$ service mysql status
Redirecting to /bin/systemctl status  mysql.service
● mysqld.service - MySQL Community Server
   Loaded: loaded (/usr/lib/systemd/system/mysqld.service; enabled; vendor preset: disabled)
   Active: active (running) since Tue 201*-03-27 12:00:00 CST; 21s ago
  Process: 2386 ExecStartPost=/usr/bin/mysql-systemd-start post (code=exited, status=0/SUCCESS)
  Process: 981 ExecStartPre=/usr/bin/mysql-systemd-start pre (code=exited, status=0/SUCCESS)
 Main PID: 2385 (mysqld_safe)
   CGroup: /system.slice/mysqld.service
           ├─2385 /bin/sh /usr/bin/mysqld_safe --basedir=/usr
           └─2578 /usr/sbin/mysqld --basedir=/usr --datadir=/var/lib/mysql --plugin-dir=/usr/lib64/mysql/plugin 
--log-error=/var/log/mysqld.log --pid-file=/var/run/mysqld/mysqld.pid --socket=/va.

2贩挣、在Mysql中新建一張表并插入一些數(shù)據(jù)

[victor@node1 ~]$ mysql -uroot –p000000
mysql> create database company;
mysql> use company;
mysql> create table company.staff(id int(4) primary key not null auto_increment, name varchar(255), 
sex varchar(255));
mysql> insert into company.staff(name, sex) values('Thomas', 'Male');
mysql> insert into company.staff(name, sex) values('Catalina', 'FeMale');

3喉前、全部導(dǎo)入

[victor@node1 sqoop-1.4.7]$ bin/sqoop import \
--connect jdbc:mysql://node1:3306/company?characterEncoding=UTF-8 \
--username root \
--password 000000 \     ## -P  大寫P 是用暗文密碼
--table staff \
--target-dir /user/company \      ##/user/company  目錄不能存在，會自動創(chuàng)建
--delete-target-dir \             ##執(zhí)行之前王财，先刪除這個/user/company目錄
--num-mappers 1 \
--fields-terminated-by "\t"      ##每個字段用什么分割卵迂，mysql默認(rèn)是用逗號分割

#csv文件是用逗號分割的文件
#tsv是用制表符tab分割的文件

4、查詢導(dǎo)入

[victor@node1 sqoop-1.4.7]$ bin/sqoop import \
--connect jdbc:mysql://node1:3306/company \
--username root \
--password 000000 \
--target-dir /user/company \
--delete-target-dir \
--num-mappers 1 \
--fields-terminated-by "\t" \
--query 'select name,sex from staff where id <=1 and $CONDITIONS;'

#尖叫提示：如果query后使用的是雙引號绒净，則$CONDITIONS前必須加轉(zhuǎn)移符见咒，防止shell識別為自己的變量。

5挂疆、導(dǎo)入指定列

[victor@node1 sqoop-1.4.7]$ bin/sqoop import \
--connect jdbc:mysql://node1:3306/company \
--username root \
--password 000000 \
--target-dir /user/company \
--delete-target-dir \
--num-mappers 1 \
--fields-terminated-by "\t" \
--columns id,sex \
--table staff

#尖叫提示：columns中如果涉及到多列改览，用逗號分隔，分隔時不要添加空格, --num-mappers 2缤言，設(shè)置為2宝当，在hdfs會生成2個文件

6、使用sqoop關(guān)鍵字篩選查詢導(dǎo)入數(shù)據(jù)

[victor@node1 sqoop-1.4.7]$ bin/sqoop import \
--connect jdbc:mysql://node1:3306/company \
--username root \
--password 000000 \
--target-dir /user/company \
--delete-target-dir \
--num-mappers 1 \
--fields-terminated-by "\t" \
--table staff \
--where "id=1"

尖叫提示：在Sqoop中可以使用sqoop import -D property.name=property.value這樣的方式加入執(zhí)行任務(wù)的參數(shù)胆萧，多個參數(shù)用空格隔開庆揩。