Ejemplos de operaciones CRUD con POJO

Requisitos previos

Debe configurar los siguientes componentes para ejecutar los ejemplos de código en esta guía:

• Servidor MongoDB ejecutándose en el puerto por defecto de MongoDB (27017)

• Dependencia de controlador instalada en su proyecto

• Las siguientes instrucciones de importación:

  import com.mongodb.client.result.InsertOneResult;
  import com.mongodb.client.result.InsertManyResult;
  import com.mongodb.client.result.DeleteResult;
  import com.mongodb.client.result.UpdateResult;
  import com.mongodb.reactivestreams.client.MongoClient;
  import com.mongodb.reactivestreams.client.MongoClients;
  import com.mongodb.reactivestreams.client.MongoCollection;
  import com.mongodb.reactivestreams.client.MongoDatabase;
  import org.bson.codecs.configuration.CodecRegistry;
  import org.bson.codecs.pojo.PojoCodecProvider;
  import java.util.List;
  import static com.mongodb.client.model.Filters.*;
  import static com.mongodb.client.model.Updates.*;
  import static java.util.Arrays.asList;
  import static org.bson.codecs.configuration.CodecRegistries.fromProviders;
  import static org.bson.codecs.configuration.CodecRegistries.fromRegistries;

• Definiciones de clases POJO. Copia el código completo de los POJO Person y Address desde el repositorio fuente del controlador en GitHub:

  • Clase person

  • Clase de dirección

Creando un Registry de Codec personalizado

Antes de poder usar un POJO con el controlador, debe configurar el CodecRegistry para incluir un códec que gestione la traducción hacia y desde BSON para sus POJOs. La forma más sencilla de hacerlo es usar el método PojoCodecProvider.builder() para crear y configurar un CodecProvider.

El siguiente ejemplo combina el registro de códecs por defecto con la PojoCodecProvider configurada para crear automáticamente instancias de POJO Codec:

CodecRegistry pojoCodecRegistry = fromRegistries(
    MongoClientSettings.getDefaultCodecRegistry(),
    fromProviders(PojoCodecProvider.builder().automatic(true).build())
);

Insertar un POJO en MongoDB

El registro de codecs intenta automáticamente crear un POJO Codec para clases desconocidas. Esto te permite utilizar POJOs lista para usar sin ninguna configuración extra.

Antes de poder insertar un POJO en MongoDB, crea una instancia de MongoCollection configurada con la clase POJO:

MongoCollection<Person> collection = database.getCollection("people", Person.class);

Person ada = new Person("Ada Byron", 20, new Address("St James Square", "London", "W1"));
collection.insertOne(ada).subscribe(new OperationSubscriber<InsertOneResult>());

List<Person> people = asList(
    new Person("Charles Babbage", 45, new Address("5 Devonshire Street", "London", "W11")),
    new Person("Alan Turing", 28, new Address("Bletchley Hall", "Bletchley Park", "MK12")),
    new Person("Timothy Berners-Lee", 61, new Address("Colehill", "Wimborne", null))
);
collection.insertMany(people).subscribe(new OperationSubscriber<InsertManyResult>());

Consulta de la colección

Para query la colección, puedes utilizar el método find().

El siguiente ejemplo muestra todas las instancias de Person en la colección:

collection.find().subscribe(new PrintToStringSubscriber<>());

Person{id='...', name='Ada Byron', age=20, address=Address{street='St James Square', city='London', zip='W1'}}
Person{id='...', name='Charles Babbage', age=45, address=Address{street='5 Devonshire Street', city='London', zip='W11'}}
Person{id='...', name='Alan Turing', age=28, address=Address{street='Bletchley Hall', city='Bletchley Park', zip='MK12'}}
Person{id='...', name='Timothy Berners-Lee', age=61, address=Address{street='Colehill', city='Wimborne', zip='null'}}

Especificar un filtro de query

Para query para instancias de Person que cumplan con ciertas condiciones, pasa un objeto de filtro al método find(). Para facilitar la creación de objetos de filtro, el driver proporciona métodos asistentes Filters.

collection.find(eq("address.city", "Wimborne"))
    .first()
    .subscribe(new PrintToStringSubscriber<>());

Person{id='591dbc2550852fa685b3ad1a', name='Timothy Berners-Lee', age=61, address=Address{street='Colehill', city='Wimborne', zip='null'}}

collection.find(gt("age", 30)).subscribe(new PrintToStringSubscriber<>());

Update Documents

Para actualizar documentos en una colección, puedes usar los métodos updateOne() y updateMany() de la colección.

Pasa los siguientes parámetros a los métodos:

• El objeto de filtro para determinar el documento o los documentos que se actualizarán. Para especificar un filtro vacío y hacer coincidir todas las instancias de Person, utiliza un objeto Document vacío.

• Actualice el documento que especifica las modificaciones. Para ver una lista de los operadores disponibles, consulta Operadores de actualizar en el manual del servidor.

Los métodos de actualización devuelven un tipo UpdateResult que proporciona información sobre la operación, incluido el número de documentos modificados por la actualización.

collection.updateOne(
    eq("name", "Ada Byron"),
    combine(set("age", 23), set("name", "Ada Lovelace"))
).subscribe(new OperationSubscriber<>());

collection.updateMany(not(eq("zip", null)), set("zip", null))
         .subscribe(new OperationSubscriber<>());

collection.replaceOne(eq("name", "Ada Lovelace"), ada)
    .subscribe(new OperationSubscriber<>());

Delete Documents

Para borrar documentos de una colección, puedes usar los métodos deleteOne() y deleteMany() de la colección.

Pase un objeto filtro para hacer coincidir el o los documentos que desea borrar. Para especificar un filtro vacío, utiliza un objeto vacío Document.

Los métodos de eliminación devuelven un tipo DeleteResult que proporciona información sobre la operación, incluido el número de documentos eliminados.

collection.deleteOne(eq("address.city", "Wimborne"))
    .subscribe(new OperationSubscriber<>());

collection.deleteMany(eq("address.city", "London"))
    .subscribe(new OperationSubscriber<>());