Recuperar dados

Visão geral

Neste guia, você pode aprender como recuperar dados de seu banco de dados MongoDB. Para recuperar dados, use operações de leitura.

As operações de leitura permitem que fazer o seguinte:

• 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 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 nosso guia Especificar uma consulta.

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 a operação agregada para executar os estágios em uma aggregation pipeline. Uma aggregation pipeline é uma transformação em várias etapas que produz um resultado agregado.

Para executar uma operação agregada, chame o método aggregate() em uma instância de um 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 obter mais informações, consulte nosso 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=8, color=green)
PaintOrder(id=3, qty=4, color=purple)