읽기 작업

전제 조건

이 가이드의 코드 예제를 실행하려면 다음 구성 요소를 설정해야 합니다.

• A test.restaurants 컬렉션 populated with documents from the restaurants.json 파일 in the documentation assets Github.

• 다음 가져오기 문:

import org.mongodb.scala._
import org.mongodb.scala.model.Filters._
import org.mongodb.scala.model.Projections._
import org.mongodb.scala.model.Sorts._

MongoDB 배포에 연결하기

먼저 MongoDB deployment에 연결한 다음 MongoDatabase 및 MongoCollection 인스턴스를 선언하고 정의합니다.

다음 코드는 포트 27017 의 localhost 에서 실행되는 독립형 MongoDB 배포서버에 연결합니다. 그런 다음 test 데이터베이스를 참조하는 database 변수와 restaurants 컬렉션을 참조하는 collection 변수를 정의합니다.

val mongoClient: MongoClient = MongoClient()
val database: MongoDatabase = mongoClient.getDatabase("test")
val collection: MongoCollection[Document] = database.getCollection("restaurants")

MongoDB deployment에 연결하는 방법에 대해 자세히 알아보려면 MongoDB에 연결 튜토리얼을 참조하세요.

컬렉션 쿼리

컬렉션을 쿼리하려면 컬렉션의 find() 메서드를 사용할 수 있습니다.

인수 없이 메서드를 호출하여 컬렉션의 모든 문서를 쿼리할 수 있습니다.

collection.find().printResults()

또는 필터를 전달하여 필터 기준과 일치하는 문서를 쿼리할 수 있습니다.

collection.find(equal("name", "456 Cookies Shop"))
          .printResults()

쿼리 필터

특정 조건과 일치하는 문서를 쿼리하려면 필터 문서를 find() 메서드에 전달합니다.

collection.find(Document()).printResults()

collection.find().printResults()

collection.find(
     Document("stars" -> Document("$gte" -> 2, "$lt"-> 5, "categories" -> "Bakery")))
    .printResults()

collection.find(and(gte("stars", 2), lt("stars", 5), equal("categories", "Bakery")))
          .printResults()

FindObservable

find() 메서드는 FindObservable 클래스의 인스턴스 를 반환합니다. 이 클래스는 find() 메서드에 연결하여 sort() 또는 projection() 와 같이 쿼리 의 출력이나 동작을 수정하고 subscribe() 메서드를 통해 결과를 반복할 수 있는 다양한 메서드를 제공합니다.

collection.find(and(gte("stars", 2), lt("stars", 5), equal("categories", "Bakery")))
          .projection(Document("name" -> 1, "stars" -> 1, "categories" -> 1, "_id" -> 0))
          .printResults()

collection.find(and(gte("stars", 2), lt("stars", 5), equal("categories", "Bakery")))
          .projection(fields(include("name", "stars", "categories"), excludeId()))
          .printResults()

collection.find(and(gte("stars", 2), lt("stars", 5), equal("categories", "Bakery")))
          .sort(ascending("name"))
          .printResults()

collection.find(and(gte("stars", 2), lt("stars", 5), eq("categories", "Bakery")))
          .explain()
          .printResults()

collection.find(and(gte("stars", 2), lt("stars", 5), eq("categories", "Bakery")))
          .explain()
          .printResults()

읽기 설정

복제본 세트 또는 샤드 클러스터에 대한 읽기 작업의 경우 다음 수준에서 읽기 설정을 구성할 수 있습니다.

• 다음과 같은 방법으로 MongoClient 에서:

  • MongoClientSettings 인스턴스를 생성합니다.

    val mongoClient = MongoClient(MongoClientSettings.builder()
            .applyConnectionString(ConnectionString("mongodb://host1,host2"))
            .readPreference(ReadPreference.secondary())
            .build())

  • ConnectionString 인스턴스를 생성합니다.

    val mongoClient = MongoClient("mongodb://host1:27017,host2:27017/?readPreference=secondary")

• withReadPreference() 메서드를 사용하여 MongoDatabase 에서:

  val database = mongoClient.getDatabase("test")
                            .withReadPreference(ReadPreference.secondary())

• withReadPreference() 메서드를 사용하여 MongoCollection 에서:

  val collection = database.getCollection("restaurants")
                           .withReadPreference(ReadPreference.secondary())

MongoDatabase MongoCollection 인스턴스는 변경할 수 없습니다. 기존 MongoDatabase 또는 MongoCollection 인스턴스에서 withReadPreference() 를 호출하면 새 인스턴스가 반환되며 메서드가 호출되는 인스턴스에는 영향을 주지 않습니다.

다음 예제에서 collectionWithReadPref 인스턴스의 읽기 기본 설정은 primaryPreferred 인 반면, collection 의 읽기 기본 설정은 영향을 받지 않습니다.

val collectionWithReadPref = collection.withReadPreference(ReadPreference.primaryPreferred())

readConcern

복제본 세트 또는 샤드 클러스터에 대한 읽기 작업의 경우 애플리케이션은 다음 수준에서 읽기 고려를 구성할 수 있습니다.

• 다음과 같은 방법으로 MongoClient 에서:

  • MongoClientSettings 인스턴스를 생성합니다.

    val mongoClient = MongoClient(MongoClientSettings.builder()
                              .applyConnectionString(ConnectionString("mongodb://host1,host2"))
                              .readConcern(ReadConcern.MAJORITY)
                              .build())

  • ConnectionString 인스턴스를 생성합니다.

    val mongoClient = MongoClient("mongodb://host1:27017,host2:27017/?readConcernLevel=majority")

• withReadConcern() 메서드를 사용하여 MongoDatabase 에서:

  val database = mongoClient.getDatabase("test")
                            .withReadConcern(ReadConcern.MAJORITY)

• withReadConcern() 메서드를 사용하여 MongoCollection 에서:

  val collection = database.getCollection("restaurants")
                           .withReadConcern(ReadConcern.MAJORITY)

MongoDatabase MongoCollection 인스턴스는 변경할 수 없습니다. 기존 MongoDatabase 또는 MongoCollection 인스턴스에서 withReadConcern() 를 호출하면 새 인스턴스가 반환되며 메서드가 호출되는 인스턴스에는 영향을 주지 않습니다.

다음 예제에서 collWithReadConcern 인스턴스에는 AVAILABLE 읽기 고려가 있는 반면 인스턴스의 읽기 collection 고려는 영향을 받지 않습니다.

val collWithReadConcern = collection.withReadConcern(ReadConcern.AVAILABLE)

읽기 고려, 읽기 설정 및 쓰기 고려의 조합을 포함하도록 MongoClientSettings, MongoDatabase 또는 MongoCollection 인스턴스를 빌드할 수 있습니다.

예를 들어 다음 코드는 컬렉션 수준에서 이 세 가지를 모두 설정합니다.

val collection = database.getCollection("restaurants")
                         .withReadPreference(ReadPreference.primary())
                         .withReadConcern(ReadConcern.MAJORITY)
                         .withWriteConcern(WriteConcern.MAJORITY)