Retrieve Data

개요

이 가이드에서는 MongoDB 데이터베이스에서 데이터를 검색하는 방법에 대해 설명합니다. 데이터를 검색하려면 읽기 작업을 사용합니다.

읽기 작업을 통해 다음을 수행할 수 있습니다.

• 찾기 작업을 사용하여 컬렉션에서 문서의 하위 집합을 검색합니다.

• 애그리게이션 작업을 사용하여 컬렉션에서 검색된 문서에서 변환 수행

• 변경 스트림을 사용하여 데이터베이스 의 실시간 변경 사항 모니터링

{ "_id": 1, "color": "purple", "qty": 10 }
{ "_id": 2, "color": "green", "qty": 8 }
{ "_id": 3, "color": "purple", "qty": 4 }
{ "_id": 4, "color": "green", "qty": 11 }

data class PaintOrder(
    @BsonId val id: Int,
    val qty: Int,
    val color: String
)

찾기 작업

찾기 작업을 사용하여 MongoDB에서 기존 데이터의 하위 집합을 검색할 수 있습니다. 검색할 문서, 검색 순서, 검색할 문서 수 등 반환할 데이터를 지정할 수 있습니다.

찾기 작업을 수행하려면 MongoCollection의 인스턴스에서 find() 메서드를 호출합니다. 이 메서드는 제공된 쿼리 필터와 일치하는 문서 컬렉션을 검색합니다. 쿼리 지정 방법에 대한 자세한 내용은 쿼리 지정 가이드를 참조하세요.

val filter = Filters.and(Filters.gt("qty", 3), Filters.lt("qty", 9))
val resultsFlow = collection.find(filter)
resultsFlow.collect { println(it) }

PaintOrder(id=2, qty=8, color=green)
PaintOrder(id=3, qty=4, color=purple)

애그리게이션 작업

집계 작업을 사용하여 집계 파이프라인의 단계를 수행합니다. 집계 파이프라인은 집계된 결과를 생성하는 다단계 변환입니다.

집계 작업을 수행하려면 MongoCollection의 인스턴스에서 aggregate() 메서드를 호출합니다. 이 메서드는 실행할 집계 표현식을 순서대로 허용합니다. 집계를 수행하려면 문서 일치, 필드 이름 변경, 값 그룹화 방법을 지정하는 집계 단계를 정의하면 됩니다. 자세한 내용은 집계 가이드를 참조하세요.

data class AggregationResult(@BsonId val id: String, val qty: Int)
val filter = Filters.empty()
val pipeline = listOf(
    Aggregates.match(filter),
    Aggregates.group(
        "\$color",
        Accumulators.sum("qty", "\$qty")
    ),
    Aggregates.sort(Sorts.descending("qty"))
)
val resultsFlow = collection.aggregate<AggregationResult>(pipeline)
resultsFlow.collect { println(it) }

PaintOrder(id=2, qty=8, color=green)
PaintOrder(id=3, qty=4, color=purple)