Overview
En esta guía, puedes aprender cómo ejecutar un comando de base de datos con el driver Java Reactive Streams. Puedes usar comandos de base de datos para realizar una variedad de tareas administrativas y de diagnóstico, como obtener estadísticas del servidor, iniciar un set de réplicas o ejecutar una pipeline de agregación.
Tip
Prefiera los métodos de controlador por sobre los comandos de base de datos
El driver proporciona métodos para muchos comandos de base de datos. Se recomienda utilizar métodos del controlador en lugar de ejecutar comandos de base de datos cuando sea posible.
Para realizar tareas administrativas, utiliza la MongoDB Shell en lugar del driver de Java Reactive Streams. Llamar al método db.runCommand() del MongoDB Shell es el método preferido para emitir comandos de base de datos, ya que proporciona una interfaz coherente entre el shell y los drivers.
Importante
Proyecto Reactor librería
Esta guía usa la librería Proyecto Reactor para consumir instancias Publisher devueltas por los métodos del driver Reactive Streams de Java. Para obtener más información sobre la biblioteca Project Reactor y cómo utilizarla, consulta Primeros pasos en la documentación de Reactor. Para obtener más información sobre cómo utilizamos los métodos de la librería Project Reactor en esta guía, consulta la guía Guardar datos en MongoDB.
Ejecute un comando
Para ejecutar un comando de base de datos, especifica el comando en un documento y pásalo al método runCommand(). El siguiente código llama al método runCommand() en una base de datos para ejecutar el comando ping, que es un comando sin efecto utilizado para probar si un servidor responde.
Document command = new Document("ping", 1); Publisher<Document> commandPublisher = database.runCommand(command); Document result = Mono.from(commandPublisher).block(); System.out.println(result);
Document{{ok=1}}
Información Adicional
Para ver una lista completa de los comandos de bases de datos y sus parámetros disponibles, consulte Comandos de base de datos en el manual de MongoDB Server.
Documentación de la API
Para obtener más información sobre el método runCommand(), consulte la documentación de la API runCommand().