OGG运维优化脚本（四）-信息修改类--长事务跳过
文件名: skiptrans.sh skip.sh
所在路径:$HOME/ggscript/ggtrandata
功能：该脚本用于重启抽取进程时跳过长事务，可自动识别1小时以上的长事务并批量跳过，skiptrans.sh通过edit脚本选择调用，skip.sh用于在其他脚本中调用用，例如allstop.sh全goldengate进程停止脚本
Ps:目前该脚本目前仅适用于AIX和LINUX系统
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+$6
print j
}'
}
cd $HOME/ggscript/ggtrandata
echo $login
echo $dir
dir=$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 > trandata2
cat 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)); do
str=`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" ]
then
sed -n "${i}p" trandata |awk '{print $2}' >> trains
fi
i=`expr $i + 1`
done
#将一小时以前的长事务组合成skiptrans指令，并通过obey指令批量执行
sed 's/^/send '$extract' skiptrans /' trains > trains1
sed 's/$/ force/' trains1 > skiptrains
cd $HOME/ggserver
cat $HOME/ggscript/ggtrandata/skiptrains > dirdat/skiptrains
echo OBEY dirdat/skiptrains |./ggsci
skip.sh
#!/bin/bash
echo $dir
cd $HOME/ggscript/ggtrandata
dir=$PWD
cd $HOME
if [ -f .profile ];then
. .profile
fi
if [ -f .bash_profile ];then
. .bash_profile
fi
cd $dir
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+$6
print j
}'
}
if [ $# -eq 0 ]; then
echo "skip EXTRACT"
exit 2
fi
extract=$1
if [ `echo $extract|grep ^E` ];then
IType=EXTRACT
elif [ `echo $extract|grep ^P` ];then
echo "only can operate the EXTRACT process"
exit 2
elif [ `echo $extract|grep ^R` ];then
echo "only can operate the extract process"
exit 2
else
echo "only can operate the EXTRACT process"
exit 2
fi
val=`echo $extract.PRM|tr A-Z a-z`
cd $HOME/ggserver/dirprm
if [ ! -e $val ]; then
echo "the EXTRACT is not exist"
exit 2
fi
cd $dir
echo $login
echo $dir
cd $HOME/ggserver
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
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 > trandata2
cat 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)); do
str=`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" ]
then
sed -n "${i}p" trandata |awk '{print $2}' >> trains
fi
i=`expr $i + 1`
done
sed 's/^/send '$extract' skiptrans /' trains > trains1
sed 's/$/ force/' trains1 > skiptrains
cd $HOME/ggserver
cat $HOME/ggscript/ggtrandata/skiptrains > dirdat/skiptrains
echo OBEY dirdat/skiptrains |./ggsci