python mysql数据迁移

import mysql.connector

# 连接源数据库
source_db = mysql.connector.connect(
    host="source_host",
    user="source_user",
    password="source_password",
    database="source_database"
)

# 连接目标数据库
target_db = mysql.connector.connect(
    host="target_host",
    user="target_user",
    password="target_password",
    database="target_database"
)

# 创建游标
source_cursor = source_db.cursor()
target_cursor = target_db.cursor()

# 查询源数据库中的数据
source_cursor.execute("SELECT * FROM source_table")
rows = source_cursor.fetchall()

# 将数据插入目标数据库
for row in rows:
    query = f"INSERT INTO target_table (column1, column2, column3) VALUES (%s, %s, %s)"
    target_cursor.execute(query, row)

# 提交事务
target_db.commit()

# 关闭连接
source_cursor.close()
target_cursor.close()
source_db.close()
target_db.close()