针对于上次《GoldenGate 自动化初始数据》过程中，存在的不适合场景，调整脚本，并对脚本进行优化，源端包括ogg_expdp.sh，目标端包括stop_rep.sh和ogg_impdp.sh

 ogg_expdp.sh首先检查ogg抽取进程是否正常，正常则导出数据，否则重置抽取时间，启动抽取进程。

 stop_rep.sh停止rep进程。

 ogg_impdp.sh首先检查rep进程是否运行，运行则退出执行提示先执行stop_rep.sh，未运行则导入数据后启动复制。

stop_rep.sh脚本内容如下:

#!/bin/bash

ggsci=/ogghome/goldengate/ggsci

echo 'kill rep_rep_cs' | $ggsci

if [ $? -ne 0 ]; then

   echo "Stop rep_rep_cs is failed, Please use ggsci check rep_rep_cs status"

else

   echo "Rep_rep_cs has been stop!!! "

fi

ogg_impdp.sh脚本内容如下：

#!/bin/bash

##used for impdp

connect=gaoyc/gaoyc_123

prefile=ogg_gaoyc

diry=expdp_dir

dmp_dir=/orabak/expdp

ggsci=/ogghome/goldengate/ggsci

ogg_dir=/ogghome/goldengate

##check rep_rep_cs status

echo "First check rep_rep_cs is running......"

rep_stats=`echo 'status rep_rep_cs' | $ggsci | grep REP_TZDB | awk -F ':' {'print $2'} |grep -o "[^ ]\+\+[]\+\+[]\+*"`

echo "rep_rep_cs status is : $rep_stats"

function exit_script()

{

    exit 1

}

if [ "$rep_stats" == "RUNNING" ]; then

      echo "rep_rep_cs is running, Please stop rep_rep_cs, then expdp "

      echo "Please execute stop_ogg.sh,ogg_expdp.sh first"

      exit_script

else

        echo "rep_status was stoped, continue"

fi

echo "Drop tables "

sqlplus -s / as sysdba<<EOF

truncate table gaoyc.t1;

truncate table gaoyc.t2;

......

truncate table gaoyc.ogg_test;

exit

EOF

if [ $? -eq 0 ]; then

   echo "tables has been droped"

else

   echo "exit scripts, please check error"

   exit_script

fi

echo "Begin import talbes"

cd $dmp_dir

csn=`cat $prefile.log | grep  -i flashback_s | awk -F '=' {'print $5'} | awk {'print $1'}`

echo "scn: $csn"

impdp $connect directory=$diry dumpfile=$prefile.dmp logfile=$prefile_imp.log INCLUDE=TABLE_DATA

if [ $? -eq 0 ]; then

          echo "tables has been imported"

        else

          echo "tables failed to import"

          exit_script

        fi

rm $prefile*

cd $ogg_dir

commd="start rep_rep_cs,  ATCSN $csn"

echo $commd

echo $commd | $ggsci

ogg_expdp.sh脚本内容如下：

#!/bin/bash

# Used for expdp and ftp

BACKUPDIRECTORY=/orabak/expdp

REMOTE_DIR=/orabak/expdp

connect=gaoyc/Gaoyc_123

prefile=ogg_gaoyc

diry=expdp_dir

ggsci=/ogghome/goldengate/ggsci

#used for check ext_cs and restart ext_cs

echo "First check ext_cs is running??"

ext_stats=`echo 'status ext_cs' | $ggsci | grep EXT_TZDB | awk -F ':' {'print $2'} |grep -o "[^ ]\+\+[]\+\+[]\+*"`

echo $ext_stats

function exit_script()

{

    exit 1

}

function change_ext_cs()

{

   echo "Begin Chhange ext_cs extract time"

   echo 'alter ext_cs, begin now' | $ggsci

   if [ $? -eq 0 ]; then

      echo "Ext_cs has been changed!!!!!!"

   else

      echo "Ext_cs has changed failed, please check info using ggsci"

      exit_script

   fi

   echo 'start ext_cs' | $ggsci

   if [ $? -eq 0 ]; then

      echo "Ext_cs has been started!!!!"

   else

      echo "Ext_Tzdb started failed, Please check info"

      exit_script

   fi

}

if [ "$ext_stats" == "RUNNING" ]; then

        echo 'kill ext_cs' | $ggsci

        if [ $? -eq 0 ]; then

          echo "Ext_cs has been stoped!!!!"

          change_ext_cs

        else

          echo "Ext_cs stop was failed!!!!!!"

          exit_script

        fi

        echo "Ext_staus is running !!!!"

else

        echo "Ext_status is not running!!!!"

        change_ext_cs

fi

###Used for used for expdp tables

echo "Begin expdp tables"

fcn=`sqlplus -S / as sysdba <<EOF 

select  'curnt_scn:'||dbms_flashback.get_system_change_number scn from dual;

 exit

 EOF`

fsn=`echo $fcn | awk -F ':' {'print $2'}`

echo "SCN: $fsn"

expdp $connect directory=$diry dumpfile=$prefile.dmp logfile=$prefile.log flashback_scn=$fsn tables=t1,t2,ogg_test

echo "Expdp has been Successfull!!!"

ftp -n<<EOF

open 192.168.1.61

user oracle oracle

cd $REMOTE_DIR

lcd $BACKUPDIRECTORY

prompt off

bin

mput $prefile*

bye

EOF

echo "Dump is send to   192.168.1.61 "

cd $BACKUPDIRECTORY

rm $prefile*

echo "Dump is deleted"