执行MySQL表复制SQL报错：No result set to fetch from

这个问题我太熟悉了，根源在于你把写入操作和查询操作用同一个函数处理了，咱们一步步来拆解和解决：

错误原因 #

INSERT INTO ... SELECT ...是典型的数据写入类操作，它的作用是把查询结果插入到目标表中，执行完成后只会返回受影响的行数，不会生成可供fetchall()读取的结果集。而你的query函数不管执行什么语句，都强行调用query_cursor.fetchall()，这就触发了MySQL连接器的InterfaceError——毕竟根本没有结果集可以读取。

解决方案：拆分查询与写入操作 #

最清晰可靠的方式是把函数拆分成两个：一个专门处理需要返回结果的查询（比如SELECT），另一个处理写入/修改类操作（比如INSERT、UPDATE、DELETE）。

1. 处理查询操作的函数 #

用于执行SELECT这类需要返回结果的语句：

def fetch_query(query_string, db_connection):
    while True:
        try:
            query_cursor = db_connection.cursor()
            query_cursor.execute(query_string)
            logging.info('Executing fetch query...')
            query_result = query_cursor.fetchall()
            return query_result
        except AttributeError:
            logging.warning('%s Bad credentials' % timestamp)

2. 处理写入操作的函数 #

用于执行INSERT、UPDATE等无结果集的操作，别忘了提交事务：

def execute_write(query_string, db_connection):
    while True:
        try:
            query_cursor = db_connection.cursor()
            query_cursor.execute(query_string)
            # 必须提交事务，否则数据不会持久化到数据库
            db_connection.commit()
            affected_rows = query_cursor.rowcount
            logging.info('Executing write query, %d rows affected', affected_rows)
            return affected_rows
        except AttributeError:
            logging.warning('%s Bad credentials' % timestamp)
        except mysql.connector.Error as e:
            # 出错时回滚事务，避免数据不一致
            db_connection.rollback()
            logging.error('Write operation failed: %s', str(e))
            raise  # 重新抛出错误，方便上层处理

3. 修改调用方式 #

现在执行你的INSERT...SELECT语句时，要调用写入函数：

# 执行数据复制操作
affected_rows = rpgen.execute_write(
    "INSERT INTO auth_user.outputdb SELECT * FROM auth_user.auth_user", 
    connection_to_input_db
)

额外注意事项 #

• 事务提交：MySQL默认关闭自动提交，所以执行写入操作后必须调用db_connection.commit()，否则数据只会停留在内存中，不会写入磁盘。
• 错误处理：添加事务回滚逻辑可以避免操作失败时出现数据不一致的情况，这在生产环境中非常重要。
• 语句区分：如果不想拆分函数，也可以在原有函数里判断语句类型（比如检查开头是否是SELECT），但拆分函数的方式更易维护和调试。

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