Leer datos

Overview

En esta página, puede ver ejemplos de código copiables que muestran métodos de controlador Scala comunes que puede usar para leer datos de MongoDB.

Tip

Para obtener más información sobre cualquiera de los métodos que se muestran en esta página, consulte el enlace proporcionado en cada sección.

Para utilizar un ejemplo de esta página, copie el ejemplo de código en el Aplicación de ejemplo o su propia aplicación. Asegúrese de reemplazar todos los marcadores de posición en los ejemplos de código, como <connection string URI>, con los valores relevantes para su implementación de MongoDB.

Aplicación de muestra

Puede utilizar la siguiente aplicación de muestra para probar los ejemplos de código en esta página. Para usar la aplicación de muestra, siga los siguientes pasos:

Asegúrese de tener el controlador Scala instalado en su proyecto Maven o sbt.
Copia el siguiente código y pégalo en un nuevo archivo .scala.
Copia un ejemplo de código de esta página y pégalo en las líneas especificadas del archivo.

1 import org.mongodb.scala._
2 import org.mongodb.scala.bson.Document
3 import org.mongodb.scala.model.Filters._
4 import org.mongodb.scala.model.changestream._
5 
6 object SampleReadApp {
7 
8   def main(args: Array[String]): Unit = {
9     val mongoClient = MongoClient("<connection string URI>")
10     val database: MongoDatabase = mongoClient.getDatabase("<database name>")
11     val collection: MongoCollection[Document] = database.getCollection("<collection name>")
12 
13 
14     // Start example code here
15 
16     // End example code here
17 
18     // Wait for the operations to complete before closing client
19     // Note: This example uses Thread.sleep() for brevity and does not guarantee all
20     // operations will be completed in time
21     Thread.sleep(1000)
22     mongoClient.close()
23   }
24 }

Encontrar uno

El siguiente ejemplo recupera un documento que coincide con los criterios especificados por el filtro dado:

val filter = equal("<field>", "<value>")
collection.find(filter).first().subscribe((doc: Document) => println(doc.toJson()),
  (e: Throwable) => println(s"There was an error: $e"))

Para obtener más información sobre el método first(), consulte la Guíade recuperación de datos.

Encontrar varios

El siguiente ejemplo recupera todos los documentos que coinciden con los criterios especificados por el filtro dado:

val filter = equal("<field>", "<value>")
collection.find(filter).subscribe((doc: Document) => println(doc.toJson()),
  (e: Throwable) => println(s"There was an error: $e"))

Para obtener más información sobre el find() método, consulte la guía Recuperar datos.

Contar documentos en una colección

El siguiente ejemplo devuelve el número de documentos en la colección especificada:

collection.countDocuments()
  .subscribe((count: Long) => println(s"Number of documents: $count"),
    (e: Throwable) => println(s"There was an error: $e"))

Para obtener más información sobre el countDocuments() método, consulte la guía Contar documentos.

Contar documentos devueltos de una query

El siguiente ejemplo devuelve la cantidad de documentos en la colección especificada que coinciden con los criterios de consulta:

collection.countDocuments(equal("<field>", "<value>"))
  .subscribe((count: Long) => println(s"Number of documents: $count"),
    (e: Throwable) => println(s"There was an error: $e"))

Para obtener más información sobre el countDocuments() método, consulte la guía Contar documentos.

Recuento estimado de documentos

El siguiente ejemplo devuelve un número aproximado de documentos en la colección especificada según los metadatos de la colección:

collection.estimatedDocumentCount()
  .subscribe((count: Long) => println(s"Estimated number of documents: $count"),
    (e: Throwable) => println(s"There was an error: $e"))

Para obtener más información sobre el estimatedDocumentCount() método, consulte la guía Contar documentos.

Retrieve Distinct Values

El siguiente ejemplo devuelve todos los valores distintos del nombre de campo especificado en una colección determinada:

collection.distinct("<field>")
  .subscribe((value: String) => println(value),
    (e: Throwable) => println(s"There was an error: $e"))

Para obtener más información sobre el método distinct(), consulta la guía Recuperar Valores Únicos de Campo.

Supervisar los cambios en los datos

El siguiente ejemplo crea un flujo de cambios para una colección determinada e imprime los eventos de cambio posteriores en esa colección:

val changeStreamObservable = collection.watch()
changeStreamObservable.subscribe(
  (changeEvent: ChangeStreamDocument[Document]) => {
    println(s"Received a change to the collection: ${changeEvent}")
  },
  (e: Throwable) => {
    println(s"Encountered an error: ${e.getMessage}")
  },
  () => println("Completed")
)

Para obtener más información sobre el watch() método, consulte la guía Monitorear cambios en los datos.

Volver

Time Series

Retrieve Data

1	import org.mongodb.scala._
2	import org.mongodb.scala.bson.Document
3	import org.mongodb.scala.model.Filters._
4	import org.mongodb.scala.model.changestream._
5
6	object SampleReadApp {
7
8	def main(args: Array[String]): Unit = {
9	val mongoClient = MongoClient("<connection string URI>")
10	val database: MongoDatabase = mongoClient.getDatabase("<database name>")
11	val collection: MongoCollection[Document] = database.getCollection("<collection name>")
12
13
14	// Start example code here
15
16	// End example code here
17
18	// Wait for the operations to complete before closing client
19	// Note: This example uses Thread.sleep() for brevity and does not guarantee all
20	// operations will be completed in time
21	Thread.sleep(1000)
22	mongoClient.close()
23	}
24	}