Agrupar dados com padrão de Bucket

Consultar dados com o padrão de bucket

No esquema atualizado, cada documento contém dados para uma única página no aplicativo. Você pode usar os campos _id e count para determinar como retornar e atualizar dados.

Para consultar dados na página apropriada, use uma query regex para obter dados de um customerId especificado e use skip para retornar aos dados da página correta. A query regex em _id usa índice _id padrão, o que resulta em consultas de alto desempenho sem a necessidade de um índice adicional.

A consulta a seguir retorna dados da primeira página de negociações para o cliente 123:

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

Para retornar dados para páginas posteriores, especifique um valor de skip menor do que a página para a qual você deseja mostrar dados. Por exemplo, para mostrar dados para a página 10, execute a seguinte query:

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

Inserir dados com o padrão Bucket

Agora que o esquema usa o padrão de bucket, atualize a lógica do aplicativo para inserir novas negociações no bucket correto. Use o comando update para inserir a negociação no bucket com o customerId e o bucket apropriados.

O comando a seguir insere uma nova negociação para 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 }
)

O aplicação exibe 10 transações por página. O filtro de atualização procura um documento para customerId: 123 onde o count é menor que 10, o que significa que o bucket não contém uma página inteira de dados.

• Se houver um documento que corresponda a "_id": /^123_/ e seu count for menor que 10, o comando de atualização empurrará a nova transação para a array history do documento correspondente.

• Se não houver um documento correspondente, o comando de atualização inserirá um novo documento com a nova transação (porque upsert é true). O campo _id do novo documento é uma concatenação do customerId e o tempo em segundos desde a Era UNIX da transação.

A lógica para comandos de atualização evita arrays ilimitadas, garantindo que nenhuma array history contenha mais de 10 documentos.

Depois de executar a operação de atualização, a coleção trades tem os seguintes documentos:

[
  {
    _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")
      }
    ]
  }
]