$replaceWith (agregação)

Exemplo 1

Uma collection de exemplo sales é preenchida com os seguintes documentos:

db.sales.insertMany([
   { "_id" : 1, "item" : "butter", "price" : 10, "quantity": 2, date: ISODate("2019-03-01T08:00:00Z"), status: "C" },
   { "_id" : 2, "item" : "cream", "price" : 20, "quantity": 1, date: ISODate("2019-03-01T09:00:00Z"), status: "A" },
   { "_id" : 3, "item" : "jam", "price" : 5, "quantity": 10, date: ISODate("2019-03-15T09:00:00Z"), status: "C" },
   { "_id" : 4, "item" : "muffins", "price" : 5, "quantity": 10, date: ISODate("2019-03-15T09:00:00Z"), status: "C" }
])

Suponha que, para fins de relatório, você queira calcular, para cada venda concluída, o valor total a partir do tempo de execução do relatório atual. A operação a seguir encontra todas as vendas com status C e cria novos documentos usando o estágio $replaceWith . O $replaceWith calcula o valor total, como também utiliza a variável NOW para obter o tempo atual.

db.sales.aggregate([
   { $match: { status: "C" } },
   { $replaceWith: { _id: "$_id", item: "$item", amount: { $multiply: [ "$price", "$quantity"]}, status: "Complete", asofDate: "$$NOW" } }
])

A operação retorna os seguintes documentos:

{ "_id" : 1, "item" : "butter", "amount" : 20, "status" : "Complete", "asofDate" : ISODate("2019-06-03T22:47:54.812Z") }
{ "_id" : 3, "item" : "jam", "amount" : 50, "status" : "Complete", "asofDate" : ISODate("2019-06-03T22:47:54.812Z") }
{ "_id" : 4, "item" : "muffins", "amount" : 50, "status" : "Complete", "asofDate" : ISODate("2019-06-03T22:47:54.812Z") }

Exemplo 2

Uma collection de exemplo reportedsales é preenchida com as informações de vendas relatadas por trimestre e regiões:

db.reportedsales.insertMany( [
   { _id: 1, quarter: "2019Q1", region: "A", qty: 400 },
   { _id: 2, quarter: "2019Q1", region: "B", qty: 550 },
   { _id: 3, quarter: "2019Q1", region: "C", qty: 1000 },
   { _id: 4, quarter: "2019Q2", region: "A", qty: 660 },
   { _id: 5, quarter: "2019Q2", region: "B", qty: 500 },
   { _id: 6, quarter: "2019Q2", region: "C", qty: 1200 }
] )

Suponha que, para fins de relatório, você queira visualizar os dados de vendas relatados por trimestre. Por exemplo

{ "_id" : "2019Q1", "A" : 400, "B" : 550, "C" : 1000 }

Para visualizar os dados agrupados por trimestre, você pode usar o seguinte aggregation pipeline:

db.reportedsales.aggregate( [
   { $addFields: { obj:  { k: "$region", v: "$qty" } } },
   { $group: { _id: "$quarter", items: { $push: "$obj" } } },
   { $project: { items2: { $concatArrays: [ [ { "k": "_id", "v": "$_id" } ], "$items" ] } } },
   { $replaceWith: { $arrayToObject: "$items2" } }
] )

Primeiro estágio:

O estágio $addFields adiciona um novo campo de documento obj que define a chave k como o valor da região e o valor v como a quantidade dessa região. Por exemplo:

{ "_id" : 1, "quarter" : "2019Q1", "region" : "A", "qty" : 400, "obj" : { "k" : "A", "v" : 400 } }

Segundo estágio:

O estágio $group agrupa por trimestre e usa $push para acumular os campos obj em um novo campo de array items. Por exemplo:

{ "_id" : "2019Q1", "items" : [ { "k" : "A", "v" : 400 }, { "k" : "B", "v" : 550 }, { "k" : "C", "v" : 1000 } ] }

Terceiro estágio:

O estágio $project usa $concatArrays para criar uma nova array items2 que inclui as informações _id e os elementos da array items:

{ "_id" : "2019Q1", "items2" : [ { "k" : "_id", "v" : "2019Q1" }, { "k" : "A", "v" : 400 }, { "k" : "B", "v" : 550 }, { "k" : "C", "v" : 1000 } ] }

Quarto estágio:

$replaceWith usa $arrayToObject para converter items2 em um documento, usando os pares de chave k e valor v especificados, e envia esse documento para o próximo estágio. Por exemplo:

{ "_id" : "2019Q1", "A" : 400, "B" : 550, "C" : 1000 }

A aggregation retorna o seguinte documento:

{ "_id" : "2019Q1", "A" : 400, "B" : 550, "C" : 1000 }
{ "_id" : "2019Q2", "A" : 660, "B" : 500, "C" : 1200 }