PHP中while循环内执行MySQL查询及同步错误解决求助

这个错误我太熟了！本质原因是你调用存储过程后，没有完全处理完它返回的所有结果集，就直接在循环里执行新的查询了。MySQL的mysqli驱动有个严格要求：必须先清空当前连接的所有未处理结果，才能执行下一个命令——而存储过程这类操作，经常会在你需要的数据集之外，额外返回一个状态结果集，这就是触发错误的元凶。

下面给你两种靠谱的解决方案，按需选择：

方案1：彻底处理完所有结果集再执行内部查询 #

核心是调用完存储过程后，不仅要读取你需要的主结果集，还要用mysqli_next_result()清理掉存储过程产生的额外结果，确保连接处于"干净"状态后再执行循环内的查询。

修改后的代码示例：

<?php
// 注意：这里建议用预处理语句防注入，后面会提
$sql = "call sp_getUpline('$user_id')";
$result = mysqli_query($connection, $sql);

$numrow = mysqli_num_rows($result);
if($numrow > 1) {
    while($resultArray = mysqli_fetch_assoc($result)) {
        $parent_id = $resultArray['parent_id'];
        if($parent_id != null) {
            $Level = $resultArray['Level'] + 1;
            // 执行你的内部查询
            $comp_sql = "SELECT ..."; // 替换成你的实际查询语句
            $comp_result = mysqli_query($connection, $comp_sql);
            
            // 处理内部查询的结果
            while($comp_row = mysqli_fetch_assoc($comp_result)) {
                // 这里写你的业务逻辑
            }
            
            // 释放内部结果集，避免内存泄漏
            mysqli_free_result($comp_result);
        }
    }
}

// 关键步骤：清理存储过程产生的额外结果集
while(mysqli_next_result($connection)) {
    $dummy_result = mysqli_store_result($connection);
    if($dummy_result) {
        mysqli_free_result($dummy_result);
    }
}

// 释放主结果集
mysqli_free_result($result);
?>

方案2：用独立连接执行内部查询 #

如果觉得处理结果集太麻烦，另一种更直观的方式是为循环内的查询创建一个独立的数据库连接，让内外查询的结果集互不干扰：

<?php
// 主连接用于执行存储过程
$main_conn = mysqli_connect(DB_HOST, DB_USER, DB_PASS, DB_NAME);
// 独立连接用于循环内的查询
$inner_conn = mysqli_connect(DB_HOST, DB_USER, DB_PASS, DB_NAME);

$sql = "call sp_getUpline('$user_id')";
$result = mysqli_query($main_conn, $sql);

$numrow = mysqli_num_rows($result);
if($numrow > 1) {
    while($resultArray = mysqli_fetch_assoc($result)) {
        $parent_id = $resultArray['parent_id'];
        if($parent_id != null) {
            $Level = $resultArray['Level'] + 1;
            $comp_sql = "SELECT ...";
            // 用独立连接执行内部查询，完全不影响主连接的结果集
            $comp_result = mysqli_query($inner_conn, $comp_sql);
            
            // 处理内部查询结果...
            
            mysqli_free_result($comp_result);
        }
    }
}

// 关闭所有连接和结果集
mysqli_free_result($result);
mysqli_close($main_conn);
mysqli_close($inner_conn);
?>

重要提醒：防SQL注入！ #

你的原代码直接把$user_id拼进了SQL语句里，这存在严重的SQL注入风险！强烈建议改用预处理语句：

// 预处理存储过程调用
$stmt = mysqli_prepare($connection, "call sp_getUpline(?)");
// 绑定参数（"s"表示字符串类型，根据你的user_id类型调整）
mysqli_stmt_bind_param($stmt, "s", $user_id);
mysqli_stmt_execute($stmt);
// 获取结果集
$result = mysqli_stmt_get_result($stmt);

// 后续的结果处理逻辑和之前一致...

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