OGG_HOME=/GoldenGate/app
LOG_FILE=$OGG_HOME/logs/auto_resolve.log

resolve_duplicate_key() {
local table_name=$1
local pk_value=$2

echo “处理主键冲突: 表=$table_name, 主键=$pk_value” >> $LOG_FILE

# 使用SQL更新记录
sqlplus -s fgedu/fgedu123@fgedudb01 << EOF
UPDATE $table_name
SET version = version + 1,
update_time = SYSDATE
WHERE order_id = $pk_value;
COMMIT;
EXIT;
EOF
}

# 监控Discard文件
while true; do
for discard_file in $OGG_HOME/dirrpt/*.dsc; do
if [ -f “$discard_file” ]; then
table_name=$(grep “Table:” $discard_file | head -1 | awk ‘{print $2}’)
pk_value=$(grep “Primary Key:” $discard_file | head -1 | awk ‘{print $3}’)

if [ ! -z “$table_name” ] && [ ! -z “$pk_value” ]; then
resolve_duplicate_key $table_name $pk_value
mv $discard_file $discard_file.processed
fi
fi
done
sleep 60
done