애그리게이션 프레임워크

전제 조건

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

• test.restaurants 문서 자산 restaurants.json Github 에 있는 파일의 문서로 채워진 컬렉션 입니다.

• 다음 가져오기 문:

import org.mongodb.scala._
import org.mongodb.scala.model.Aggregates._
import org.mongodb.scala.model.Accumulators._
import org.mongodb.scala.model.Filters._
import org.mongodb.scala.model.Projections._

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에 연결 튜토리얼을 참조하세요.

집계 수행

집계 집계 단계 목록을 MongoCollection.aggregate() 메서드에 전달합니다. 이 운전자 는 집계 단계에 대한 빌더 가 포함된 Aggregates 헬퍼 클래스를 제공합니다.

이 예제에서 집계 파이프라인은 다음 작업을 수행합니다.

• $match 단계를 사용하여 categories 배열 필드에 "Bakery" 요소가 포함된 문서를 필터링합니다. 이 예제에서는 Aggregates.filter() 를 사용하여 $match 단계를 빌드합니다.

• $group 단계를 사용하여 일치하는 문서를 stars 필드 별로 그룹 하여 stars 의 각 고유 값에 대한 문서 수를 누적합니다. 이 예시 에서는 Aggregates.group() 를 사용하여 $group 단계를 빌드 하고 Accumulators.sum() 를 사용하여 축적자 표현식 을 빌드 합니다. $group 단계 내에서 사용하기 위한 축적자 자 표현식의 경우 운전자 는 Accumulators 헬퍼 클래스를 제공합니다.

collection.aggregate(Seq(
    Aggregates.filter(Filters.equal("categories", "Bakery")),
    Aggregates.group("$stars", Accumulators.sum("count", 1))
)).printResults()

collection.aggregate(
  Seq(
    Aggregates.project(
      Projections.fields(
        Projections.excludeId(),
        Projections.include("name"),
        Projections.computed(
          "firstCategory",
          Document("$arrayElemAt"-> Seq("$categories", 0))
        )
      )
    )
  )
).printResults()

collection.aggregate(
  Seq(Aggregates.filter(Filters.eq("categories", "Bakery")),
      Aggregates.group("$stars", Accumulators.sum("count", 1)))
).explain().printResults()