PHP PDO执行含MySQL用户变量的查询无返回行问题

你遇到的这个情况挺常见的，咱们一步步拆解来定位问题根源：

1. 先确认内层子查询的有效性 #

整个外层查询完全依赖$priority_query的输出，所以第一步必须单独验证这个子查询是否能返回数据：

-- 替换成你实际的$priority_query内容
SELECT * FROM (你的$priority_query内容) AS test_check;

如果这一步就没有返回任何数据，那外层查询自然也不会有结果。

2. 检查用户变量的初始化与赋值顺序 #

MySQL中用户变量的读写顺序很容易踩坑，你当前的变量初始化写法可能存在执行顺序的问题。可以改成用CROSS JOIN来初始化变量，确保变量在查询开始前就被正确设置：

SELECT * FROM (
 SELECT 
   id, 
   status_ts, 
   @num := IF(@prev_priority = priority, @num + 1, 1) AS _row_number,
   @prev_priority := priority AS priority
 FROM (
   -- 替换为你的$priority_query内容
   SELECT id, status_ts, priority FROM your_target_table
 ) AS get_priority
 CROSS JOIN (SELECT @num := 0, @prev_priority := '') AS var_init
 ORDER BY priority DESC, status_ts ASC
) AS items
WHERE items._row_number <= CEIL(items.priority);

这种写法能避免因MySQL执行顺序导致的变量值异常。

3. 验证_row_number与CEIL(priority)的逻辑匹配 #

你可以先去掉外层的WHERE条件，看看子查询返回的原始数据：

SET @num := 0, @priority := '';
SELECT id, status_ts, _row_number, priority FROM (
 SELECT id, status_ts, @num := IF(@priority = priority, @num + 1, 1) AS _row_number, @priority := priority AS priority
 FROM ($priority_query) AS get_priority
 ORDER BY priority DESC, status_ts ASC
) AS items;

重点查看每一行的_row_number是否真的小于等于CEIL(priority)：

• 如果priority是0，CEIL(0)等于0，而_row_number从1开始，自然不会满足条件
• 如果priority是小数（比如1.1），CEIL后是2，那前两行会被保留，若你的分组内只有1行，也会被保留

4. 排查PDO执行的潜在错误 #

有时候rowCount()返回0不是因为SQL没结果，而是查询执行出错了。可以在执行后添加错误检查：

$sql = $PDO->query($query);
if (!$sql) {
    print_r($PDO->errorInfo()); // 打印具体错误信息
} else {
    echo "返回行数：" . $sql->rowCount();
}

这能帮你排查语法错误、权限问题等导致查询未正常执行的情况。

5. 尝试用窗口函数替代用户变量（MySQL 8.0+） #

如果你的MySQL版本是8.0及以上，推荐用窗口函数重构查询，逻辑更清晰，还能避免变量的坑：

WITH ranked_items AS (
 SELECT 
   id, 
   status_ts, 
   priority,
   ROW_NUMBER() OVER (PARTITION BY priority ORDER BY status_ts ASC) AS _row_number
 FROM ($priority_query) AS get_priority
)
SELECT id, status_ts, priority, _row_number
FROM ranked_items
WHERE _row_number <= CEIL(priority)
ORDER BY priority DESC, status_ts ASC;

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