文件名: skiptrans.sh skip.sh

所在路径:$HOME/ggscript/ggtrandata

功能:该脚本用于重启抽取进程时跳过长事务,可自动识别1小时以上的长事务并批量跳过,skiptrans.sh通过edit脚本选择调用,skip.sh用于在其他脚本中调用用,例如allstop.shgoldengate进程停止脚本

Ps:目前该脚本目前仅适用于AIXLINUX系统 

skiptrans.sh

#!/bin/bash
#时间转换为秒的函数,参考某位大神的脚本
function date2seconds {echo "$*" | awk '{z=int((14-$2)/12); y=$1+4800-z; m=$2+12*z-3;j=int((153*m+2)/5)+$3+y*365+int(y/4)-int(y/100)+int(y/400)-2472633;j=j*86400+$4*3600+$5*60+$6print j}'
}cd $HOME/ggscript/ggtrandata
echo $login
echo $dirdir=$PWD 
echo $dir
cd $HOME/ggserver
#输入需要跳过长事务的进程名
echo "searching the Extract name......"
(echo info all;echo exit)|./ggsci|grep "EXTRACT" |awk 'BEGIN {FS=" +"} {print $3}'|grep  '^E'
read -p "Please enter the extract name:" extract#获取2个线程的showtrans长事务
echo "loading the trans data.....please wait....."
(echo send $extract showtrans thread 1;echo exit)|./ggsci > $dir/thread1
echo "Thread 1 data load compete"
(echo send $extract showtrans thread 2;echo exit)|./ggsci > $dir/thread2
echo "Thread 2 data load compete"cd $dir#将长事务信息分割为时间与trans编号两部分
cat thread1|awk 'BEGIN{}{FS=" "} /^XID:/{print $2}'|sed  -e '/^$/d' > xid1
cat thread1|awk -F 'Time:           ' '{print $2}'|sed  -e '/^$/d' > time1
paste time1 xid1 > trandata
cat thread2|awk 'BEGIN{}{FS=" "} /^XID:/{print $2}'|sed  -e '/^$/d' > xid2
cat thread2|awk -F 'Time:           ' '{print $2}'|sed  -e '/^$/d' > time2
paste time2 xid2 > trandata2cat trandata2 >> trandata#通过函数转换时间,并排除掉一小时以内的长事务
sydate=`date +"%Y-%m-%d:%H:%M:%S"`
echo $HSYSTIME
date2seconds `echo $sydate | sed 's/-/ /g;s/:/ /g'` > secondssys
HSYSTIME=`cat secondssys`
echo $HSYSTIME
rm -f secondssys
#date2seconds `echo $sydate | sed 's/-/ /g;s/:/ /g'`NUX=`sed -n '$=' trandata`i=1
cat /dev/null > trains
while(($i<=$NUX));  dostr=`sed -n "${i}p"  trandata |awk '{print $1}'`
echo $str
date2seconds `echo $str | sed 's/-/ /g;s/:/ /g'` > secondssys
HGTI=`cat secondssys`
rm -f secondssys
echo $HGTI
echo $HSYSTIME
POOR=`expr $HSYSTIME - 3600`
echo $POOR
echo "--------------------"
if [ "$HGTI" -le "$POOR" ]thensed -n "${i}p"  trandata |awk '{print $2}' >> trains
fii=`expr $i + 1`done
#将一小时以前的长事务组合成skiptrans指令,并通过obey指令批量执行
sed 's/^/send '$extract' skiptrans /' trains > trains1
sed 's/$/ force/' trains1 > skiptrains cd $HOME/ggservercat $HOME/ggscript/ggtrandata/skiptrains > dirdat/skiptrainsecho   OBEY dirdat/skiptrains |./ggsci


skip.sh

#!/bin/bash
echo $dir
cd $HOME/ggscript/ggtrandata
dir=$PWD
cd $HOME
if [ -f .profile ];then. .profile
fiif [ -f .bash_profile ];then . .bash_profile
ficd $dirfunction date2seconds {echo "$*" | awk '{z=int((14-$2)/12); y=$1+4800-z; m=$2+12*z-3;j=int((153*m+2)/5)+$3+y*365+int(y/4)-int(y/100)+int(y/400)-2472633;j=j*86400+$4*3600+$5*60+$6print j}'
}if [ $# -eq 0 ]; thenecho "skip EXTRACT"exit 2
fiextract=$1if [ `echo $extract|grep ^E` ];thenIType=EXTRACTelif [ `echo $extract|grep ^P` ];thenecho "only can operate the EXTRACT  process"exit 2
elif  [ `echo $extract|grep ^R` ];thenecho "only can operate the extract process"exit 2
elseecho "only can operate the EXTRACT  process"exit 2
fival=`echo $extract.PRM|tr A-Z a-z`cd $HOME/ggserver/dirprm
if [ ! -e $val ]; thenecho "the EXTRACT is not exist"exit 2
ficd $dir
echo $loginecho $dir
cd $HOME/ggserverecho "loading the trans data.....please wait....."
(echo send $extract showtrans thread 1;echo exit)|./ggsci > $dir/thread1
echo "Thread 1 data load compete"
(echo send $extract showtrans thread 2;echo exit)|./ggsci > $dir/thread2
echo "Thread 2 data load compete"cd $dircat thread1|awk 'BEGIN{}{FS=" "} /^XID:/{print $2}'|sed  -e '/^$/d' > xid1
cat thread1|awk -F 'Time:           ' '{print $2}'|sed  -e '/^$/d' > time1
paste time1 xid1 > trandata
cat thread2|awk 'BEGIN{}{FS=" "} /^XID:/{print $2}'|sed  -e '/^$/d' > xid2
cat thread2|awk -F 'Time:           ' '{print $2}'|sed  -e '/^$/d' > time2
paste time2 xid2 > trandata2cat trandata2 >> trandatasydate=`date +"%Y-%m-%d:%H:%M:%S"`
echo $HSYSTIME
date2seconds `echo $sydate | sed 's/-/ /g;s/:/ /g'` > secondssys
HSYSTIME=`cat secondssys`
echo $HSYSTIME
rm -f secondssys
#date2seconds `echo $sydate | sed 's/-/ /g;s/:/ /g'`NUX=`sed -n '$=' trandata`i=1
cat /dev/null > trains
while(($i<=$NUX));  dostr=`sed -n "${i}p"  trandata |awk '{print $1}'`
echo $str
date2seconds `echo $str | sed 's/-/ /g;s/:/ /g'` > secondssys
HGTI=`cat secondssys`
rm -f secondssys
echo $HGTI
echo $HSYSTIME
POOR=`expr $HSYSTIME - 3600`
echo $POOR
echo "--------------------"
if [ "$HGTI" -le "$POOR" ]thensed -n "${i}p"  trandata |awk '{print $2}' >> trains
fii=`expr $i + 1`donesed 's/^/send '$extract' skiptrans /' trains > trains1
sed 's/$/ force/' trains1 > skiptrains cd $HOME/ggservercat $HOME/ggscript/ggtrandata/skiptrains > dirdat/skiptrainsecho   OBEY dirdat/skiptrains |./ggsci