Criar um MongoClient

Visão geral

Para se conectar a um MongoDB deployment, você precisa de duas coisas:

Um URI de conexão , também conhecido como string de conexão , que informa ao driver Scala a qual sistema do MongoDB se conectar.
Um objeto MongoClient, que cria a conexão e permite que você execute operações no MongoDB deployment.

Você também pode usar MongoClientSettings para personalizar a maneira como o driver Scala se comporta enquanto conectado ao MongoDB.

Este guia mostra como criar uma string de conexão e usar um objeto MongoClient para se conectar ao MongoDB.

URI de conexão

Uma connection string padrão inclui os seguintes componentes:

Componente	Descrição
`mongodb://`	Obrigatório. Um prefixo que identifica isso como uma string no formato de conexão padrão.
`username:password`	Opcional. Credenciais de autenticação. Se você incluir estes, o cliente autenticará o usuário no banco de dados especificado no `authSource`. Para saber mais sobre a `authSource` opção de conexão do, consulte o guia de mecanismos de autenticação.
`host[:port]`	Obrigatório. O host e o número da porta opcional em que o MongoDB está sendo executado. Se você não incluir o número da porta, o driver usará a porta padrão, `27017`.
`/defaultauthdb`	Opcional. O authentication database de autenticação a ser usado se a connection string incluir as credenciais de autenticação `username:password@` , mas não a opção `authSource` . Se você não incluir este componente, o cliente autenticará o usuário no banco de dados do `admin` .
`?<options>`	Opcional. Uma string da query que especifica opções específicas de conexão como `<name>=<value>` pares.

Para obter mais informações sobre a criação de uma string de conexão, consulte Connection strings no manual do MongoDB Server .

Exemplo de conexão do Atlas

Para se conectar a uma implementação do MongoDB no Atlas, você deve primeiro criar um cliente.

Você pode passar um URI de conexão como uma string para o método MongoClient.create() para se conectar a uma instância do MongoDB :

// Replace the placeholder with your Atlas connection stringval connectionString = "<connection string>"
// Create a new client and connect to the serverval mongoClient = MongoClient(connectionString)val database = mongoClient.getDatabase("sample_mflix")

Você também pode criar um cliente com suas configurações desejadas passando um objeto MongoClientSettings para um objeto MongoClient .

Para instanciar um objeto MongoClientSettings, chame o método builder(), encadeie o método applyConnectionString() e passe sua string de conexão. Você também pode utilizar o método builder() para especificar quaisquer outras opções do cliente . Depois de ter a configuração desejada, chame o método build().

Você pode definir a opção de cliente da stable API para evitar alteração interruptiva ao atualizar para uma nova versão do servidor. Para saber mais sobre o recurso de stable API, consulte a página de stable API.

O código a seguir mostra como você pode especificar a cadeia de conexão e a opção de cliente Stable API ao se conectar a uma implementação do MongoDB no Atlas e verificar se a conexão foi bem-sucedida:

import com.mongodb.{ServerApi, ServerApiVersion}import org.mongodb.scala.{ConnectionString, MongoClient, MongoClientSettings}import org.mongodb.scala.bson.Document
import scala.concurrent.Awaitimport scala.concurrent.duration.DurationIntimport scala.util.Using
object MongoClientConnectionExample {
  def main(args: Array[String]): Unit = {
    // Replace the placeholder with your Atlas connection string    val connectionString = "<connection string>"
    // Construct a ServerApi instance using the ServerApi.builder() method    val serverApi = ServerApi.builder.version(ServerApiVersion.V1).build()
    val settings = MongoClientSettings      .builder()      .applyConnectionString(ConnectionString(connectionString))      .serverApi(serverApi)      .build()
    // Create a new client and connect to the server    Using(MongoClient(settings)) { mongoClient =>      // Send a ping to confirm a successful connection      val database = mongoClient.getDatabase("admin")      val ping = database.runCommand(Document("ping" -> 1)).head()
      Await.result(ping, 10.seconds)      System.out.println("Pinged your deployment. You successfully connected to MongoDB!")    }  }}

Documentação da API

Para obter mais informações sobre como criar um objeto MongoClient com o driver Scala, consulte a seguinte documentação da API:

Voltar

Começar

Especificar opções de conexão