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. A partir do MongoDB 8.0, você pode executar operações de gravação em massa em vários bancos de dados e collections. Se você estiver usando uma versão anterior ao MongoDB 8.0, poderá executar operações de gravação em massa em uma única coleção.

Para realizar operações de escrita em massa em vários bancos de dados e collections no MongoDB 8.0, use o comando de banco de dadosbulkWrite ou o método Mongo.bulkWrite() mongosh.

Para executar operações de escrita em massa em uma única collection, use o método db.collection.bulkWrite() mongosh. Se você estiver executando o MongoDB 8.0 ou posterior, também poderá usar bulkWrite ou Mongo.bulkWrite() para escrever em uma única collection.

Operações ordenadas versus não ordenadas

Você pode definir suas operações de gravação em massa como 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.

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 gravação restantes na lista.

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, todos os comandos e métodos de gravação em massa executam operações ordenadas. Para especificar operações não ordenadas, defina a opção ordered como false ao chamar seu comando ou método preferido. Para saber mais sobre a sintaxe de cada comando ou método, consulte suas páginas vinculadas acima.

Métodos de gravação em massa

Todos os métodos e comandos de escrita em massa suportam as seguintes operações de escrita:

• insertOne

• UpdateOne

• UpdateMany

• replaceOne

• Excluir um

• deleteMany

Ao chamar seu comando ou método preferido, você passa cada operação de gravação como um documento em uma array. Para saber mais sobre a sintaxe de cada comando ou método, consulte suas páginas vinculadas acima.

Exemplo

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 )
}

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

db.getMongo().bulkWrite(
   [
      {
         namespace: 'db.authors',
         name: 'insertOne',
         document: { name: 'Stephen King' }
      },
      {
         namespace: 'db.books',
         name: 'insertOne',
         document: { name: 'It' }
      },
      {
         namespace: 'db.books',
         name: 'updateOne',
         filter: { name: 'it' },
         update: { $set: { year: 1986 } }
      }
   ],
   {
      ordered: true,
      bypassDocumentValidation: true
   }
)

{
   acknowledged: true,
   insertedCount: 2,
   matchedCount: 1,
   modifiedCount: 1,
   deletedCount: 0,
   upsertedCount: 0,
   insertResults: { '1': { insertedId: ObjectId('67ed8ce8efd926c84cab7945') },
                    '2': { insertedId: ObjectId('67ed8ce8efd926c84cab7946') } }
   updateResults: { '1': { matchedCount: 1, modifiedCount: 1, didUpsert: false } }
}

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
}