使用sqlload导文本数据到oracle中想必很多人多使用过,但是倘若有几百或者几千个数据文本,或者实时有文本数据产生。这种场景如何批量导入oracle呢,下面就来讲解下我处理的方式。
1.shell脚本LoadData.sh如下
#!/bin/bash
data_dir=/home/bea/datasource/warn-log/dayflow # 文本数据目录
data_dir_bak=/home/bea/datasource/warn-log/dayflow_bak
shell_dir=/home/bea/script
while [ 1 ]
do
cd $data_dir
if [ `pwd` == $data_dir ]
then
filelist=`ls -rt | grep dayflow.log_.` #数据文本文件名匹配
fi
#echo $filelist
cd $shell_dir
if [ `pwd` == $shell_dir ]
then
for file in $filelist
do
date=`date "+%Y%m%d %H:%M:%S"`
export LoadFileName=$data_dir"/"$file #这个地方很重要,要加载变量到环境中
echo "Time is $date ,开始导$LoadFileName数据"
sqlldr user_1/123456@213_db control=dayflow.log.ctl BAD=dayflow.log.bad
echo "Time is $date ,$LoadFileName数据导入完毕"
echo "开始备份文件$file"
mv $LoadFileName $data_dir_bak
echo "$file备份完毕"
done
fi
done
export LoadFileName=$data_dir"/"$file
这里将LoadFileName (导入oracle 的文本,绝对路径)这个变量 export到linux环境中,这样sqlload的控制文件就可以读到这个变量并进行导入
2.sqlldr控制文本dayflow.log.ctl
load data
CHARACTERSET AL32UTF8
infile '$LoadFileName'
APPEND into table user_1.BIL_FLUX_HIGH_CUR
fields terminated by '|'
trailing nullcols
(ACCS_NBR "TRIM(:ACCS_NBR)",
DATE_ID "TRIM(:DATE_ID)",
TOTAL_FLUX "TRIM(:TOTAL_FLUX)",
sys_date "sysdate")
请注意 infile '$LoadFileName',这里就是shell中 刚才export的变量,通过这种方式就可以以变量的形式传入文件名,那么批量导入也就是一个循环的操作。
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。