Bases de datos y colecciones

Overview

En esta guía, puedes aprender cómo interactuar con bases de datos y colecciones de MongoDB utilizando el controlador de Scala.

MongoDB organiza los datos en una jerarquía de los siguientes niveles:

• Bases de datos: Estructuras de datos de nivel superior en una implementación de MongoDB que almacenan colecciones.

• Colecciones: Grupos de documentos de MongoDB. Son análogos a las tablas en bases de datos relacionales.

• Documentos: Unidades que almacenan datos literales como cadenas, números, fechas y otros documentos incrustados. Para obtener más información sobre los tipos de campos de documentos y la estructura, consulta la guía Documentos en el manual de MongoDB Server.

Acceder a una base de datos

Accede a una base de datos llamando al método getDatabase() en una instancia de MongoClient.

El siguiente ejemplo accede a una base de datos llamada "test_database":

val database = mongoClient.getDatabase("test_database")

Acceder a una colección

Accede a una colección llamando al método getCollection() en una instancia de MongoDatabase.

El siguiente ejemplo accede a una colección llamada "test_collection":

val collection = database.getCollection("test_collection")

Crear una colección

Utiliza el método createCollection() en una instancia MongoDatabase para crear explícitamente una colección en una base de datos.

El siguiente ejemplo crea una colección llamada "example_collection":

val createObservable = database.createCollection("example_collection")
Await.result(createObservable.toFuture(), Duration(10, TimeUnit.SECONDS))

Puedes especificar las opciones de la colección, como el tamaño máximo y las reglas de validación de documentos, pasando una instancia de CreateCollectionOptions al método createCollection(). Para obtener una lista completa de parámetros opcionales, consulte la documentación del comando create en el manual del MongoDB Server.

Obtén una lista de colecciones

Puedes solicitar una lista de colecciones en una base de datos llamando al método listCollections() de una instancia MongoDatabase.

El siguiente ejemplo enumera todas las colecciones en una base de datos:

val results = Await.result(database.listCollections().toFuture(), Duration(10, TimeUnit.SECONDS))
results.foreach(println)

Iterable((name,BsonString{value='test_collection'}), (type,BsonString{value='collection'}), ... )
Iterable((name,BsonString{value='example_collection'}), (type,BsonString{value='collection'}), ... )

Para hacer un query para solo los nombres de las colecciones en la base de datos, lleva a cabo el método listCollectionNames() de la siguiente manera:

val results = Await.result(database.listCollectionNames().toFuture(), Duration(10, TimeUnit.SECONDS))
results.foreach(println)

test_collection
example_collection

Borrar una colección

Puedes borrar una colección llamando al método drop() en una instancia de MongoCollection.

El siguiente ejemplo elimina la colección test_collection:

val deleteObservable = database.getCollection("test_collection").drop()
Await.result(deleteObservable.toFuture(), Duration(10, TimeUnit.SECONDS))

Borrar una base de datos

Puedes borrar una base de datos llamando al método drop() en una instancia MongoDatabase.

El siguiente ejemplo borra la base de datos test_database:

var database = mongoClient.getDatabase("test_database")
val deleteObservable = database.drop()
Await.result(deleteObservable.toFuture(), Duration(10, TimeUnit.SECONDS))

Configurar operaciones de lectura y guardar

Puedes controlar cómo el driver direcciona las operaciones de lectura configurando una preferencia de lectura. También puede controlar las opciones de cómo el driver espera la confirmación de las operaciones de lectura y escritura en un set de réplicas configurando un nivel de consistencia de lectura y un nivel de confirmación de escritura (write concern).

Por defecto, las bases de datos heredan estas configuraciones de la instancia de MongoClient, y las colecciones las heredan de la base de datos. Sin embargo, puedes cambiar estos ajustes en tu base de datos utilizando el método withReadPreference().

El siguiente ejemplo accede a una base de datos mientras especifica la preferencia de lectura de la base de datos como secondary:

val databaseWithReadPrefs =
    mongoClient.getDatabase("test_database").withReadPreference(ReadPreference.secondary())

También se pueden cambiar los ajustes de lectura y escritura de las colecciones utilizando el método withReadPreference(). El siguiente ejemplo muestra cómo acceder a una colección especificando la preferencia de lectura de la colección como secondary:

val collectionWithReadPrefs =
    database.getCollection("test_collection").withReadPreference(ReadPreference.secondary())

Para obtener más información sobre la configuración de lectura y escritura, consulta las siguientes guías en el manual del servidor MongoDB:

• preferencia de lectura

• readConcern

• Nivel de confirmación de escritura

val tag1 = new Tag("dc", "ny")
val tag2 = new Tag("dc", "sf")
val tagSet = new TagSet(List(tag1, tag2).asJava)
val connectionString = ConnectionString("<connection string URI>")
val readPreference = ReadPreference.primaryPreferred(tagSet)
val mongoClientSettings = MongoClientSettings.builder()
  .applyConnectionString(connectionString)
  .readPreference(readPreference)
  .build()
val clientWithTags = MongoClient(mongoClientSettings)

val connectionString = ConnectionString("mongodb://localhost:27017")
val mongoClientSettings = MongoClientSettings.builder()
  .applyConnectionString(connectionString)
  .applyToClusterSettings(builder => builder.localThreshold(35, TimeUnit.MILLISECONDS))
  .build()
val client = MongoClient(mongoClientSettings)

Documentación de la API

Para aprender más sobre cualquiera de los tipos o métodos discutidos en esta guía, consulta la siguiente documentación de la API:

• MongoClient

• MongoDatabase

• MongoCollection

• CreateCollectionOptions

• ClusterSettings

• MongoClientSettings