AsyncMysqlQueryErrorResult::getSuccessfulResults
Returns the results that were fetched by the successful query statements
public function getSuccessfulResults(): Vector<AsyncMysqlQueryResult>;
Returns
Vector<AsyncMysqlQueryResult>
- AVector
ofAsyncMysqlQueryResult
objects for each result produced by a successful query statement.
Examples
This example shows how we can get the successful results of a multi-query, even though one of those queries gave us an error (which we caught in the exception). This is done via AsyncMysqlQueryErrorResult::getSuccessfulResults
.
use \Hack\UserDocumentation\API\Examples\AsyncMysql\ConnectionInfo as CI;
async function connect(
\AsyncMysqlConnectionPool $pool,
): Awaitable<\AsyncMysqlConnection> {
return await $pool->connect(
CI::$host,
CI::$port,
CI::$db,
CI::$user,
CI::$passwd,
);
}
async function multi_query_error(): Awaitable<?int> {
$queries = Vector {
'SELECT name FROM test_table WHERE userID = 1',
'SELECT age, email FROM test_table WHERE userID = 2',
'SELECT bogus FROM bogus WHERE bogus = 1',
};
$pool = new \AsyncMysqlConnectionPool(darray[]);
$conn = await connect($pool);
try {
$result = await $conn->multiQuery($queries);
} catch (\AsyncMysqlQueryException $ex) {
$qr = $ex->getResult();
\var_dump($qr is \AsyncMysqlQueryErrorResult);
// Constructor to the exception takes AsyncMysqlErrorResult, need to
// ensure typechecker that we have an AsyncMysqlQueryErrorResult
invariant($qr is \AsyncMysqlQueryErrorResult, "Bad news if not");
$rows = 0;
// Ok, we had an error in our multiquery, but maybe we had some
// successful results in some of the queries.
if (\array_key_exists(0, $qr->getSuccessfulResults())) {
$rows = $qr->getSuccessfulResults()[0]->numRows();
}
\var_dump($rows);
$conn->close();
return null;
}
$conn->close();
return $result->numRows();
}
<<__EntryPoint>>
async function run(): Awaitable<void> {
$r = await multi_query_error();
\var_dump($r);
}
```.hhvm.expectf
bool(true)
int(%d)
NULL
```.example.hhvm.out
bool(true)
int(1)
NULL
```.skipif
await \Hack\UserDocumentation\API\Examples\AsyncMysql\skipif_async();