数据库扩展限时活动

import pymysql

def migrate_data(source_conn, target_conn):
    try:
        with source_conn.cursor() as source_cursor, target_conn.cursor() as target_cursor:
            source_cursor.execute("SELECT * FROM users")
            users = source_cursor.fetchall()
            
            for user in users:
                target_cursor.execute("INSERT INTO users (id, name, email) VALUES (%s, %s, %s)", user)
        
        target_conn.commit()
        print("Migration completed successfully.")
    except Exception as e:
        print(f"Error during migration: {e}")
        target_conn.rollback()

# 配置源数据库和目标数据库连接
source_config = {
    'host': 'source_host',
    'user': 'source_user',
    'password': 'source_password',
    'database': 'source_db'
}

target_config = {
    'host': 'target_host',
    'user': 'target_user',
    'password': 'target_password',
    'database': 'target_db'
}

source_conn = pymysql.connect(**source_config)
target_conn = pymysql.connect(**target_config)

migrate_data(source_conn, target_conn)