MongoDB ステートメントを使用したクエリ

SELECT ステートメント

SELECT * FROM sessions;

MongoDB は Sessionsコレクションのすべてのドキュメントを返します。

制限ステートメント

SELECT * FROM users LIMIT 2;

MongoDB は Usersコレクションから 2 つのドキュメントを返します。

WHERE ステートメント

SELECT * FROM users WHERE name = 'Jon Snow';

MongoSQL は、ユーザーの name が Jon Snow であるドキュメントを Usersコレクションから返します。

With キーワード

WITH キーワードを使用すると、後で使用するための派生データソースの作成が簡単になります。

WITH RecentSales AS (
  SELECT customer_id, SUM(amount) AS total_sales
  FROM sales
  WHERE sale_date > '2025-01-01'
  GROUP BY customer_id
)
SELECT customer_id, total_sales
FROM RecentSales
WHERE total_sales > 1000;

MongoDB は、1、2025 年 1 月 日以降の合計売上額が 1000 を超える customer_id を持つドキュメントを Salesコレクションから返します。

FLATTEN

FLATTEN 半構造化データ（JSON 内の名前と値のペア）を別々の列にフラット化します。 フィールド名は、そのフィールドのすべての値を行に保持する列名になります。

ネストされたドキュメントをフラット化するための構文は、データソースと オプションと組み合わせてFROM句で使用できるFLATTEN関数です。

SELECT *
FROM FLATTEN(<data source>
 WITH DEPTH => <integer>,
 SEPARATOR => <string>
)

平面の例

サンプルシナリオでは、 customerInfoコレクションには次のように構造されたドキュメントが含まれています。

{
  id: 1,
  location: "New York",
  customer: {
    age: 50,
    email: "customer@email.com",
    satisfaction: 5
  }
}

クエリ SELECT * FROM customerInfo を実行すると、MongoSQL は次の最上位フィールドを持つドキュメントを返します。

クエリ SELECT * FROM FLATTEN(customerInfo) を実行すると、MongoSQL は次の最上位フィールドを持つドキュメントを返します。

FLATTENを使用すると、元のドキュメントの各フラット化フィールドは結果セットの最上位フィールドになります。 ネストされたフィールドは親フィールド名と連結され、デフォルトの区切り文字_で区切られます。

UNWIND

UNWIND 入力データソースから配列フィールドを分解して、その配列内の各項目に対して 1 行を出力します。 展開の詳細については、 $unwind集計ステージのドキュメントを参照してください。

配列フィールドを展開する構文は、データソースと オプションと組み合わせてFROM句で使用できるUNWIND関数です。

SELECT *
FROM UNWIND(<data source>
 WITH PATH | PATHS => <array_paths>,
 INDEX => <identifier>,
 OUTER => <bool>
)

展開例: 最上位フィールド

サンプルシナリオでは、 customerInfoコレクションには次のように構造されたドキュメントが含まれています。

{
  id: 1,
  location: "New York",
  customer: {
    age: 50,
    email: "customer@email.com",
    satisfaction: 5
  },
  visits: [
    {
      year: 2020,
      score: 10
    },
    {
      year: 2021,
      score: 8
    },
    {
      year: 2022
      score: 7
    }
  ]
}

クエリ SELECT * FROM customerInfo を実行すると、MongoSQL は次の最上位フィールドを持つドキュメントを返します。

クエリ SELECT * FROM UNWIND(customerInfo WITH PATH => visits, INDEX => idx) を実行すると、MongoSQL は次の最上位フィールドを持つドキュメントを返します。

UNWINDとPATH => visitsを併用すると、各visitsオブジェクトはテーブル行になります。

展開例: ネストされた配列と保存配列の展開

サンプルシナリオでは、 customerInfoコレクションには次のように構造されたドキュメントが含まれています。

{
  "id": 1,
  "location": "New York",
  "customer": {
    "age": 50,
    "email": "customer@email.com",
    "satisfaction": 5
  },
  "visits": [
    {
      "year": 2020,
      "score": 10
    },
    {
      "year": 2021,
      "score": 8
    },
    {
      "year": 2022,
      "score": 7
    }
  ],
  "purchases": [
    {
      "transaction": "1A",
      "transactions": [
        {
          "amount": 100
        },
        {
          "amount": 150
        }
      ]
    },
    {
      "transaction": "2B",
      "transactions": [
        {
          "amount": 200
        }
      ]
    }
  ]
}

次のクエリを実行するとします。

SELECT v.year AS visit_year, v.score AS visit_score, p.transaction AS transaction_id, t.amount AS purchase_amount
FROM UNWIND(
  customerInfo WITH PATHS => (
    visits[INDEX => visit_idx],
    purchases[OUTER => TRUE, INDEX => purchase_idx].transactions[]
  ),
  INDEX => idx,
  OUTER => FALSE
)

上記のクエリでは、次の処理が行われます。

• visits 配列を展開し、展開した配列内のインデックス位置を追跡するためにインデックス名 visit_idx を割り当てます。

• 各 purchasesオブジェクト内で purchases 配列を展開し、transactions 配列を展開します。また、OUTER => TRUEを使用して、transactions 配列が欠落しているか空である購入を保持します。

MongoSQL では、次のフィールドを持つドキュメントが返されます。

結果では、各行には 1 つの visits エントリと 1 つの transactions エントリのデータが含まれています。

FLATTEN と UNIX を組み合わせた例

次の例では、FLATTEN 関数とUNWIND 関数を組み合わせています。

サンプルシナリオでは、 customerInfoコレクションには次のように構造されたドキュメントが含まれています。

{
  id: 1,
  location: "New York",
  customer: {
    age: 50,
    email: "customer@email.com",
    satisfaction: 5
  },
  visits: [
    {
      year: 2020,
      score: 10
    },
    {
      year: 2021,
      score: 8
    },
    {
      year: 2022
      score: 7
    }
  ]
}

クエリ SELECT * FROM customerInfo を実行すると、MongoSQL は次の最上位フィールドを持つドキュメントを返します。

クエリ Select * from FLATTEN(UNWIND(customerInfo WITH PATH => visits, INDEX => idx)) を実行すると、MongoSQL は次の最上位フィールドを持つドキュメントを返します。

FLATTEN関数とUNWIND 関数の両方を使用すると、visits 配列が展開され、結果のドキュメントがフラット化されます。