mysql定时同步表结构

import mysql.connector
from mysql.connector import Error
import schedule
import time

def sync_table_structure():
    try:
        # 连接源数据库
        source_conn = mysql.connector.connect(
            host='source_host',
            user='source_user',
            password='source_password',
            database='source_database'
        )
        source_cursor = source_conn.cursor()

        # 连接目标数据库
        target_conn = mysql.connector.connect(
            host='target_host',
            user='target_user',
            password='target_password',
            database='target_database'
        )
        target_cursor = target_conn.cursor()

        # 获取源数据库表结构
        source_cursor.execute("SHOW CREATE TABLE your_table")
        table_structure = source_cursor.fetchone()[1]

        # 在目标数据库中创建或修改表结构
        target_cursor.execute(f"CREATE TABLE IF NOT EXISTS your_table LIKE {table_structure}")
        target_cursor.execute(f"ALTER TABLE your_table {table_structure}")

        # 提交事务并关闭连接
        target_conn.commit()
        source_conn.close()
        target_conn.close()

    except Error as e:
        print(f"Error: {e}")

# 定时任务配置（每分钟执行一次）
schedule.every(1).minutes.do(sync_table_structure)

while True:
    schedule.run_pending()
    time.sleep(1)