测试sqoop从mysql到hive的导入导出

从mysql导出表customers到hive，并重命名表名为cust，分割符指定为'\t'

#sqoop import --connect jdbc:mysql://localhost/dualcore  \

--username root --table customers \

--hive-import  --warehouse-dir /user/hive/warehouse --hive-table  cust \

--fields-terminated-by '\t'

在mysql中建表cust

mysql>create table dualcore.cust as select * from dualcore.customers;
从hdfs指定目录导出表并插入到mysql数据库dualcore

# sqoop export --connect jdbc:mysql://localhost/dualcore  \

 --username root --export-dir /user/hive/warehouse/cust --table cust  \

 --fields-terminated-by '\t'

 

 查看cust表行数，确认同原表一致

 mysql> select count(*) from cust;