sqoop匯出指令碼

#!/bin/bash

if [ $1 ];
then
export hive_db_name=$1
else
echo 「請指定要匯出的源資料庫」
exit 1
fiif [ $2 ];
then
export hive_t_name=$2
else
echo 「請指定要匯出的源表名」
exit 1
fiif [ $3 ];
then
export mysql_db_name=$3
else
echo 「請指定目標資料庫」
exit 1
fiecho "這是乙個通用的資料匯出指令碼...,手動建立目標表並保持和源表同名"
export_data() ?useunicode=true&characterencoding=utf-8" \
--username root \
--password ****** \
--table $1 \
--export-dir /warehouse/$hive_db_name/ads/$1 \
--input-fields-terminated-by "\t" \
--update-mode allowinsert \
--update-key $2 \
--input-null-string '\\n' \
--input-null-non-string '\\n'
}export_data "$hive_t_name" "dt"

sqoop匯出指令碼

sqoop匯出指令碼 bin sh source exitcodecheck.sh opts getparam incstart getparam inc start incend getparam inc end pg connection getparam jdbc str pg usernam...

sqoop匯入匯出

sqoop官方手冊位址 最近在看sqoop有些感想，就寫下來。sqoop是大資料裡面匯入匯出的乙個工具。關於import匯出 可以從mysql匯出到hdfs,hbase,hive,案例如下，這是乙個匯出到hdfs的案例 import connect jdbc mysql username root ...

sqoop匯入 匯出

全部匯入 sqoop import connect jdbc mysql hadoop01 3306 test1 username root password 1234 table students target dir user test1 delete target dir fields ter...