Dimensões que mudam lentamente

Exemplo

Considere uma collection chamada prices que armazena os preços de um conjunto de itens. Você precisa acompanhar as alterações do preço de um item ao longo do tempo para poder processar as devoluções de um item, pois o valor reembolsado deve corresponder ao preço do item no momento da compra. Cada documento na coleção tem um campo item e price :

db.prices.insertMany( [
   { 'item': 'shorts', 'price': 10 },
   { 'item': 't-shirt', 'price': 2 },
   { 'item': 'pants', 'price': 5 },
] )

Suponha que o preço das roupas mude de 5 para 7. Para rastrear essa alteração de preço, assuma os valores padrão para os campos de dados necessários para o Tipo de SCD 2. O valor padrão para validFrom é 01.01.1900, validTo é 01.01.9999 e isValid é true. Para alterar o campo price no objeto com 'item': 'pants', insira um novo documento para representar o estado atual da calca e atualize o documento válido anteriormente para não ser mais válido:

let now = new Date();
db.prices.updateOne(
   {
      'item': 'pants',
      "$or": [
         { "isValid": false },
         { "isValid": null }
      ]
   },
   { "$set":
      {
         "validFrom": new Date("1900-01-01"),
         "validTo": now,
         "isValid": false
      }
   }
);
db.prices.insertOne(
   {
      'item': 'pants',
      'price': 7,
      "validFrom": now,
      "validTo": new Date("9999-01-01"),
      "isValid": true
   }
);

Para evitar a quebra da cadeia de validade, certifique-se de que ambas as operações de banco de dados acima ocorram no mesmo registro de data e hora. Dependendo dos requisitos do aplicação, é possível encapsular os dois comandos acima em uma transação para garantir que o MongoDB sempre aplique as duas alterações juntas. Para mais informações, consulteTransações .

A seguinte operação demonstra como fazer query do price mais recente do documento que contém o item pants:

db.prices.find( { 'item': 'pants', 'isValid': true } );

Para executar query do price do documento contendo o item pants em um ponto específico no tempo, use a seguinte operação:

let time = new Date("2022-11-16T13:00:00");
db.prices.find( {
   'item': 'pants',
   'validFrom': { '$lte': time },
   'validTo': { '$gt': time }
} );

Monitoramento de alterações em alguns campos

Se você só precisar acompanhar as alterações ao longo do tempo em alguns campos de um documento, poderá usar o tipo SCD 3 incorporando o histórico de um campo como uma array no primeiro documento.

Por exemplo, o agregação pipeline a seguir atualiza o price no documento que representa pants para 7 e armazena o valor anterior do price com um carimbo de data/hora de quando o price anterior se tornou inválido em uma array chamada priceHistory:

db.prices.aggregate( [
   { $match: { 'item': 'pants' } },
   { $addFields:
      { price: 7, priceHistory:
         { $concatArrays:
            [
               { $ifNull: [ '$priceHistory', [] ] },
               [ { price: "$price", time: now } ]
            ]
         }
      }
   },
   { $merge:
      {
         into: "prices",
         on: "_id",
         whenMatched: "merge",
         whenNotMatched: "fail"
      }
   }
] )

Essa solução pode se tornar lenta ou ineficiente se o tamanho do array ficar muito grande. Para evitar arrays grandes, você pode usar o outlier ou os padrões de bucket para projetar seu esquema.