SOURCE_DB=”fgedudb01″
TARGET_DB=”fgedudb02″
LOG_FILE=/GoldenGate/app/logs/data_integrity_check.log

check_integrity() {
local table=$1
local source_checksum=$(sqlplus -s fgedu/fgedu123@$SOURCE_DB << EOF
SET PAGESIZE 0
SET FEEDBACK OFF
SELECT DBMS_CRYPTO.HASH(UTL_RAW.CAST_TO_RAW(order_id || customer_id || total_amount), ‘MD5’)
FROM $table
WHERE ROWNUM <= 1000;
EXIT
EOF
)

local target_checksum=$(sqlplus -s fgedu/fgedu123@$TARGET_DB << EOF
SET PAGESIZE 0
SET FEEDBACK OFF
SELECT DBMS_CRYPTO.HASH(UTL_RAW.CAST_TO_RAW(order_id || customer_id || total_amount), ‘MD5’)
FROM $table
WHERE ROWNUM <= 1000;
EXIT
EOF
)

if [ “$source_checksum” = “$target_checksum” ]; then
echo “表 $table 数据完整: 校验和一致” >> $LOG_FILE
else
echo “表 $table 数据不完整: 校验和不一致” >> $LOG_FILE
fi
}

echo “========== 数据完整性校验: $(date) ==========” >> $LOG_FILE

# 校验所有表
check_integrity “fgedu01.fgedu_orders”
check_integrity “fgedu01.fgedu_products”
check_integrity “fgedu01.fgedu_customers”