Use POJOs para modelar seus dados

Visão geral

Neste guia, você aprenderá a usar o driver Java Reactive Streams para armazenar e recuperar dados modelados por objetos Java antigos simples, ou POJOs. POJOs são frequentemente usados para encapsulamento de dados, que é a prática de separar lógica de negócios da representação de dados.

Este guia mostra como executar as seguintes tarefas:

• Configurar o driver para serializar e desserializar POJOs

• Execute operações CRUD usando dados modelados por POJOs

POJOs de amostra

Os exemplos neste guia usam as classes POJO Person e Address para modelar documentos em uma coleção de amostra chamada people.

A classe Person armazena o nome, a idade e o endereço de uma pessoa. Esta classe tem a seguinte definição:

import org.bson.types.ObjectId;
public final class Person {
    private ObjectId id;
    private String name;
    private int age;
    private Address address;
    public Person() {}
    public Person(final String name, final int age, final Address address) {
        this.name = name;
        this.age = age;
        this.address = address;
    }
    public ObjectId getId() { return id; }
    public void setId(final ObjectId id) { this.id = id; }
    public String getName() { return name; }
    public void setName(final String name) { this.name = name; }
    public int getAge() { return age; }
    public void setAge(final int age) { this.age = age; }
    public Address getAddress() { return address; }
    public void setAddress(final Address address) { this.address = address; }
    @Override
    public String toString() {
        return "Person{"
                + "id='" + id + "'"
                + ", name='" + name + "'"
                + ", age=" + age
                + ", address=" + address
                + "}";
    }
}

A classe Address armazena uma rua, cidade e CEP. Esta classe tem a seguinte definição:

public final class Address {
    private String street;
    private String city;
    private String zip;
    public Address() {}
    public Address(final String street, final String city, final String zip) {
        this.street = street;
        this.city = city;
        this.zip = zip;
    }
    public String getStreet() { return street; }
    public void setStreet(final String street) { this.street = street; }
    public String getCity() { return city; }
    public void setCity(final String city) { this.city = city; }
    public String getZip() { return zip; }
    public void setZip(final String zip) { this.zip = zip; }
    @Override
    public String toString() {
        return "Address{"
                + "street='" + street + "'"
                + ", city='" + city + "'"
                + ", zip='" + zip + "'"
                + "}";
    }
}

Ao definir uma classe POJO, certifique-se de atender aos seguintes requisitos:

• A classe POJO não pode implementar interfaces ou estender classes de uma framework.

• Inclua todos os campos para os quais deseja armazenar e recuperar dados e certifique-se de que não estejam marcados como static ou transient.

• Se você incluir métodos getter ou setter públicos seguindo as convenções de nomenclatura JavaBean, o driver os chamará ao serializar ou desserializar dados. Se você omitir os métodos getter ou setter de um campo público, o driver os acessará ou atribuirá diretamente.

Configurar o driver para POJOs

Antes de usar um POJO com o driver Java Reactive Streams, você deve configurá-lo para serializar e desserializar POJOs criando um CodecRegistry personalizado. As etapas a seguir mostram como criar o CodecRegistry e aplicá-lo a um cliente, banco de dados ou coleção.

CodecProvider pojoCodecProvider = PojoCodecProvider.builder().automatic(true).build();

CodecRegistry pojoCodecRegistry = fromRegistries(
        getDefaultCodecRegistry(),
        fromProviders(pojoCodecProvider)
);

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

Realizar operações CRUD

Depois de configurar o driver para usar o POJO Person, você poderá executar operações CRUD nos dados modelados pelo POJO.

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>());

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

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

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

Person{id='...', name='Charles Babbage', age=45, address=Address{street='5 Devonshire Street', city='London', zip='W11'}}
Person{id='...', name='Timothy Berners-Lee', age=61, address=Address{street='Colehill', city='Wimborne', zip='null'}}

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<>());

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

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

Informações adicionais

Para saber mais sobre as operações CRUD mencionadas neste guia, consulte a seção Operações CRUD.