1 対 1 の結合

項目一覧

はじめに

集計タスクの概要
始める前に
Tutorial
2020 年注文の一致ステージを追加します
コレクションをリンクするためにルックアップステージを追加します
新しいドキュメントフィールドを作成するにはセットステージを追加します
不要なフィールドを削除するために設定されていないステージを追加します
集計パイプラインの実行
結果の解釈

はじめに

このチュートリアルでは、Node.js ドライバーを使用して集計パイプラインを構築し、コレクションに対して集計を実行し、サンプルアプリを完了して実行して結果を出力する方法を学習できます。

この集計では 1 対 1 の結合が実行されます。 1 対 1 の結合は、1 つのコレクション内のドキュメントのフィールド値が、同じフィールド値を持つ別のコレクション内の単一のドキュメントと一致する場合に行われます。集計はフィールド値でこれらのドキュメントを照合し、両方のソースからの情報を 1 つの結果に結合します。

Tip

1 対 1 の結合では、ドキュメントに 1 対 1 の関係必要はありません。このデータ関係の詳細については、 Wikipedia の 1 対 1（データモデル）に関するエントリを参照してください。

集計タスクの概要

このチュートリアルでは、製品情報を記述するコレクションのデータと、カスタマーの注文を記述する別のコレクションのデータを組み合わせる方法を説明します。結果には、2020 年に行われたすべての注文のリストが表示され、各注文に関連付けられた製品の詳細が含まれます。

この例では、2 つのコレクションを使用します。

orders: 店舗内の製品の個々の注文を説明するドキュメントが含まれています
products: 店舗が販売する商品を説明するドキュメントが含まれています

注文には1つの製品しか含めることができないため、集計では 1 対 1 の結合を使用して注文ドキュメントと製品のドキュメントを照合します。コレクションは、両方のコレクションのドキュメントに存在するproduct_idというフィールドによって結合されます。

始める前に

このチュートリアルを開始する前に、集計テンプレートアプリの手順を完了して、動作する Node.js アプリケーションを設定してください。

ordersproductsアプリを設定したら、次のコードをアプリケーションに追加して、コレクションとコレクションにアクセスします。

const ordersColl = aggDB.collection("orders");
const productsColl = aggDB.collection("products");

次のコードに示すように、既存のデータを削除し、サンプルデータをordersコレクションに挿入します。

await ordersColl.deleteMany({});
const orderData = [
  {
    customer_id: "elise_smith@myemail.com",
    orderdate: new Date("2020-05-30T08:35:52Z"),
    product_id: "a1b2c3d4",
    value: 431.43,
  },
  {
    customer_id: "tj@wheresmyemail.com",
    orderdate: new Date("2019-05-28T19:13:32Z"),
    product_id: "z9y8x7w6",
    value: 5.01,
  },
  {
    customer_id: "oranieri@warmmail.com",
    orderdate: new Date("2020-01-01T08:25:37Z"),
    product_id: "ff11gg22hh33",
    value: 63.13,
  },
  {
    customer_id: "jjones@tepidmail.com",
    orderdate: new Date("2020-12-26T08:55:46Z"),
    product_id: "a1b2c3d4",
    value: 429.65,
  },
];
await ordersColl.insertMany(orderData);

次のコードに示すように、既存のデータを削除し、サンプルデータをproductsコレクションに挿入します。

await productsColl.deleteMany({});
const productData = [
  {
    id: "a1b2c3d4",
    name: "Asus Laptop",
    category: "ELECTRONICS",
    description: "Good value laptop for students",
  },
  {
    id: "z9y8x7w6",
    name: "The Day Of The Triffids",
    category: "BOOKS",
    description: "Classic post-apocalyptic novel",
  },
  {
    id: "ff11gg22hh33",
    name: "Morphy Richardds Food Mixer",
    category: "KITCHENWARE",
    description: "Luxury mixer turning good cakes into great",
  },
  {
    id: "pqr678st",
    name: "Karcher Hose Set",
    category: "GARDEN",
    description: "Hose + nosels + winder for tidy storage",
  },
];
await productsColl.insertMany(productData);

Tutorial

2020 年注文の一致ステージを追加します

2020での注文に一致する$matchステージを追加します。

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

コレクションをリンクするためにルックアップステージを追加します

次に、 $lookupステージを追加します。 $lookupステージは、 ordersコレクションのproduct_idフィールドをproductsコレクションのidフィールドに結合します。

pipeline.push({
  $lookup: {
    from: "products",
    localField: "product_id",
    foreignField: "id",
    as: "product_mapping",
  },
});

新しいドキュメントフィールドを作成するにはセットステージを追加します

次に、パイプラインに 2 つの$setステージを追加します。

最初の$setステージは、 product_mappingフィールドを、前の$lookupステージで作成されたproduct_mappingオブジェクトの最初の要素に設定します。

2 つ目の$setステージでは、 product_mappingオブジェクトフィールドの値から 2 つの新しいフィールド（ product_nameとproduct_category ）が作成されます。

pipeline.push(
    {
      $set: {
        product_mapping: { $first: "$product_mapping" },
      },
    },
    {
      $set: {
        product_name: "$product_mapping.name",
        product_category: "$product_mapping.category",
      },
    }
  );

Tip

これは 1 対 1 の結合であるため、 $lookupステージは入力ドキュメントに 1 つの配列要素のみを追加します。パイプラインは$first演算子を使用して、この要素からデータを検索します。

不要なフィールドを削除するために設定されていないステージを追加します

最後に、 $unsetステージを追加します。 $unsetステージは、ドキュメントから不要なフィールドを削除します。

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

集計パイプラインの実行

次のコードをアプリケーションの末尾に追加して、 ordersコレクションで集計を実行します。

const aggregationResult = await ordersColl.aggregate(pipeline);

最後に、shell で次のコマンドを実行してアプリケーションを起動します。

node agg_tutorial.js

結果の解釈

集計された結果には 3 つのドキュメントが含まれます。ドキュメントは、注文製品のproduct_nameとproduct_categoryを含む、2020 年に発生したカスタマーの注文を表します。

{
  customer_id: 'elise_smith@myemail.com',
  orderdate: 2020-05-30T08:35:52.000Z,
  value: 431.43,
  product_name: 'Asus Laptop',
  product_category: 'ELECTRONICS'
}
{
  customer_id: 'oranieri@warmmail.com',
  orderdate: 2020-01-01T08:25:37.000Z,
  value: 63.13,
  product_name: 'Morphy Richardds Food Mixer',
  product_category: 'KITCHENWARE'
}
{
  customer_id: 'jjones@tepidmail.com',
  orderdate: 2020-12-26T08:55:46.000Z,
  value: 429.65,
  product_name: 'Asus Laptop',
  product_category: 'ELECTRONICS'
}

結果は、 ordersコレクションとproductsコレクション内のドキュメントのフィールドを含むドキュメントで構成されており、各元のドキュメントに存在するproduct_idフィールドを一致させて結合されます。

このチュートリアルの完全なコードを表示するには、「完了した 1 対 1 の結合アプリ Github」を参照してください。 .

戻る

配列とグループを解凍

複数フィールド結合