# 检查详细的复制状态
SLAVE_POD=$(kubectl get pod -l role=slave -o jsonpath='{.items[0].metadata.name}')
MASTER_POD=$(kubectl get pod -l role=master -o jsonpath='{.items[0].metadata.name}')

echo "=== 检查复制状态 ==="
kubectl exec $SLAVE_POD -- mysql -uroot -proot123 -e "SHOW REPLICA STATUS\G" | grep -E "Replica_IO_Running|Replica_SQL_Running|Seconds_Behind_Source|Source_Host|Source_User|Last_IO_Error|Last_SQL_Error"

# 获取具体的运行状态
IO_RUNNING=$(kubectl exec $SLAVE_POD -- mysql -uroot -proot123 -e "SHOW REPLICA STATUS\G" | grep "Replica_IO_Running:" | awk '{print $2}')
SQL_RUNNING=$(kubectl exec $SLAVE_POD -- mysql -uroot -proot123 -e "SHOW REPLICA STATUS\G" | grep "Replica_SQL_Running:" | awk '{print $2}')

echo -e "\nIO线程状态: $IO_RUNNING"
echo "SQL线程状态: $SQL_RUNNING"

if [ "$IO_RUNNING" = "Yes" ] && [ "$SQL_RUNNING" = "Yes" ]; then
    echo "✅ 复制运行正常！"
else
    echo "❌ 复制异常"
fi