PHP异步mysql查询

Question

我的应用程序首先查询2个大型数据集，然后对第一组数据做一些工作，然后在第二组数据上“使用”它。

如果可能的话，我希望它只是同步查询第一个集合，第二个集合是异步查询的，对第一个集合进行处理，然后等待第二个集合的查询完成最后使用它上面的第一组数据。

这是可能以某种方式？

Answer 1

这是可能的。

$mysqli->query($long_running_sql, MYSQLI_ASYNC); 

echo 'run other stuff'; 

$result = $mysqli->reap_async_query(); //gives result (and blocks script if query is not done) 
$resultArray = $result->fetch_assoc(); 

或者你可以使用mysqli_poll，如果你不希望有一个阻塞调用

http://php.net/manual/en/mysqli.poll.php

Answer 2

MySQL的要求，一个连接里面，查询完全处理before the next query is launched。那includes the fetching of all results。

这是可能的，但是，到：

• 通过建立多个连接

默认情况下，在一次

推出多个查询获取结果的一个，而不是所有的一个，PHP将等待直到全部结果可用，然后在内部（在mysql驱动程序中）一次获取所有结果。即使在使用例如PDOStatement::fetch()将其一次一行地导入到您的代码中时也是如此。使用PDO时，可以通过将属性\PDO::MYSQL_ATTR_USE_BUFFERED_QUERY设置为false来防止这种情况。这是有用的：

• 加快查询结果的处理：你的代码can start processing as soon as one row is found而不是仅仅后每行找到。
• 使用的结果集可能大于PHP可用的内存（PHP自带的memory_limit或RAM内存）。

请注意，速度通常受到存储系统的限制，其特征意味着两个查询的总处理时间在同时运行时的总处理时间大于逐个运行它们的总处理时间。

一个例子（可以完全做到在MySQL，但表示其原理...）：

$dbConnectionOne = new \PDO('mysql:hostname=localhost;dbname=test', 'user', 'pass'); 
$dbConnectionOne->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION); 

$dbConnectionTwo = new \PDO('mysql:hostname=localhost;dbname=test', 'user', 'pass'); 
$dbConnectionTwo->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION); 
$dbConnectionTwo->setAttribute(\PDO::MYSQL_ATTR_USE_BUFFERED_QUERY, false); 

$synchStmt = $dbConnectionOne->prepare('SELECT id, name, factor FROM measurementConfiguration'); 
$synchStmt->execute(); 

$asynchStmt = $dbConnectionTwo->prepare('SELECT measurementConfiguration_id, timestamp, value FROM hugeMeasurementsTable'); 
$asynchStmt->execute(); 

$measurementConfiguration = array(); 
foreach ($synchStmt->fetchAll() as $synchStmtRow) { 
    $measurementConfiguration[$synchStmtRow['id']] = array(
     'name' => $synchStmtRow['name'], 
     'factor' => $synchStmtRow['factor'] 
    ); 
} 

while (($asynchStmtRow = $asynchStmt->fetch()) !== false) { 
    $currentMeasurementConfiguration = $measurementConfiguration[$asynchStmtRow['measurementConfiguration_id']]; 
    echo 'Measurement of sensor ' . $currentMeasurementConfiguration['name'] . ' at ' . $asynchStmtRow['timestamp'] . ' was ' . ($asynchStmtRow['value'] * $currentMeasurementConfiguration['factor']) . PHP_EOL; 
}