mysql数据库迁移到sqlserver

import pymysql
import pyodbc

# 连接MySQL数据库
mysql_conn = pymysql.connect(host='localhost', user='user', password='password', db='source_db')
mysql_cursor = mysql_conn.cursor()

# 连接SQL Server数据库
sqlserver_conn = pyodbc.connect('DRIVER={ODBC Driver 17 for SQL Server};SERVER=server_name;DATABASE=target_db;UID=user;PWD=password')
sqlserver_cursor = sqlserver_conn.cursor()

# 获取MySQL表结构
mysql_cursor.execute("SHOW TABLES")
tables = mysql_cursor.fetchall()

for table in tables:
    table_name = table[0]
    
    # 创建表结构
    mysql_cursor.execute(f"SHOW CREATE TABLE {table_name}")
    create_table_sql = mysql_cursor.fetchone()[1]
    create_table_sql = create_table_sql.replace('AUTO_INCREMENT', 'IDENTITY(1,1)')  # 修改自增字段
    sqlserver_cursor.execute(create_table_sql)
    
    # 迁移数据
    mysql_cursor.execute(f"SELECT * FROM {table_name}")
    rows = mysql_cursor.fetchall()
    for row in rows:
        placeholders = ', '.join(['?'] * len(row))
        sqlserver_cursor.execute(f"INSERT INTO {table_name} VALUES ({placeholders})", row)

# 提交事务并关闭连接
sqlserver_conn.commit()
mysql_cursor.close()
mysql_conn.close()
sqlserver_cursor.close()
sqlserver_conn.close()