mysqli_poll()

Funkcija mysqli_poll() se uporablja za pregledovanje (anketiranje) seznama povezav, na katerih smo sprožili asinhrone poizvedbe z uporabo zastavice MYSQLI_ASYNC. V kodi bomo odprli 10 vzporednih povezav, ki bodo hkrati brale te podatke, funkcija mysqli_poll() pa bo preverila, katera je prva končala.

PRIMER

<?php
$sql = "SELECT * FROM mysqli_tabela";
$vse_povezave = array();

// Odpremo 10 povezav in sprožimo asinhrone poizvedbe
for ($i = 0; $i < 10; $i++) {
    $pov = mysqli_connect("localhost", "root", "", "mysqli_baza_podatkov");
    // MYSQLI_ASYNC bazi naroči, naj takoj vrne nadzor PHP-ju, medtem ko v ozadju išče podatke
    $pov->query($sql, MYSQLI_ASYNC);
    $vse_povezave[] = $pov;
}

$obdelano = 0;
do {
    $povezave = $errors = $reject = $vse_povezave;
    
    // Anketiranje povezav (timeout nastavljen na 1 sekundo)
    // OPOMBA: Funkcija mysqli_poll() preveri, katere od asinhronih povezav so 
    // že končale z iskanjem podatkov in so pripravljene na prevzem rezultatov. Spremenljivke 
    // $povezave, $errors in $reject se avtomatsko napolnijo z ustreznimi objekti.
    if (!mysqli_poll($povezave, $errors, $reject, 1)) {
        continue;
    }

    foreach ($povezave as $pov) {
        // reap_async_query() pobere pripravljen rezultat iz asinhrono dokončane poizvedbe
        if ($rezultat = $pov->reap_async_query()) {
            // Izpišemo surovo prvo vrstico z uporabo print_r
            print_r($rezultat->fetch_row()); echo "<br>";
            echo "<br>";
            mysqli_free_result($rezultat);
        } else {
            die(mysqli_error($pov));
        }
        $obdelano++;
    }
} while ($obdelano < count($vse_povezave));

foreach ($vse_povezave as $pov) {
    mysqli_close($pov);
}
?>

REZULTAT

Tu bo prikazan rezultat...

Uporaba v praksi: To je vrhunska tehnika za optimizacijo. Namesto da bi PHP čakal na odgovor ene poizvedbe, da lahko pošlje naslednjo, jih pošlje vse hkrati. To drastično skrajša čas nalaganja strani pri delu z velikimi količinami podatkov.

Vzporedno izvajanje 10 ali več poizvedb hkrati.
Uporaba metode reap_async_query() za prevzem rezultatov.
Bistveno povečanje odzivnosti aplikacije pri kompleksnih operacijah.