MongoDB\ChangeStream::current()

Definición

MongoDB\ChangeStream::current()

Devuelve el evento actual en el flujo de cambios.

function current(): array|object|null

La estructura de cada documento de evento variará según el tipo de operación. Ver Cambiar eventos en el manual de MongoDB para obtener más información.

Return Values

Una matriz u objeto para el evento actual en el flujo de cambios, o null si no hay ningún evento actual (es decir, MongoDB\ChangeStream::valid() falsedevuelve). El tipo de retorno dependerá de la typeMap opción MongoDB\Collection::watch() para.

Ejemplos

Este ejemplo informa eventos mientras se itera un flujo de cambios.

<?php
$uri = 'mongodb://rs1.example.com,rs2.example.com/?replicaSet=myReplicaSet';
$collection = (new MongoDB\Client($uri))->test->inventory;
$changeStream = $collection->watch();
for ($changeStream->rewind(); true; $changeStream->next()) {
    if ( ! $changeStream->valid()) {
        continue;
    }
    $event = $changeStream->current();
    $ns = sprintf('%s.%s', $event['ns']['db'], $event['ns']['coll']);
    $id = json_encode($event['documentKey']['_id']);
    switch ($event['operationType']) {
        case 'delete':
            printf("Deleted document in %s with _id: %s\n\n", $ns, $id);
            break;
        case 'insert':
            printf("Inserted new document in %s\n", $ns);
            echo json_encode($event['fullDocument']), "\n\n";
            break;
        case 'replace':
            printf("Replaced new document in %s with _id: %s\n", $ns, $id);
            echo json_encode($event['fullDocument']), "\n\n";
            break;
        case 'update':
            printf("Updated document in %s with _id: %s\n", $ns, $id);
            echo json_encode($event['updateDescription']), "\n\n";
            break;
    }
}

Suponiendo que se insertó, actualizó y eliminó un documento mientras el script anterior iteraba el flujo de cambios, el resultado sería similar a lo siguiente:

Inserted new document in test.inventory
{"_id":{"$oid":"5a81fc0d6118fd1af1790d32"},"name":"Widget","quantity":5}
Updated document in test.inventory with _id: {"$oid":"5a81fc0d6118fd1af1790d32"}
{"updatedFields":{"quantity":4},"removedFields":[]}
Deleted document in test.inventory with _id: {"$oid":"5a81fc0d6118fd1af1790d32"}

Ver también

MongoDB\Client::watch()
MongoDB\Collection::watch()
MongoDB\Database::watch()
Iterator::current()
Iteración de cursor adaptable
Documentación de flujos de cambios en el manual de MongoDB
Documentación de eventos de cambio en el manual de MongoDB

Volver

ChangeStream

getCursorId()