Scalaドライバーを使い始める

依存関係をインストールします。

開発を行う前に、開発環境に次の依存関係がインストールされていることを確認してください。

• JDK バージョン 8 以降

• sbt バージョン 1 以降

プロジェクトディレクトリを作成します。

シェルで次のコマンドを実行して、このプロジェクト用に scala-quickstart というディレクトリを作成します。

mkdir scala-quickstart

オペレーティング システムに対応するタブを選択し、次のコマンドを実行して、scala-quickstartディレクトリに build.sbtファイルを作成します。

cd scala-quickstart
touch build.sbt

cd scala-quickstart
type nul > build.sbt

Scalaドライバーを使用するようにプロジェクトを構成します。

build.sbtファイルに移動し、次のコードを追加して、アプリケーションでScalaドライバーを使用します。

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

このコードは、 Scalaバージョン 2.13.16 とScalaドライバー バージョン 5.6.1 を使用するようにアプリケーションを構成します。

Atlas に無料のMongoDB配置を作成します。

MongoDB の使用開始ガイドを完了して、新しい Atlas アカウントを設定し、サンプルデータを新しい無料階層の MongoDB 配置にロードします。

認証情報を保存します。

データベースユーザーを作成したら、そのユーザーのユーザー名とパスワードを安全な場所に保存して、後の手順で使用します。

MongoDB Atlas接続文字列を見つけます。

To retrieve your connection string for the deployment that you created in the previous step, log in to your Atlas account and navigate to the Clusters page under the Database section. Click the Connect button for your new deployment.

データベースユーザーをまだ設定していない場合、 MongoDB は新しいユーザーを作成して設定するように要求します。

Connect to your application セクションの下の Drivers ボタンをクリックし、Driver 選択メニューから「Scala」を選択し、Version 選択メニューからインストールしたバージョンに最適なバージョンを選択します。

接続文字列のみを表示するには、View full code sample オプションが選択されていないことを確認します。

接続文字列をコピーします。

次のスクリーンショットに示すように、接続文字列の右側にある ボタンをクリックして、接続stringをクリップボードにコピーします。

パスワード プレースホルダーを更新します。

この接続文字列をテキストエディタのファイルに貼り付け、<db_password> プレースホルダーをデータベースユーザーのパスワードに置き換えます。接続文字列には、すでにデータベースユーザーのユーザー名が入力されています。

このファイルを安全な場所に保存して、次の手順で使用します。

アプリケーションファイルを作成します。

このガイドのダウンロードとインストールのステップで作成した scala-quickstartディレクトリに移動し、src/main/scala/quickstart のネストされたディレクトリを作成します。

オペレーティング システムに対応するタブを選択し、次のコマンドを実行して、quickstart サブディレクトリに Main.scalaファイルを作成します。

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

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

ヘルパーメソッドを追加します。

Helpers.scalaドライバーのソースコードから次の ファイルをsrc/main/scala/quickstart ディレクトリに追加します。

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())}")
  }
}

このファイルを使用すると、クエリ結果を出力するためのヘルパーメソッドにアクセスできます。

アプリケーションコードを追加します。

次のコードをコピーして、 Main.scalaファイルに貼り付けます。このコードは、 sample_mflixデータベース内のmoviesコレクションをクエリします。

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

接続文字列を割り当てます。

<connection string> プレースホルダーを、このガイドの接続文字列の作成ステップからコピーした接続文字列に置き換えます。

Scalaアプリケーション を実行します。

プロジェクトルートディレクトリで、次のコマンドを実行して sbt シェル を起動し、アプリケーションを実行します。

sbt
run

コマンドライン出力には、検索された映画ドキュメントの詳細が含まれます。

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

エラーが発生した場合や出力が表示されない場合は、Main.scala ファイルに適切な接続stringが指定されており、サンプル データがロードされていることを確認してください。

exit