将hive表导出到mysql中

1,ZhangSan
2,LiSi
3,LaoWang
4,ZhaoLiu
5,QianQi

# 执行hive命令进入hive终端
hive
# 以下命令是在 hive 终端中执行的
# 创建名为 hive 的数据库
hive> create database hive;
# 切换当前使用的数据库为 hive 库
hive> use hive;
# 创建表 test1，其中第二行代码代表数据字段用 `,` 逗号分隔，第三行代码代表数据用换行符分隔
hive> CREATE TABLE test1 (id INT, name STRING)
    > ROW FORMAT DELIMITED FIELDS TERMINATED BY ','
    > LINES TERMINATED BY '\n';
# 导入文本文件到 test1 表中, 此处数据源参数我使用的是绝对路径
hive> LOAD DATA LOCAL INPATH '/home/master/testdata/test1.txt' INTO TABLE test1;
# 查询数据，看是否导入成功
hive> select * from test1;

# 进入mysql
mysql -u hive -p
# 创建库
mysql> create database hive;
# 创建表
mysql> CREATE TABLE test1 (
     > id INT,
     > name VARCHAR(255)
     > );

# 注意执行 sqoop 命令的路径，我这里是添加了 bin 目录的
bin/sqoop export \
--connect jdbc:mysql://localhost:3306/hive \
--username root \
--password 111111 \
--table test1 \
--export-dir /user/hive/warehouse/hive.db/test1 \
# 指定导出的 test1 中字段顺序
--columns "id,name" \
--input-fields-terminated-by '\t' \
--input-lines-terminated-by '\n' \
--input-null-string '\\N' \
--input-null-non-string '\\N' \
# 后面两个参数可以不写
-m 1 \
--direct

use hive;

CREATE TABLE result (
id INT,
name VARCHAR(255),
count INT
);

bin/sqoop export \
--connect jdbc:mysql://localhost:3306/hive \
--username root \
--password 111111 \
--table result \
--export-dir /user/hive/warehouse/hive.db/result \
--columns "id,name,count" \
--input-fields-terminated-by ',' \
--input-lines-terminated-by '\n' \
--input-null-string '\\N' \
--input-null-non-string '\\N'

# 切换数据库
use mysql;
# 修改权限
update user set host = '%' where user = 'root';
# 检查
select host,user from user;

bin/sqoop import \
--connect jdbc:mysql://slave2:3306/hive \
--username hive \
--password 111111 \
--table test1 \
# 指定数据分隔的字段
--split-by id \
--hive-import \
--hive-table hive.test1