Conecte-se ao MongoDB

O driver Reactive Streams do Java é uma implementação da API de Reactive Streams, que consiste em três componentes:

Publisher
Subscriber
Subscription

Um Publisher é um provedor de um número ilimitado de elementos sequenciados, publicados de acordo com a demanda recebida de seu Subscriber ou múltiplas instâncias de Subscriber. Um Subscription representa um ciclo de vida individual de um Subscriber assinando um Publisher.

Dica

Para saber mais sobre fluxos reativos, acesse a documentação de fluxos reativos.

Neste tutorial, você deve implementar o Java Reactive Streams Subscribers para executar query de seu banco de dados de dados. Este guia usa métodos da biblioteca Reactor, uma biblioteca baseada na especificação Reactive Streams para implementar o Java Reactive Streams Subscribers.

Para saber mais sobre a biblioteca Reactor, consulte Introdução na documentação do Projeto Reactor.

Crie seu aplicativo de driver Java Reactive Streams

Você deve usar um projeto dentro de um ambiente de desenvolvimento integrado (IDE) para concluir as etapas a seguir. No seu projeto, crie um novo arquivo Java no pacote Java denominado QueryDatabase. Copie e cole o seguinte código no arquivo QueryDatabase :

import com.mongodb.*;
import com.mongodb.reactivestreams.client.MongoCollection;
import org.bson.Document;
import reactor.core.publisher.Mono;
import com.mongodb.reactivestreams.client.MongoClient;
import com.mongodb.reactivestreams.client.MongoClients;
import com.mongodb.reactivestreams.client.MongoDatabase;
import static com.mongodb.client.model.Filters.eq;
public class QueryDatabase {
    public static void main(String[] args) {
        // Replace the placeholder with your Atlas connection string
        String uri = "<connection string>";
        // Construct a ServerApi instance using the ServerApi.builder() method
        ServerApi serverApi = ServerApi.builder()
                .version(ServerApiVersion.V1)
                .build();
        MongoClientSettings settings = MongoClientSettings.builder()
                .applyConnectionString(new ConnectionString(uri))
                .serverApi(serverApi)
                .build();
        // Create a new client and connect to the server
        try (MongoClient mongoClient = MongoClients.create(settings)) {
            MongoDatabase database = mongoClient.getDatabase("sample_mflix");
            MongoCollection<Document> movies = database.getCollection("movies");
            Mono.from(movies.find(eq("title", "Back to the Future")))                   
                    .doOnSuccess(i -> System.out.println(i))                            
                    .doOnError(err -> System.out.println("Error: " + err.getMessage())) 
                    .block();                                                           
        }
    }
}

Atribuir a connection string

Substitua o placeholder <connection string> pela connection string que você copiou da etapa Criar uma connection string deste guia.

Execute seu aplicativo

Execute seu aplicação, em seu IDE ou em seu shell. A saída mostra que você se conectou ao MongoDB e consultou o banco de dados de dados.

{
   _id: ...,
   plot: 'A young man is accidentally sent 30 years into the past...',
   genres: [ 'Adventure', 'Comedy', 'Sci-Fi' ],
   ...
   title: 'Back to the Future',
   ...
 }

Dica

Se você encontrar um erro, verifique se especificou a string de conexão adequada e se carregou os dados de amostra.

Depois de concluir essas etapas, você tem um aplicação funcional que usa o driver para se conectar à implementação do MongoDB , consulta o banco de dados de dados e imprime o resultado.

Observação

Caso ocorra algum problema nesta etapa, peça ajuda nos Fóruns da MongoDB Community ou envie feedback pela aba Rate this page no lado direito ou no canto inferior direito desta página.

Voltar

Criar uma connection string

Próximos passos