oracle mysql结构同步

import mysql.connector

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

    # 获取源数据库的结构
    cursor_source.execute("SHOW TABLES")
    tables = cursor_source.fetchall()

    for table in tables:
        table_name = table[0]
        cursor_source.execute(f"SHOW CREATE TABLE {table_name}")
        create_table_sql = cursor_source.fetchone()[1]

        # 在目标数据库中创建表
        cursor_target.execute(create_table_sql)

    target_conn.commit()

# 连接源数据库和目标数据库
source_conn = mysql.connector.connect(user='source_user', password='source_password', host='source_host', database='source_db')
target_conn = mysql.connector.connect(user='target_user', password='target_password', host='target_host', database='target_db')

# 同步结构
sync_structure(source_conn, target_conn)

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