使用mysql.connector导入S3数据到MySQL Aurora临时表失败

核心问题分析 #

MySQL临时表是会话级资源，仅在创建它的数据库连接会话内可见。出现查询返回None的情况，通常是因为：

• 创建临时表和查询时用了不同的数据库连接（会话）
• 数据导入语句未正确执行（比如漏写cursor.execute()或触发了未捕获的异常）
• 误操作导致会话重置（比如调用connection.reset_session()）

正确实现步骤 #

1. 保持单一会话操作 #

创建临时表、导入数据、查询数据必须使用同一个数据库连接，不能中途重建连接。

2. 完整代码示例 #

import mysql.connector
from mysql.connector import Error

try:
    # 建立单一数据库连接
    connection = mysql.connector.connect(
        host='你的主机地址',
        database='目标数据库',
        user='用户名',
        password='密码'
    )

    if connection.is_connected():
        cursor = connection.cursor()
        
        # 1. 创建临时表
        create_temp_sql = """
        CREATE TEMPORARY TABLE temp_order (
            order_id INT PRIMARY KEY,
            product_name VARCHAR(100),
            price DECIMAL(10,2)
        )
        """
        cursor.execute(create_temp_sql)
        
        # 2. 导入数据（单条或批量均可）
        # 单条插入示例
        insert_sql = "INSERT INTO temp_order (order_id, product_name, price) VALUES (%s, %s, %s)"
        insert_data = (101, "无线耳机", 299.99)
        cursor.execute(insert_sql, insert_data)

        # 批量插入示例（可选）
        # batch_data = [(102, "蓝牙音箱", 199.99), (103, "智能手表", 499.99)]
        # cursor.executemany(insert_sql, batch_data)
        
        # 临时表操作无需提交即可在当前会话查询，普通表需调用connection.commit()
        # connection.commit()
        
        # 3. 查询验证临时表数据
        select_sql = "SELECT * FROM temp_order WHERE order_id = %s"
        cursor.execute(select_sql, (101,))
        result = cursor.fetchone()
        
        if result:
            print(f"查询到记录: {result}")
        else:
            print("未查到记录")

except Error as e:
    print(f"数据库操作错误: {e}")
finally:
    # 关闭资源
    if connection.is_connected():
        cursor.close()
        connection.close()

常见排查点 #

• 检查是否在创建临时表后重新建立了连接，这会导致原会话的临时表被销毁
• 用cursor.rowcount查看数据导入后的受影响行数，确认数据是否真的被插入
• 若使用连接池，确保创建临时表和查询用的是同一个连接实例
• 避免在操作临时表过程中调用connection.reset_session()，这会重置会话

内容的提问来源于stack exchange，提问作者BackgroundChecker1994