MySQL Poll

mysqli-poll.php

<?php
$queryConnection = new \mysqli($host, $username, $password, $database);
$killConnection = new \mysqli($host, $username, $password, $database);

// Execute the query
$queryConnection->query($sql, MYSQLI_ASYNC | MYSQLI_USE_RESULT);

// Poll for results
$start = microtime(true);
do {
    $connections = [$queryConnection];
    $error = [];
    $reject = [];
    if ($queryConnection->poll($connections, $error, $reject, 0, 500 * 1000)) {
        break;
    }
    $executionTime = microtime(true) - $start;
    if ($executionTime > $maxExecutionTime / 1000) {
        $killConnection->query('KILL QUERY ' . $queryConnection->thread_id);
        throw new \Exception('Query took too long: ' . round($executionTime, 4));
    }
} while (true);