mysql表结构比对更新工具

from sqlalchemy import create_engine, MetaData, Table
from sqlalchemy.schema import CreateTable

# 连接源数据库和目标数据库
source_engine = create_engine('mysql+pymysql://user:password@source_host/source_db')
target_engine = create_engine('mysql+pymysql://user:password@target_host/target_db')

# 加载源数据库和目标数据库的元数据
source_metadata = MetaData(bind=source_engine)
target_metadata = MetaData(bind=target_engine)

# 获取源数据库和目标数据库的所有表名
source_tables = source_metadata.tables.keys()
target_tables = target_metadata.tables.keys()

# 比对表结构并生成SQL语句
for table_name in source_tables:
    if table_name in target_tables:
        source_table = Table(table_name, source_metadata, autoload_with=source_engine)
        target_table = Table(table_name, target_metadata, autoload_with=target_engine)
        
        # 生成更新SQL语句（示例）
        update_sql = CreateTable(source_table).compile(dialect=target_engine.dialect)
        print(update_sql)
    else:
        # 生成创建表SQL语句（示例）
        create_sql = CreateTable(Table(table_name, source_metadata, autoload_with=source_engine)).compile(dialect=target_engine.dialect)
        print(create_sql)

# 注意：以上代码仅为示例，实际使用时需根据具体情况进行调整和完善。