mysqli 实现异步查询的核心在于使用 mysqli_async 标志调用 mysqli::query()，该方法会立即返回而不会阻塞等待结果，随后通过 mysqli::poll() 函数轮询连接状态以获取实际数据。具体做法是：在发起查询时传入 mysqli_async 标志，将多个查询分发到不同的连接或同一连接的不同流上，然后循环调用 poll() 检查哪些连接已准备好读取结果，最后对准备好的连接调用 store_result() 或 use_result() 获取数据。需要注意的是，这种模式要求每个查询必须绑定到一个独立的 mysqli 对象实例，因为单个连接在同一时刻只能处理一个未完成的异步操作。
如何初始化并发起多个异步查询？
要发起异步查询，必须在创建 mysqli 对象后，在调用 query() 方法时显式添加 MYSQLI_ASYNC 常量作为第二个参数。这一步骤会将查询请求发送到服务器并立即返回，程序控制权交还给开发者，从而允许同时发起多个查询而不必等待任何一个完成。关键在于，每个异步查询必须关联一个独立的 mysqli 实例，因为 MySQL 协议本身不支持在一个 TCP 连接上并行发送多个未确认的查询包。
$link1 = new mysqli("host", "user", "pass", "db");
$link2 = new mysqli("host", "user", "pass", "db");
// 发起第一个异步查询
$result1 = $link1->query("SELECT * FROM table1", MYSQLI_ASYNC);
// 发起第二个异步查询
$result2 = $link2->query("SELECT * FROM table2", MYSQLI_ASYNC);
上述代码展示了两个独立的连接分别执行查询。由于使用了 MYSQLI_ASYNC，query() 调用不会阻塞，而是立即返回一个结果集对象（如果语法正确）或 false（如果语法错误）。此时，数据库服务器正在后台处理这些查询，PHP 脚本可以继续执行其他逻辑，或者进入轮询阶段。这种分离确保了网络 I/O 和 CPU 处理的重叠，提高了并发处理能力。
安装、修复、更新或打包一个基于 Python 和 PyMySQL 实现的 Windows `mysql` 命令。适用于用户希望在 PowerShell/CMD 中输入 `mysql` 时重定向到 Python 实现、需要交互式输入 MySQL 连接信息、需要同步到当前用户本地 bin 目录，或需要将该能力封装成可公开复用的 Codex skill。
如何使用 poll() 检测查询完成状态？
当异步查询发出后，需要使用 mysqli::poll() 函数来定期检查哪些连接已经完成了查询并可以读取结果。poll() 接受一个由 mysqli 对象组成的数组，以及可选的超时时间和最大重试次数。它会阻塞直到至少有一个连接准备好，或者超时发生。一旦某个连接被标记为“准备好”，就可以安全地调用 store_result() 来获取完整的结果集，或者迭代 use_result() 来逐行读取数据。
$links = [$link1, $link2];
$max_wait_time = 5; // 秒
$max_retries = 10;
$ready = mysqli_poll($links, $error, $retry, $max_wait_time);
if ($ready === false) {
echo "Poll failed or timed out.";
} else {
foreach ($ready as $link) {
if ($link->connect_errno) {
echo "Connection error: " . $link->connect_error;
} else {
// 获取结果
$result = $link->store_result();
while ($row = $result->fetch_assoc()) {
print_r($row);
}
$result->free();
}
}
}
在这个示例中，mysqli_poll() 会阻塞最多 5 秒，直到 $link1 或 $link2 中的至少一个有数据可读。如果有多个连接同时准备好，它们都会出现在 $ready 数组中。开发者需要遍历这个数组，对每个准备好的连接进行结果处理。如果在指定时间内没有任何连接准备好，poll() 将返回 false 或空数组，具体取决于实现细节和超时设置。这种机制允许程序高效地管理多个并发数据库操作，避免线程阻塞。
异步查询中如何处理连接错误和超时？
在使用 MYSQLI_ASYNC 和 poll() 时，必须妥善处理网络连接中断、查询超时或服务器拒绝连接等异常情况。例如，如果某个连接在查询期间断开，poll() 可能仍然返回该连接，但随后的 store_result() 调用会失败。因此，在获取结果前，应检查 mysqli 对象的 connect_errno 属性。此外，poll() 的超时参数至关重要，它防止程序无限期挂起。如果查询耗时过长，可能需要调整 SQL 语句或增加超时限制，而不是依赖更长的轮询时间。
$links = [$link1, $link2];
$timeout = 10;
$ready = mysqli_poll($links, $error, $retry, $timeout);
if (empty($ready)) {
echo "No connections ready within timeout.";
} else {
foreach ($ready as $link) {
if ($link->connect_errno) {
echo "Error on link: " . $link->connect_error;
continue;
}
// 尝试获取结果
$result = @$link->store_result();
if (!$result) {
echo "Failed to store result for link. 
