Junção de vários campos

Adicione um estágio de pesquisa para vincular as collection e importar campo

O primeiro estágio do pipeline é um estágio $lookup para unir a collection orders à collection products por dois campos em cada collection. O estágio de pesquisa contém um pipeline incorporado para configurar a união.

No pipeline incorporado, adicione um estágio $match para corresponder aos valores de dois campos em cada lado da união. Observe que o código a seguir usa nomes alternativos para os campos name e variation definidos ao criar o estágio $lookup:

const embedded_pl = [];
embedded_pl.push({
  $match: {
    $expr: {
      $and: [
        { $eq: ["$product_name", "$$prdname"] },
        { $eq: ["$product_variation", "$$prdvartn"] },
      ],
    },
  },
});

No pipeline incorporado, adicione outro estágio $match para corresponder aos pedidos feitos em 2020:

embedded_pl.push({
  $match: {
    orderdate: {
      $gte: new Date("2020-01-01T00:00:00Z"),
      $lt: new Date("2021-01-01T00:00:00Z"),
    },
  },
});

No pipeline incorporado, adicione um estágio $unset para remover campos desnecessários do lado da coleção orders da união:

embedded_pl.push({
  $unset: ["_id", "product_name", "product_variation"],
});

Após a conclusão do pipeline incorporado, adicione o estágio $lookup ao pipeline de agregação principal. Configure este estágio para armazenar os campos de pesquisa processados em um campo de matriz denominado orders:

pipeline.push({
  $lookup: {
    from: "orders",
    let: {
      prdname: "$name",
      prdvartn: "$variation",
    },
    pipeline: embedded_pl,
    as: "orders",
  },
});

Adicione um estágio de correspondência para produtos pedidos em 2020

Em seguida, adicione um estágio $match para mostrar apenas produtos para os quais há pelo menos um pedido em 2020, com base na array orders calculada na etapa anterior:

pipeline.push({
  $match: {
    orders: { $ne: [] },
  },
});

Adicione um estágio não definido para remover campos desnecessários

Finalmente, adicione um estágio $unset . O estágio $unset remove os campos _id e description dos documentos de resultado:

pipeline.push({
  $unset: ["_id", "description"],
});

Executar o pipeline de agregação

Adicione o seguinte código ao final do seu aplicativo para executar a aggregation na collection products :

const aggregationResult = await productsColl.aggregate(pipeline);

Por fim, execute o seguinte comando em seu shell para iniciar seu aplicativo:

node agg_tutorial.js

Interpretar resultados

O resultado agregado contém dois documentos. Os documentos representam produtos para os quais houve pedidos feitos em 2020. Cada documento contém um campo de array orders que lista detalhes sobre cada pedido para esse produto:

{
  name: 'Asus Laptop',
  variation: 'Standard Display',
  category: 'ELECTRONICS',
  orders: [
    {
      customer_id: 'elise_smith@myemail.com',
      orderdate: 2020-05-30T08:35:52.000Z,
      value: 431.43
    },
    {
      customer_id: 'jjones@tepidmail.com',
      orderdate: 2020-12-26T08:55:46.000Z,
      value: 429.65
    }
  ]
}
{
  name: 'Morphy Richards Food Mixer',
  variation: 'Deluxe',
  category: 'KITCHENWARE',
  orders: [
    {
      customer_id: 'oranieri@warmmail.com',
      orderdate: 2020-01-01T08:25:37.000Z,
      value: 63.13
    }
  ]
}

Os documentos de resultado contêm detalhes de documentos na collection orders e na collection products , unidas pelos nomes e variações do produto.