mssql与mysql数据同步

from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, Integer, String

Base = declarative_base()

class User(Base):
    __tablename__ = 'users'
    id = Column(Integer, primary_key=True)
    name = Column(String)

# MSSQL连接
mssql_engine = create_engine('mssql+pyodbc://username:password@server/database?driver=ODBC+Driver+17+for+SQL+Server')
mssql_session = sessionmaker(bind=mssql_engine)()

# MySQL连接
mysql_engine = create_engine('mysql+pymysql://username:password@host/database')
mysql_session = sessionmaker(bind=mysql_engine)()

# 同步数据
def sync_data():
    mssql_users = mssql_session.query(User).all()
    for user in mssql_users:
        mysql_user = mysql_session.query(User).filter_by(id=user.id).first()
        if not mysql_user:
            mysql_session.add(user)
        else:
            mysql_user.name = user.name
    mysql_session.commit()

sync_data()