MongoClient 만들기

이 페이지의 내용

개요

연결 URI
Atlas 연결 예시
API 문서

개요

MongoDB deployment에 연결하려면 다음 두 가지가 필요합니다.

연결할 MongoDB deployment 스칼라 운전자 에 알려주는 연결 문자열 이라고도 하는 연결 URI입니다.
MongoClient 객체, MongoDB deployment에 대한 연결을 생성하고 MongoDB deployment 에서 작업을 수행할 수 있도록 합니다.

MongoClientSettings 를 사용하여 MongoDB 에 연결된 동안 스칼라 운전자 작동하는 방식을 사용자 지정할 수도 있습니다.

이 가이드에서는 연결 string 을 만들고 MongoClient 객체를 사용하여 MongoDB 에 연결하는 방법을 보여 줍니다.

연결 URI

표준 연결 string 에는 다음 구성 요소가 포함됩니다.

구성 요소	설명
`mongodb://`	필수 사항입니다. 표준 연결 형식의 문자열로 식별하는 접두사입니다.
`username:password`	선택 사항. 인증 자격 자격 증명. 이를 포함하면 클라이언트 에 지정된 데이터베이스 에 대해 사용자를 `authSource` 인증합니다.`authSource` 연결 옵션에 대해 자세히 학습 인증 메커니즘 가이드 참조하세요.
`host[:port]`	필수입니다. MongoDB가 실행 중인 호스트 및 선택적 포트 번호입니다. 포트 번호를 포함하지 않으면 드라이버는 기본 포트인 `27017` 을 사용합니다.
`/defaultauthdb`	선택 사항. 연결 string 에 `username:password@` 인증 자격 증명이 포함되어 있지만 `authSource` 옵션이 없는 경우에 사용할 인증 데이터베이스입니다. 이 구성 요소를 포함하지 않으면 클라이언트는 `admin` 데이터베이스에 대해 사용자를 인증합니다.
`?<options>`	선택 사항 연결별 옵션을 `<name>=<value>` 쌍으로 지정하는 쿼리 문자열입니다.

연결 문자열 생성에 대한 자세한 내용은 MongoDB Server 매뉴얼에서 연결 문자열을 참조하세요.

Atlas 연결 예시

Atlas 에서 MongoDB deployment 에 연결하려면 먼저 클라이언트 를 만들어야 합니다.

인스턴스 에 연결하기 위해 메서드에 연결 URI를 string 로 MongoClient.create() 전달할 수 MongoDB 있습니다.

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

MongoClientSettings 객체 MongoClient 객체 에 전달하여 원하는 구성으로 클라이언트 만들 수도 있습니다.

MongoClientSettings 객체 인스턴스화하려면 builder() 메서드를 호출한 다음 applyConnectionString() 메서드를 체인으로 연결하고 연결 문자열 전달합니다. builder() 메서드를 사용하여 다른 클라이언트 옵션을 지정할 수도 있습니다. 원하는 구성을 얻었으면 build() 메서드를 호출합니다.

새 서버 버전으로 업그레이드할 때 호환성이 손상되는 변경을 피하려면 Stable API 버전 클라이언트 옵션을 설정할 수 있습니다. Stable API 기능에 대해 자세히 알아보려면 Stable API 페이지를 참조하세요.

다음 코드는 Atlas의 MongoDB deployment에 연결할 때 연결 문자열과 Stable API 클라이언트 옵션을 지정하고 연결이 성공했는지 확인하는 방법을 보여줍니다.

import com.mongodb.{ServerApi, ServerApiVersion}
import org.mongodb.scala.{ConnectionString, MongoClient, MongoClientSettings}
import org.mongodb.scala.bson.Document
import scala.concurrent.Await
import scala.concurrent.duration.DurationInt
import 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!")
    }
  }
}

API 문서

스칼라 운전자 사용하여 MongoClient 객체 만드는 방법에 대한 자세한 내용은 다음 API 설명서를 참조하세요.

돌아가기

연결

Stable API