#The program which created by hudaohang making export database scripts
#!/bin/sh
workdir="/test/scripts/test_exp"
expscr_dir="$workdir/scripts"
tmpdir="$workdir/tmp"
tmpfile="$tmpdir/tmpfile.txt"
expfile_dir="$workdir/expfile"
expfile_log="$workdir/explog"
expfile_reflex="oracle_cdr_exp_"
expuser="username/userpassword"
owner_user="tableowner"

if [ $# -ne 1 ]
then 
  echo "Usage: $0 YYYYMMDD-YYYYMMDD"
  echo "Example: $0 20060901-20060920"
  exit 1
fi 
echo $1|awk '{print substr($1,1,6)}'|read exp_month
echo $1|awk '{print substr($1,1,8)}'|read exp_sdate
echo $1|awk '{print substr($1,10,8)}'|read exp_edate

sqlplus oracleuser/user@SERVICE_NAME << !
set ECHO off
set heading off
set pagesize 0
set linesize 1000
set term off
set trims on
set feedback off
spool $tmpfile
select owner||'.'||table_name||',\' from all_tables where owner=upper('$owner_user') and table_name like 'DR%$exp_month%';
spool off
quit
!
while [ "$exp_sdate" -le "$exp_edate" ]
do
expfile=$expfile_reflex$exp_sdate
expscr=$expscr_dir/JSDR_$exp_sdate
echo "exp $expuser file=$expfile_dir/$expfile log=$expfile_log/$expfile.log buffer=100000000 compress=n tables=\\">$expscr
cat $tmpfile|grep "$exp_sdate" >>$expscr
let exp_sdate=exp_sdate+1
done

#Create by hudaohang for exportting and checking CDR automatically 
# ORACLE数据库亿级记录表自动导出及核对
#!/bin/ksh
. /oracle/.profile

# 参数设定
workdir="/test/test_exp"
logfiledir="/test/test_exp/explog"
expfiledir="/test/test_exp/expfile"
scriptdir="/test/test_exp/scripts"
logfile="/test/test_exp/explog.txt"
expfile_reflex="oracle_cdr_exp_"
tmpfiledir="/test/test_exp/tmp"
ip="XXX.XXX.XXX.XXX"
typeset -i i
typeset -i Date
typeset -i limit=31
typeset -i process=2

# 取上月最后一天函数
get_lastday_of_lastmonth()
{
year=`date +%Y`
month=`date +%m-1|bc`
[ $month -lt 1 ] && month=12;year=`expr $year - 1`
getlastmonth=`cal $month $year`
lastday=`echo $getlastmonth|awk '{print $NF}'`
}

# 取SQL脚本函数
ftp_tool()
{
ftp -i -n $ip << GET_SCRIPT
user wbass wbass
cd /test/scripts/test_exp/scripts
lcd $scriptdir
get JSDR_$1
bye
GET_SCRIPT
}

ls -l $logfiledir|grep $expfile_reflex|awk '{print substr($9,24,8)}'|sort +0 -nr|head -1|read Date #从导出日志中获取最新日表日期
ls -l $expfiledir|grep dmp|wc -l|read i 
get_lastday_of_lastmonth
if [ "$i" -lt "$lastday" ] #获取备份目录下详单文件个数不能超过limit个
  then
    let Date=Date+1 
    echo $Date|awk '{print substr($1,1,4),substr($1,5,2),substr($1,7,2)}'|read yy mm dd
    let dd=dd+30-30
    cal $mm $yy|grep $dd|grep -v $yy|wc -l|read border
    if [ "$border" -eq "0" ] #跨月判断
      then
      let mm=mm+1
      let dd=dd-dd+1
      if [ "$mm" -eq "13" ] #跨年判断
        then
          let mm=mm-mm+1
          let Date=yy*10000+10000+mm*100+dd        
        else
          let Date=yy*10000+mm*100+dd
      fi  
    fi
    ftp_tool $Date
    nohup ksh $scriptdir/JSDR_$Date >> $tmpfiledir/nohup_$Date 2>&1 &
  else #备份目录下达到limit个文件进行核对
    more $logfile|grep $(date +"%Y/%m/%d")|wc -l|read record #判断是否已经写过日志时间
    if [ "$record" -eq "0" ]
    then
      echo ================ >> $logfile
      date +"%Y/%m/%d %R"   >> $logfile  
      echo ================ >> $logfile
      echo [Export Name]"    "[Export Size]"    "[Backup Size]"    "[Size Compare] >> $logfile
    fi
    ls -l $expfiledir|grep dmp|awk '{print substr($9,24,8)}'|sort +0 -nr|while read cdrdate #判断导出详单的最新日期
    do
      ps -ef|grep exp|grep -v grep|awk 'BEGIN{FS=" "};{print substr($10,54,8)}'|grep $cdrdate|wc -l|read sts #判断状态，该文件是否正在写入
      if [ "$sts" -ne "0" ]
        then echo Exportting the $cdrdate.dmp haven not been finished ..."    "[$(date +"%m/%d %R")] >> $logfile
        else
          tail -1 $logfiledir/jxwbass_oracle_cdr_exp_$cdrdate.log|awk '{print substr($3,1,14)}'|read flag #从导出日志获取详单导出是否成功
          if [[ $flag != successfully ]] #该日表导出不成功，重新执行导出程序
            then       
              ps -ef|awk 'BEGIN{FS=" "}grep $8~/^exp$/'|wc -l|read howmany #判断进程中是否有2个以上的日表导出程序，超过2个放弃执行
              if [ "$howmany" -lt "$process" ]
                then
                  echo Exportting the $cdrdate.dmp failure! REExproting ..."    "[$(date +"%m/%d %R")] >> $logfile
                  nohup ksh $scriptdir/JSDR_$cdrdate >> $tmpfiledir/nohup_$Date 2>&1 & 
                else
                  echo Waitting the next time to REExport ..."    "[$(date +"%m/%d %R")] >> $logfile
              fi
            else
              more $logfile|grep $cdrdate|grep "Backup Successfully"|wc -l|read jump
              if [ "$jump" -eq "0" ] #判断是否已经核对成功，并写人日志
                then
                  ls -l $expfiledir/jxwbass_oracle_cdr_exp_$cdrdate.dmp|awk '{print $5}'|read exp_size
                  bplist -C WBASS_2 -S STOR_MAM -l -s 03/21/2008 -e 12/12/2008 -R $expfiledir|grep "$cdrdate.dmp"|grep "K"|head -1|awk '{printf "%d\n",substr($4,1,8)*1024}'|read imp_size #磁带上可能存在2个以上同日表文件拷贝，取最新导入的文件
                  if [ "$imp_size" -eq "$exp_size" ] #判断导入，导出日表文件的大小是否一致
                    then 
                      tag="Backup Successfully"   
                      nohup rm $expfiledir"/jxwbass_oracle_cdr_exp_"$cdrdate".dmp" &
                    else tag="Backup Abort"
                  fi
                  echo $cdrdate.dmp"    "$exp_size"    "$imp_size"    "$tag >> $logfile
              fi
          fi
      fi
    done
    echo >> $logfile
fi