db2db转换mysql

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

# 创建源数据库和目标数据库的连接引擎
source_engine = create_engine('db2://username:password@host:port/dbname')
target_engine = create_engine('mysql+pymysql://username:password@host:port/dbname')

# 创建会话
Session = sessionmaker(bind=source_engine)
session = Session()

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

# 遍历源数据库中的所有表
for table_name in metadata.tables.keys():
    table = Table(table_name, metadata, autoload_with=source_engine)
    
    # 创建目标数据库中的同名表
    table.create(target_engine, checkfirst=True)
    
    # 将数据从源表迁移到目标表
    result = session.execute(table.select())
    data = result.fetchall()
    
    # 插入数据到目标表
    target_session = sessionmaker(bind=target_engine)()
    target_session.execute(table.insert(), data)
    target_session.commit()

# 关闭会话
session.close()