如何使用PHP显示MySQL长查询的进度百分比

我来帮你搞定这个MySQL长查询进度显示的问题！普通AJAX请求是一次性返回结果，没法中途传递进度，所以咱们得用**「触发查询+轮询进度」**的组合方式，配合PHP会话（Session）来共享进度数据。下面是具体实现步骤：

一、修改后端PHP代码（backend.php） #

我们需要把长查询拆分成可追踪进度的逻辑，用Session存储当前进度，同时注意释放Session锁避免阻塞轮询请求：

<?php
session_start();

// 初始化进度
if (!isset($_SESSION['query_progress'])) {
    $_SESSION['query_progress'] = 0;
}

// 处理查询启动请求
if ($_POST['action'] == 'start_query') {
    // 1. 先获取符合条件的总数据量（根据你的筛选逻辑调整SQL）
    $pdo = new PDO('mysql:host=localhost;dbname=你的数据库名', '用户名', '密码');
    $countStmt = $pdo->prepare("SELECT COUNT(*) FROM 你的表名 WHERE 你的筛选条件");
    $countStmt->execute();
    $total = $countStmt->fetchColumn();
    
    // 2. 分批处理数据（比如每次处理100条，可根据服务器性能调整）
    $batchSize = 100;
    $processed = 0;
    $resultHtml = '';
    
    while ($processed < $total) {
        $stmt = $pdo->prepare("SELECT * FROM 你的表名 WHERE 你的筛选条件 LIMIT :offset, :limit");
        $stmt->bindValue(':offset', $processed, PDO::PARAM_INT);
        $stmt->bindValue(':limit', $batchSize, PDO::PARAM_INT);
        $stmt->execute();
        
        // 遍历当前批次数据，生成表格行HTML
        while ($row = $stmt->fetch(PDO::FETCH_ASSOC)) {
            $resultHtml .= "<tr><td>{$row['字段1']}</td><td>{$row['字段2']}</td></tr>";
        }
        
        // 更新进度百分比
        $processed += $batchSize;
        $_SESSION['query_progress'] = min(100, round(($processed / $total) * 100));
        
        // 关键：释放Session锁，让轮询请求能读取最新进度
        session_write_close();
        // 后续还要更新进度，重新开启Session
        session_start();
        
        // 可选：给服务器留一点缓冲时间，避免压力过大
        usleep(10000);
    }
    
    // 查询完成，重置进度并释放Session
    $_SESSION['query_progress'] = 100;
    session_write_close();
    
    // 返回最终的表格内容
    echo $resultHtml;
    exit;
}

// 处理进度查询请求
if ($_POST['action'] == 'get_progress') {
    echo $_SESSION['query_progress'];
    exit;
}
?>

二、修改前端JavaScript代码 #

原来的show()函数要改成先触发查询，再定时轮询进度，实时更新输入框的数值：

function show(){ 
    // 初始化进度显示为0%
    $("#percents").val("0%");
    
    // 1. 发送启动长查询的请求
    $.ajax({ 
        url:"backend.php", 
        type:"POST",
        data: {action: 'start_query'},
        beforeSend:function(){ 
            $("body").addClass("loading"); 
        }, 
        success:function(data){ 
            $("tbody").html(data); 
            $("body").removeClass("loading");
            // 查询完成后强制设置进度为100%
            $("#percents").val("100%");
            // 停止进度轮询
            clearInterval(progressInterval);
        } 
    });
    
    // 2. 启动进度轮询（每500毫秒查询一次，可调整频率）
    let progressInterval = setInterval(() => {
        $.ajax({
            url:"backend.php",
            type:"POST",
            data: {action: 'get_progress'},
            success:function(progress){
                $("#percents").val(progress + "%");
                // 如果进度已到100，提前终止轮询
                if (progress == 100) {
                    clearInterval(progressInterval);
                }
            }
        });
    }, 500);
}

三、几个重要注意事项 #

• Session阻塞问题：必须在更新进度后调用session_write_close()，否则后续的轮询请求会被卡住，直到长查询结束，就看不到实时进度了。
• 分批大小调整：$batchSize的数值要根据你的数据量和服务器性能来定——太小会增加数据库请求次数，太大则进度更新不及时。
• 进度准确性：总数据量的查询SQL要和实际筛选数据的SQL条件完全一致，不然进度计算会出现偏差。
• Session清理：查询完成后重置$_SESSION['query_progress']，避免下次查询时进度从上次的数值开始。

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