pg_connect_poll

<?php
// Asynchrone Verbindung initiieren
$conn = pg_connect('host=localhost dbname=testdb user=postgres password=secret', PGSQL_CONNECT_ASYNC);

if (!$conn) {
    die('Fehler beim Initiieren der asynchronen Verbindung');
}

// Polling-Schleife: Status regelmäßig prüfen
do {
    $status = pg_connect_poll($conn);

    switch ($status) {
        case PGSQL_POLLING_READING:
            echo "Warte auf lesbare Daten...\n";
            // Hier könnten andere Aufgaben erledigt werden
            break;
        case PGSQL_POLLING_WRITING:
            echo "Warte auf schreibbare Daten...\n";
            break;
        case PGSQL_POLLING_ACTIVE:
            echo "Verbindungsaufbau aktiv...\n";
            break;
        case PGSQL_POLLING_OK:
            echo "Verbindung erfolgreich hergestellt!\n";
            break;
        case PGSQL_POLLING_FAILED:
            die("Verbindungsaufbau fehlgeschlagen!\n");
    }

    // Kurz warten, um CPU-Last zu reduzieren
    usleep(1000);
} while ($status !== PGSQL_POLLING_OK && $status !== PGSQL_POLLING_FAILED);

// Verbindung verwenden
$result = pg_query($conn, 'SELECT version()');
echo pg_fetch_result($result, 0, 0) . "\n";

pg_close($conn);

<?php
$dsns = [
    'host=db1.example.com dbname=app user=postgres',
    'host=db2.example.com dbname=app user=postgres',
];

// Alle Verbindungen asynchron starten
$connections = [];
foreach ($dsns as $dsn) {
    $conn = pg_connect($dsn, PGSQL_CONNECT_ASYNC);
    if ($conn) {
        $connections[] = $conn;
    }
}

// Alle Verbindungen parallel pollen
$pending = count($connections);
while ($pending > 0) {
    foreach ($connections as $key => $conn) {
        $status = pg_connect_poll($conn);
        if ($status === PGSQL_POLLING_OK) {
            echo "Verbindung #{$key} bereit.\n";
            unset($connections[$key]);
            $pending--;
        } elseif ($status === PGSQL_POLLING_FAILED) {
            echo "Verbindung #{$key} fehlgeschlagen.\n";
            unset($connections[$key]);
            $pending--;
        }
    }
    usleep(500);
}

echo "Alle Verbindungen abgeschlossen.\n";