数据库迁移怎么创建

from sqlalchemy import create_engine, MetaData, Table
from sqlalchemy.orm import sessionmaker

# 创建源数据库和目标数据库的连接
source_engine = create_engine('source_database_url')
target_engine = create_engine('target_database_url')

# 创建会话
SourceSession = sessionmaker(bind=source_engine)
TargetSession = sessionmaker(bind=target_engine)

# 获取源数据库的元数据
metadata = MetaData(bind=source_engine)
metadata.reflect()

# 遍历所有表并复制到目标数据库
for table_name in metadata.tables.keys():
    source_table = Table(table_name, metadata, autoload_with=source_engine)
    target_table = Table(table_name, MetaData(bind=target_engine), autoload_with=target_engine)
    
    # 复制数据
    for row in source_engine.execute(source_table.select()):
        target_engine.execute(target_table.insert().values(row))

# 验证数据完整性
# 这里可以添加自定义的验证逻辑