mysql 同步到sqlserver

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

# MySQL连接配置
mysql_engine = create_engine('mysql+pymysql://user:password@host:port/database')
mysql_metadata = MetaData(bind=mysql_engine)
mysql_session = sessionmaker(bind=mysql_engine)()

# SQL Server连接配置
sqlserver_engine = create_engine('mssql+pyodbc://user:password@host:port/database?driver=ODBC+Driver+17+for+SQL+Server')
sqlserver_metadata = MetaData(bind=sqlserver_engine)
sqlserver_session = sessionmaker(bind=sqlserver_engine)()

# 定义表结构
mysql_table = Table('table_name', mysql_metadata, autoload_with=mysql_engine)
sqlserver_table = Table('table_name', sqlserver_metadata, autoload_with=sqlserver_engine)

# 同步数据
def sync_data():
    result = mysql_session.query(mysql_table).all()
    for row in result:
        insert_stmt = sqlserver_table.insert().values(**row.__dict__)
        sqlserver_session.execute(insert_stmt)
    sqlserver_session.commit()

sync_data()