MysqlndUhConnection::reapQuery
(PECL mysqlnd-uh >= 1.0.0-alpha)
MysqlndUhConnection::reapQuery — Get result from async query
Description
public bool MysqlndUhConnection::reapQuery
( mysqlnd_connection
$connection
)Get result from async query.
Parameters
-
connection -
Mysqlnd connection handle. Do not modify!
Return Values
Returns TRUE on success.
Otherwise, returns FALSE
Examples
Example #1 MysqlndUhConnection::reapQuery() example
<?php
class proxy extends MysqlndUhConnection {
public function reapQuery($res) {
printf("%s(%s)\n", __METHOD__, var_export(func_get_args(), true));
$ret = parent::reapQuery($res);
printf("%s returns %s\n", __METHOD__, var_export($ret, true));
return $ret;
}
}
mysqlnd_uh_set_connection_proxy(new proxy());
$conn1 = new mysqli("localhost", "root", "", "test");
$conn2 = new mysqli("localhost", "root", "", "test");
$conn1->query("SELECT 1 as 'one', SLEEP(1) AS _sleep FROM DUAL", MYSQLI_ASYNC | MYSQLI_USE_RESULT);
$conn2->query("SELECT 1.1 as 'one dot one' FROM DUAL", MYSQLI_ASYNC | MYSQLI_USE_RESULT);
$links = array(
$conn1->thread_id => array('link' => $conn1, 'processed' => false),
$conn2->thread_id => array('link' => $conn2, 'processed' => false)
);
$saved_errors = array();
do {
$poll_links = $poll_errors = $poll_reject = array();
foreach ($links as $thread_id => $link) {
if (!$link['processed']) {
$poll_links[] = $link['link'];
$poll_errors[] = $link['link'];
$poll_reject[] = $link['link'];
}
}
if (0 == count($poll_links))
break;
if (0 == ($num_ready = mysqli_poll($poll_links, $poll_errors, $poll_reject, 0, 200000)))
continue;
if (!empty($poll_errors)) {
die(var_dump($poll_errors));
}
foreach ($poll_links as $link) {
$thread_id = mysqli_thread_id($link);
$links[$thread_id]['processed'] = true;
if (is_object($res = mysqli_reap_async_query($link))) {
// result set object
while ($row = mysqli_fetch_assoc($res)) {
// eat up all results
var_dump($row);
}
mysqli_free_result($res);
} else {
// either there is no result (no SELECT) or there is an error
if (mysqli_errno($link) > 0) {
$saved_errors[$thread_id] = mysqli_errno($link);
printf("'%s' caused %d\n", $links[$thread_id]['query'], mysqli_errno($link));
}
}
}
} while (true);
?>
The above example will output:
proxy::reapQuery(array (
0 => NULL,
))
proxy::reapQuery returns true
array(1) {
["one dot one"]=>
string(3) "1.1"
}
proxy::reapQuery(array (
0 => NULL,
))
proxy::reapQuery returns true
array(2) {
["one"]=>
string(1) "1"
["_sleep"]=>
string(1) "0"
}
See Also
- mysqlnd_uh_set_connection_proxy() - Installs a proxy for mysqlnd connections
- mysqli_real_async_query()
- PHP Руководство
- Функции по категориям
- Индекс функций
- Справочник функций
- Расширения для работы с базами данных
- Расширения для работы с базами данных отдельных производителей
- MySQL Drivers and Plugins
- Mysqlnd user handler plugin
- Функция MysqlndUhConnection::changeUser() - Changes the user of the specified mysqlnd database connection
- Функция MysqlndUhConnection::charsetName() - Returns the default character set for the database connection
- Функция MysqlndUhConnection::close() - Closes a previously opened database connection
- Функция MysqlndUhConnection::connect() - Open a new connection to the MySQL server
- Функция MysqlndUhConnection::__construct() - The __construct purpose
- Функция MysqlndUhConnection::endPSession() - End a persistent connection
- MysqlndUhConnection::escapeString
- Функция MysqlndUhConnection::getAffectedRows() - Gets the number of affected rows in a previous MySQL operation
- Функция MysqlndUhConnection::getErrorNumber() - Returns the error code for the most recent function call
- Функция MysqlndUhConnection::getErrorString() - Returns a string description of the last error
- Функция MysqlndUhConnection::getFieldCount() - Returns the number of columns for the most recent query
- Функция MysqlndUhConnection::getHostInformation() - Returns a string representing the type of connection used
- Функция MysqlndUhConnection::getLastInsertId() - Returns the auto generated id used in the last query.
- Функция MysqlndUhConnection::getLastMessage() - Retrieves information about the most recently executed query
- Функция MysqlndUhConnection::getProtocolInformation() - Returns the version of the MySQL protocol used
- Функция MysqlndUhConnection::getServerInformation() - Returns the version of the MySQL server
- Функция MysqlndUhConnection::getServerStatistics() - Gets the current system status
- Функция MysqlndUhConnection::getServerVersion() - Returns the version of the MySQL server as an integer
- Функция MysqlndUhConnection::getSqlstate() - Returns the SQLSTATE error from previous MySQL operation
- Функция MysqlndUhConnection::getStatistics() - Returns statistics about the client connection.
- Функция MysqlndUhConnection::getThreadId() - Returns the thread ID for the current connection
- Функция MysqlndUhConnection::getWarningCount() - Returns the number of warnings from the last query for the given link
- Функция MysqlndUhConnection::init() - Initialize mysqlnd connection
- Функция MysqlndUhConnection::killConnection() - Asks the server to kill a MySQL thread
- Функция MysqlndUhConnection::listFields() - List MySQL table fields
- Функция MysqlndUhConnection::listMethod() - Wrapper for assorted list commands
- Функция MysqlndUhConnection::moreResults() - Check if there are any more query results from a multi query
- Функция MysqlndUhConnection::nextResult() - Prepare next result from multi_query
- Функция MysqlndUhConnection::ping() - Pings a server connection, or tries to reconnect if the connection has gone down
- Функция MysqlndUhConnection::query() - Performs a query on the database
- Функция MysqlndUhConnection::queryReadResultsetHeader() - Read a result set header
- Функция MysqlndUhConnection::reapQuery() - Get result from async query
- Функция MysqlndUhConnection::refreshServer() - Flush or reset tables and caches
- Функция MysqlndUhConnection::restartPSession() - Restart a persistent mysqlnd connection
- Функция MysqlndUhConnection::selectDb() - Selects the default database for database queries
- Функция MysqlndUhConnection::sendClose() - Sends a close command to MySQL
- Функция MysqlndUhConnection::sendQuery() - Sends a query to MySQL
- Функция MysqlndUhConnection::serverDumpDebugInformation() - Dump debugging information into the log for the MySQL server
- Функция MysqlndUhConnection::setAutocommit() - Turns on or off auto-committing database modifications
- Функция MysqlndUhConnection::setCharset() - Sets the default client character set
- Функция MysqlndUhConnection::setClientOption() - Sets a client option
- Функция MysqlndUhConnection::setServerOption() - Sets a server option
- Функция MysqlndUhConnection::shutdownServer() - The shutdownServer purpose
- Функция MysqlndUhConnection::simpleCommand() - Sends a basic COM_* command
- Функция MysqlndUhConnection::simpleCommandHandleResponse() - Process a response for a basic COM_* command send to the client
- Функция MysqlndUhConnection::sslSet() - Used for establishing secure connections using SSL
- Функция MysqlndUhConnection::stmtInit() - Initializes a statement and returns a resource for use with mysqli_statement::prepare
- Функция MysqlndUhConnection::storeResult() - Transfers a result set from the last query
- Функция MysqlndUhConnection::txCommit() - Commits the current transaction
- Функция MysqlndUhConnection::txRollback() - Rolls back current transaction
- Функция MysqlndUhConnection::useResult() - Initiate a result set retrieval
Коментарии
404 Not Found