Operações de gravação em massa

Visão geral

O MongoDB oferece aos clientes a capacidade de realizar operações de gravação em massa. Operações de gravação em massa afetam uma única coleção. O MongoDB permite que os aplicativos determinem o nível aceitável de confirmação necessário para operações de gravação em massa.

O método db.collection.bulkWrite() oferece a capacidade de realizar operações de inserção, atualização e exclusão em massa.

O MongoDB também suporta inserção em massa pelo método db.collection.insertMany().

Operações ordenadas versus não ordenadas

Operações de gravação em massa podem ser ordenadas ou não ordenadas.

Com uma lista ordenada de operações, o MongoDB executa as operações serialmente. Se ocorrer um erro durante o processamento de uma das operações de gravação, o MongoDB retornará sem processar as operações de gravação restantes na lista.Ver escrita em massa ordenada

Com uma lista não ordenada de operações, o MongoDB pode executar as operações em paralelo, mas esse comportamento não é garantido. Se ocorrer um erro durante o processamento de uma das operações de gravação, o MongoDB continuará processando as operações de escrita restantes na lista. Veja o exemplo de escrita em massa não ordenada.

Em geral, a execução de uma lista ordenada de operações em uma coleção fragmentada será mais lenta do que a execução de uma lista não ordenada, pois com uma lista ordenada, cada operação deve aguardar a conclusão da operação anterior.

Por padrão, o bulkWrite() executa operações do ordered. Para especificar unordered operações de gravação, defina ordered : false no documento de opções.

Consulte Execução de operações

Métodos bulkWrite()

bulkWrite() suporta as seguintes operações de gravação:

• insertOne

• Atualização 1

• updateMany

• replaceOne

• Excluir um

• deleteMany

Cada operação de gravação é passada para bulkWrite() como um documento em uma array.

Exemplo

O exemplo nesta seção utiliza a coleção pizzas:

db.pizzas.insertMany( [
   { _id: 0, type: "pepperoni", size: "small", price: 4 },
   { _id: 1, type: "cheese", size: "medium", price: 7 },
   { _id: 2, type: "vegan", size: "large", price: 8 }
] )

O seguinte exemplo do bulkWrite() executa estas operações na coleção do pizzas :

• Adiciona dois documentos usando insertOne.

• Atualiza um documento usando updateOne.

• Exclui um documento usando deleteOne.

• Substitui um documento usando replaceOne.

try {
   db.pizzas.bulkWrite( [
      { insertOne: { document: { _id: 3, type: "beef", size: "medium", price: 6 } } },
      { insertOne: { document: { _id: 4, type: "sausage", size: "large", price: 10 } } },
      { updateOne: {
         filter: { type: "cheese" },
         update: { $set: { price: 8 } }
      } },
      { deleteOne: { filter: { type: "pepperoni"} } },
      { replaceOne: {
         filter: { type: "vegan" },
         replacement: { type: "tofu", size: "small", price: 4 }
      } }
   ] )
} catch( error ) {
   print( error )
}

Exemplo de saída, que inclui um resumo das operações concluídas:

{
   acknowledged: true,
   insertedCount: 2,
   insertedIds: { '0': 3, '1': 4 },
   matchedCount: 2,
   modifiedCount: 2,
   deletedCount: 1,
   upsertedCount: 0,
   upsertedIds: {}
}

Para obter mais exemplos, consulte Exemplos de BulkWrite().

Estratégias para inserção em massa em uma coleção compartilhada

Grandes operações de inserção em massa, incluindo inserções iniciais de dados ou importação de dados de rotina, podem afetar o desempenho do cluster fragmentado. Para inserções em massa, considere as seguintes estratégias:

using namespace mongo;
OID make_an_id() {
  OID x = OID::gen();
  const unsigned char *p = x.getData();
  swap( (unsigned short&) p[0], (unsigned short&) p[10] );
  return x;
}
void foo() {
  // create an object
  BSONObj o = BSON( "_id" << make_an_id() << "x" << 3 << "name" << "jane" );
  // now we may insert o into a sharded collection
}