Conéctese a MongoDB

Overview

Esta página contiene ejemplos de código que muestran cómo utilizar el controlador Kotlin Sync para conectar su aplicación a MongoDB especificando varias configuraciones.

Para utilizar un ejemplo de conexión de esta página, copie el ejemplo de código en el Aplicación de ejemplo o su propia aplicación. Asegúrese de reemplazar todos los marcadores de posición en los ejemplos de código, como <hostname>, con los valores relevantes para su implementación de MongoDB.

1
import com.mongodb.kotlin.client.MongoClient
2
import org.bson.Document
3
4
fun main() {
5
6
    // Start example code here
7
8
    // End example code here
9
10
    val database = mongoClient.getDatabase("admin")
11
12
    val command = Document("ping", 1)
13
    val commandResult = database.runCommand(command)
14
    println("Pinged your deployment. You successfully connected to MongoDB!")
15
}

Conexión

Las siguientes secciones describen cómo conectarse a diferentes destinos, como una instancia local de MongoDB o una instancia alojada en la nube en Atlas.

val uri = "mongodb://localhost:27017/"
val mongoClient = MongoClient.create(uri)

val uri = "mongodb+srv://<db_username>:<db_password>@<hostname/port>/?<options>"
val mongoClient = MongoClient.create(uri)

val uri = "mongodb://<replica set member>:<port>/?replicaSet=<replica set name>"
val mongoClient = MongoClient.create(uri)

Capa de seguridad de transporte (TLS)

Las siguientes secciones describen cómo conectarse a MongoDB con el protocolo TLS habilitado. Para obtener más información sobre el uso de TLS con el controlador de sincronización de Kotlin, consulte Habilitar TLS/SSL en una conexión.

val settings = MongoClientSettings.builder()
    .applyConnectionString(ConnectionString("<connection string>"))
    .applyToSslSettings { builder ->
        builder.enabled(true)
    }
    .build()
val mongoClient = MongoClient.create(settings)

val uri = "mongodb+srv://<db_username>:<db_password>@<cluster-url>?tls=true"
val mongoClient = MongoClient.create(uri)

val settings = MongoClientSettings.builder()
    .applyConnectionString(ConnectionString("<connection string>"))
    .applyToSslSettings { builder ->
        builder.enabled(true)
        builder.invalidHostNameAllowed(true)
    }
    .build()
val mongoClient = MongoClient.create(settings);

val uri = "mongodb://<db_username>:<db_password>@<hostname>:<port>/?"tls=true&tlsAllowInvalidHostnames=true"
val mongoClient = MongoClient.create(uri)

Selección de servidores

El siguiente código muestra una cadena de conexión que especifica una función de selección de servidor:

val client = MongoClient.create("mongodb://<db_username>:<db_password>@<hostname>:<port>",
                             server_selector=<selector function>)

Stable API

El siguiente código muestra cómo especificar la configuración de API estable dentro de una instancia MongoClientSettings:

val serverApi = ServerApi.builder()
    .version(ServerApiVersion.V1)
    .build()
val uri = "<connection string>"
val settings = MongoClientSettings.builder()
    .applyConnectionString(ConnectionString(uri))
    .serverApi(serverApi)
    .build()
val client = MongoClient.create(settings)

Para obtener más información sobre la API estable, consulte Conectarse con la API estable.