Retrieve Data

Visão geral

Neste guia, você pode aprender como recuperar dados de seu banco de dados MongoDB usando o driver Kotlin . Você pode realizar operações de leitura para recuperar dados do MongoDB.

As operações de leitura permitem executar as seguintes tarefas:

• Recupere um subconjunto de documentos da sua coleção usando uma operação find

• Executar transformações em documentos recuperados de sua coleção usando uma operação agregada

• Monitore alterações em tempo real em seu banco de dados de dados usando change streams

{ "_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
)

Encontrar operação

Utilize a operação de localizar para recuperar um subconjunto dos seus dados existentes no MongoDB. Você pode especificar os dados a serem retornados, inclusive quais documentos devem ser recuperados, em que ordem devem ser recuperados e quantos devem ser recuperados.

Para executar uma operação de localizar, ligue para o método find() em uma instância de um MongoCollection. Esse método pesquisa uma coleção de documentos que correspondam ao filtro de query que você fornece. Para obter mais informações sobre como especificar uma query, consulte o guia Especificar uma query.

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)

Operação agregada

Use operações de agregação para executar um agregação pipeline em seus dados. Uma agregação pipeline é uma transformação em várias etapas que produz um resultado agregado.

Para executar uma operação de agregação , chame o método aggregate() em uma instância de MongoCollection. Este método aceita expressões de agregação para executar em sequência. Para realizar agregações, você pode definir estágios de agregação que especificam como fazer a correspondência entre documentos, renomear campos e agrupar valores. Para saber mais, consulte o guia de agregação.

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)