fbird_set_event_handler

<?php
// Verbindung zur Firebird-Datenbank herstellen
$dbh = fbird_connect('localhost:/path/to/database.fdb', 'SYSDBA', 'masterkey');

// Callback-Funktion definieren
function meinEreignisHandler(string $ereignisName, int $anzahl): void
{
    echo "Ereignis '{$ereignisName}' wurde {$anzahl} Mal ausgelöst." . PHP_EOL;
}

// Event-Handler registrieren
$handler = fbird_set_event_handler('meinEreignisHandler', 'NEUER_AUFTRAG', 'AUFTRAG_GEAENDERT');

if ($handler === false) {
    die('Fehler beim Registrieren des Event-Handlers.');
}

echo 'Event-Handler registriert. Warte auf Ereignisse...' . PHP_EOL;

// Auf Ereignisse warten (blockiert bis ein Ereignis eintrifft)
fbird_wait_event($dbh, 'NEUER_AUFTRAG', 'AUFTRAG_GEAENDERT');

// Handler wieder freigeben
fbird_free_event_handler($handler);

fbird_close($dbh);
?>

<?php
$dbh = fbird_connect('localhost:/data/meine_db.fdb', 'SYSDBA', 'masterkey');

// Anonyme Callback-Funktion mit Closure
$handler = fbird_set_event_handler(
    function (string $ereignis, int $anzahl) use ($dbh): void {
        echo date('H:i:s') . " | Ereignis: {$ereignis} | Anzahl: {$anzahl}" . PHP_EOL;

        // Auf neue Datensätze reagieren
        if ($ereignis === 'LAGER_AKTUALISIERT') {
            $result = fbird_query($dbh, 'SELECT * FROM lager WHERE status = 0');
            while ($row = fbird_fetch_assoc($result)) {
                echo '  -> Artikel: ' . $row['ARTIKEL_NR'] . ' | Menge: ' . $row['MENGE'] . PHP_EOL;
            }
        }
    },
    'LAGER_AKTUALISIERT',
    'LAGER_FEHLER'
);

if ($handler) {
    // Auf Ereignisse warten
    fbird_wait_event($dbh, 'LAGER_AKTUALISIERT', 'LAGER_FEHLER');
    fbird_free_event_handler($handler);
}

fbird_close($dbh);
?>