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; 
}