Retrieve Data

개요

이 가이드 에서는 코틀린 (Kotlin) 운전자 사용하여 MongoDB database 에서 데이터를 조회 방법을 학습 수 있습니다.읽기 작업을 수행하여 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에서 기존 데이터의 하위 집합을 검색할 수 있습니다. 검색할 문서, 검색 순서, 검색할 문서 수 등 반환할 데이터를 지정할 수 있습니다.

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

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=19, color=green)
PaintOrder(id=3, qty=14, color=purple)