バケット パターンでデータをグループ化する

バケット パターンを含むデータのクエリ

更新されたスキーマでは、各ドキュメントにアプリケーション内の 1 つのページのデータが含まれています。 _idcountデータを返して更新する方法を決定するには、 フィールドと フィールドを使用します。

適切なページのデータをクエリするには、正規表現クエリを使用して指定されたcustomerIdのデータを返し、 skipを使用して正しいページのデータを返します。 _idの正規表現クエリはデフォルトの _id インデックスを使用するため、追加のインデックスは必要ありません。

次のクエリは、カスタマー123のトランザクションの最初のページのデータを返します。

db.trades.find( { "_id": /^123_/ } ).sort( { _id: 1 } ).limit(1)

後続のページのデータを返すには、データを表示するページより 1 つ小さいskip値を指定します。 たとえば、ページ10のデータを表示するには、次のクエリを実行します。

db.trades.find( { "_id": /^123_/ } ).sort( { _id: 1 } ).skip(9).limit(1)

バケット パターンを使用したデータの挿入

スキーマがバケット パターンを使用するようになりました。アプリケーション ロジックを更新して、新しいトランザクションを正しいバケットに挿入します。 アップデート コマンドを使用して、適切なcustomerIdと バケットを持つバケットにトランザクションを挿入します。

次のコマンドは、 customerId: 123の新しいトランザクションを挿入します。

db.trades.updateOne( { "_id": /^123_/, "count": { $lt: 10 } },
   {
      "$push": {
         "history": {
         "type": "buy",
         "ticker": "MSFT",
         "qty": 42,
         "date": ISODate("2023-11-02T11:43:10")
       }
    },
    "$inc": { "count": 1 },
    "$setOnInsert": { "_id": "123_1698939791", "customerId": 123 }
   },
   { upsert: true }
)

アプリケーションには、1 ページあたり10のトランザクションが表示されます。 アップデート フィルターは、 countが10より小さいcustomerId: 123のドキュメントを検索します。つまり、バケットには完全なページのデータが含まれていません。

• "_id": /^123_/に一致するドキュメントがあり、そのcountが10より小さい場合、アップデート コマンドは新しいトランザクションを一致したドキュメントのhistory配列にプッシュします。

• 一致するドキュメントがない場合、アップデート コマンドは新しいトランザクションを含む新しいドキュメントを挿入します（ upsertはtrueであるため）。 新しいドキュメントの_idフィールドは、 customerIdとトランザクションの UNIX エポックからの時間（秒単位）を連結したものです。

アップデート コマンドのロジックは、 history配列に10ドキュメントを超えるドキュメントが含まれないようにすることで、無制限配列を回避します。

アップデート操作の実行後、 tradesコレクションには次のドキュメントが含まれます。

[
  {
    _id: '123_1698349623',
    customerId: 123,
    count: 3,
    history: [
      {
        type: 'buy',
        ticker: 'MDB',
        qty: 419,
        date: ISODate("2023-10-26T15:47:03.434Z")
      },
      {
        type: 'sell',
        ticker: 'MDB',
        qty: 29,
        date: ISODate("2023-10-30T09:32:57.765Z")
      },
      {
        type: 'buy',
        ticker: 'MSFT',
        qty: 42,
        date: ISODate("2023-11-02T11:43:10.000Z")
      }
    ]
  },
  {
    _id: '456_1698765362',
    customerId: 456,
    count: 1,
    history: [
      {
        type: 'buy',
        ticker: 'GOOG',
        quantity: 50,
        date: ISODate("2023-10-31T11:16:02.120Z")
      }
    ]
  }
]