mysql断线重新同步

import mysql.connector
from mysql.connector import errorcode

def connect_to_mysql():
    try:
        cnx = mysql.connector.connect(user='user', password='password',
                                      host='host', database='database')
        return cnx
    except mysql.connector.Error as err:
        if err.errno == errorcode.ER_ACCESS_DENIED_ERROR:
            print("Something is wrong with your user name or password")
        elif err.errno == errorcode.ER_BAD_DB_ERROR:
            print("Database does not exist")
        else:
            print(err)
        return None

def sync_data(cnx):
    cursor = cnx.cursor()
    try:
        cursor.execute("SELECT * FROM table")
        rows = cursor.fetchall()
        # 处理数据同步逻辑
        for row in rows:
            print(row)
    except mysql.connector.Error as err:
        print(err)
    finally:
        cursor.close()

def main():
    cnx = connect_to_mysql()
    if cnx:
        try:
            while True:
                sync_data(cnx)
        except mysql.connector.Error as err:
            print("Connection lost, reconnecting...")
            cnx = connect_to_mysql()
            if cnx:
                sync_data(cnx)
        finally:
            cnx.close()

if __name__ == "__main__":
    main()