数据库表结构同步mysql

import mysql.connector

def sync_table_structure(source_conn, target_conn, table_name):
    cursor_source = source_conn.cursor()
    cursor_target = target_conn.cursor()

    # 获取源数据库的表结构
    cursor_source.execute(f"SHOW CREATE TABLE {table_name}")
    create_table_sql = cursor_source.fetchone()[1]

    # 在目标数据库中创建或更新表结构
    try:
        cursor_target.execute(create_table_sql)
        print(f"Table {table_name} synchronized successfully.")
    except mysql.connector.Error as err:
        print(f"Error synchronizing table {table_name}: {err}")

    cursor_source.close()
    cursor_target.close()

# 示例连接信息
source_config = {
    'host': 'source_host',
    'user': 'source_user',
    'password': 'source_password',
    'database': 'source_database'
}

target_config = {
    'host': 'target_host',
    'user': 'target_user',
    'password': 'target_password',
    'database': 'target_database'
}

# 连接数据库
source_conn = mysql.connector.connect(**source_config)
target_conn = mysql.connector.connect(**target_config)

# 同步表结构
sync_table_structure(source_conn, target_conn, 'example_table')

# 关闭连接
source_conn.close()
target_conn.close()