Comienza con el controlador de Scala

Instalar dependencias.

Antes de comenzar a desarrollar, asegúrese de tener las siguientes dependencias instaladas en su entorno de desarrollo:

• JDK versión 8 o posterior

• versiónsbt 1 o posterior

Crea un directorio de proyecto.

Ejecute el siguiente comando en su shell para crear un directorio llamado scala-quickstart Para este proyecto:

mkdir scala-quickstart

Seleccione la pestaña correspondiente a su sistema operativo y ejecute los siguientes comandos para crear un archivo build.sbt en el directorio scala-quickstart:

cd scala-quickstart
touch build.sbt

cd scala-quickstart
type nul > build.sbt

Configure su proyecto para utilizar el controlador Scala.

Navegue hasta su archivo build.sbt y agregue el siguiente código para usar el controlador Scala en su aplicación:

ThisBuild / scalaVersion := "2.13.16"
libraryDependencies += "org.mongodb.scala" %% "mongo-scala-driver" % "5.6.1"

Este código configura su aplicación para usar la versión 2.13.16 de Scala y la versión 5.6.1 del controlador de Scala.

Cree una implementación gratuita de MongoDB en Atlas.

Completa la Guía de inicio de MongoDB para configurar una nueva cuenta de Atlas y cargar datos de muestra en una nueva implementación de MongoDB de nivel gratuito.

Guarda tus credenciales.

Después de crear un usuario de base de datos, guardar el nombre de usuario y la contraseña de ese usuario en una ubicación segura para usarlos en un paso próximo.

Encuentra tu cadena de conexión de MongoDB Atlas.

Para recuperar su cadena de conexión para la implementación que creó en el paso anterior, inicie sesión en su cuenta de Atlas y navegue hasta la Clusters Página en la sección Database. Haga clic en el botón Connect para su nueva implementación.

Si aún no tienes un usuario de base de datos configurado, MongoDB te pedirá que crees y configures un nuevo usuario.

Haga clic en el botón Drivers en la sección Connect to your application y seleccione "Scala" en el menú de selección Driver y la versión que mejor coincida con la versión que instaló en el menú de selección Version.

Asegúrate de que la opción View full code sample esté desmarcada para ver solo la cadena de conexión.

Copie su cadena de conexión.

Haz clic en el botón a la derecha de la cadena de conexión para copiarla en el portapapeles, como se muestra en la siguiente captura de pantalla:

Actualiza el marcador de posición de la contraseña.

Pega esta cadena de conexión en un archivo en tu editor de texto preferido y reemplaza el marcador de posición <db_password> con la contraseña de tu usuario de base de datos. La cadena de conexión ya está completada con el nombre de usuario de tu usuario de base de datos.

Guarda este archivo en una ubicación segura para usarlo en el siguiente paso.

Crear un archivo de aplicación.

Navegue al scala-quickstart directorio que creó en el paso de Descarga e instalación de esta guía y cree los src/main/scala/quickstart directorios anidados.

Seleccione la pestaña correspondiente a su sistema operativo y ejecute los siguientes comandos para crear un archivo Main.scala en el subdirectorio quickstart:

cd src/main/scala/quickstart
touch Main.scala

cd src/main/scala/quickstart
type nul > Main.scala

Añade métodos asistentes.

Agregue el siguiente Helpers.scala archivo del código fuente del src/main/scala/quickstart controlador al directorio:

package quickstart
import java.util.concurrent.TimeUnit
import scala.concurrent.Await
import scala.concurrent.duration.Duration
import org.mongodb.scala._
object Helpers {
  implicit class DocumentObservable[C](val observable: Observable[Document]) extends ImplicitObservable[Document] {
    override val converter: (Document) => String = (doc) => doc.toJson
  }
  implicit class GenericObservable[C](val observable: Observable[C]) extends ImplicitObservable[C] {
    override val converter: (C) => String = (doc) => Option(doc).map(_.toString).getOrElse("")
  }
  trait ImplicitObservable[C] {
    val observable: Observable[C]
    val converter: (C) => String
    def results(): Seq[C] = Await.result(observable.toFuture(), Duration(10, TimeUnit.SECONDS))
    def headResult() = Await.result(observable.head(), Duration(10, TimeUnit.SECONDS))
    def printResults(initial: String = ""): Unit = {
      if (initial.length > 0) print(initial)
      results().foreach(res => println(converter(res)))
    }
    def printHeadResult(initial: String = ""): Unit = println(s"${initial}${converter(headResult())}")
  }
}

Este archivo le permite acceder a métodos auxiliares para imprimir resultados de consultas.

Añade el código de tu aplicación.

Copie y pegue el siguiente código en el archivo Main.scala, que hace un query en la colección movies en la base de datos sample_mflix:

package quickstart
import org.mongodb.scala._
import org.mongodb.scala.model.Filters._
import Helpers._
object Main {
  def main(args: Array[String]): Unit = {
    val mongoClient = MongoClient("<connection string>")
    val database: MongoDatabase = 
       mongoClient.getDatabase("sample_mflix")
    val collection: MongoCollection[Document] = 
       database.getCollection("movies")
    val filter = equal("title", "The Shawshank Redemption")
    collection.find(filter).printResults()
    mongoClient.close()
    
  }
}

Asigna la cadena de conexión.

Reemplaza el marcador de posición <connection string> con la cadena de conexión que se copió del paso Crear una cadena de conexión de esta guía.

Ejecute su aplicación Scala.

En el directorio raíz de su proyecto, ejecute los siguientes comandos para iniciar el shell sbt y ejecutar su aplicación:

sbt
run

La salida de la línea de comandos contiene detalles sobre el documento de película recuperado:

{"_id": {"$oid": "..."}, ... , "genres": ["Crime", "Drama"], "rated": "R",
"metacritic": 80, "title": "The Shawshank Redemption", ... }

Si encuentras un error o no ves ninguna salida, asegúrate de haber especificado la cadena de conexión correcta en el archivo Main.scala y de haber cargado los datos de muestra.

exit