sqoop命令總結

解析:

--hive-delims-replacement 這個是為了防止mysql欄位的值有換行符,

--hive-delims-replacement ''可以替換換行符換成空字串

/opt/cloudera/parcels/cdh-5.12.1-1.cdh5.12.1.p0.3/lib/sqoop/bin/sqoop import \

--connect jdbc:mysql://
mysql_ip:3306/mysql_database \
--username root \
--password mysql_pwd \
--table mysql_table \
--fields-terminated-by '
\001'\
--lines-terminated-by '\n'
\--hive-import \
--hive-overwrite \
--hive-database hive_database \
--hive-table hive_table \
--hive-delims-replacement ''
\--delete-target-dir -m 1
解析:

--hive-delims-replacement 這個是為了防止mysql欄位的值有換行符,

--hive-delims-replacement ''可以替換換行符換成空字串

/opt/cloudera/parcels/cdh-5.12.1-1.cdh5.12.1.p0.3/lib/sqoop/bin/sqoop export \

--connect jdbc:mysql://
mysql_ip:3306/mysql_database \
--username root \
--password mysql_pwd
\--table mysql_table \
\--export-dir /data/hive/warehouse/xzs.db/
hive_table \
--input-fields-terminated-by  '
\001
'

/opt/cloudera/parcels/cdh-5.12.1-1.cdh5.12.1.p0.3/lib/sqoop/bin/sqoop eval \

--connect jdbc:mysql://
mysql_ip:3306/mysql_database \
--username root \
--password mysql_pwd
\--query "
truncate table mysql_table;
"

sqoop命令總結

解析 hive delims replacement 這個是為了防止mysql欄位的值有換行符,hive delims replacement 可以替換換行符換成空字串 opt cloudera parcels cdh 5.12.1 1.cdh5.12.1.p0.3 lib sqoop bin sq...

Sqoop 常用命令總結

sqoop幫助匯入 用法 sqoop import generic args tool args 共同論點 connect 指定jdbc連線字串 connect manager 指定要使用的連線管理器類 driver 手動指定要使用的jdbc驅動程式類 hadoop mapred home 覆蓋 h...

Sqoop資料匯入匯出命令總結

1 列出mysql資料庫中的所有資料庫命令 sqoop list databases connect jdbc mysql username root password 123456 2 連線mysql並列出資料庫中的表命令 sqoop list tables connect jdbc mysql ...