Operações em massa

Dados de amostra

Os exemplos neste guia usam as movies users collections e no sample_mflix banco de dados , que está incluído nos conjuntos de dados de amostra do Atlas . Para saber como criar um cluster MongoDB Atlas gratuito e carregar os conjuntos de dados de amostra, consulte o guia Iniciar com Atlas .

Inserções em massa de collections

Para executar uma operação de inserção em massa na sua collection, crie um InsertOneModel para cada operação. Em seguida, chame o método bulkWrite() em sua coleção e passe uma array de modelos como parâmetro. Para criar um InsertOneModel, especifique o campo document do modelo e defina-o para o documento que você deseja inserir.

const insertModels = [{
    insertOne: {
        document: {
            title: "The Favourite",
            year: 2018,
            rated: "R",
            released: "2018-12-21"
        }
    }
}, {
    insertOne: {
        document: {
            title: "I, Tonya",
            year: 2017,
            rated: "R",
            released: "2017-12-08"
        }
    }
}];
const insertResult = await movies.bulkWrite(insertModels);
console.log(`Inserted documents: ${insertResult.insertedCount}`);

Inserted documents: 2

Inserções em massa do cliente

Para executar uma operação de inserção em massa em múltiplas coleções ou bancos de dados, crie um ClientBulkWriteModel para cada operação. Em seguida, chame o método bulkWrite() em seu cliente e passe uma array de modelos como parâmetro.

A tabela seguinte descreve os campos que você pode configurar em um ClientBulkWriteModel para especificar uma operação de inserção:

const clientInserts = [{
    namespace: "sample_mflix.movies",
    name: "insertOne",
    document: {
        title: "The Favourite",
        year: 2018,
        rated: "R",
        released: "2018-12-21"
    }
}, {
    namespace: "sample_mflix.movies",
    name: "insertOne",
    document: {
        title: "I, Tonya",
        year: 2017,
        rated: "R",
        released: "2017-12-08"
    }
}, {
    namespace: "sample_mflix.users",
    name: "insertOne",
    document: {
        name: "Brian Schwartz",
        email: "bschwartz@example.com"
    }
}];
const clientInsertRes = await client.bulkWrite(clientInserts);
console.log(`Inserted documents: ${clientInsertRes.insertedCount}`);

Inserted documents: 3

Coleções de substituições em massa

Para executar uma operação de substituição em massa na sua collection, crie um ReplaceOneModel para cada operação. Em seguida, chame o método bulkWrite() em sua coleção e passe uma array de modelos como parâmetro.

A tabela a seguir descreve os campos que você pode definir em um ReplaceOneModel:

const replaceOperations = [{
    replaceOne: {
        filter: {
            title: "The Dark Knight"
        },
        replacement: {
            title: "The Dark Knight Rises",
            year: 2012,
            rating: "PG-13"
        },
        upsert: false
    }
}, {
    replaceOne: {
        filter: {
            title: "Inception"
        },
        replacement: {
            title: "Inception Reloaded",
            year: 2010,
            rating: "PG-13"
        },
        upsert: false
    }
}];
const replaceResult = await movies.bulkWrite(replaceOperations);
console.log(`Modified documents: ${replaceResult.modifiedCount}`);

Modified documents: 2

Substituições em massa do cliente

Para executar uma operação de substituição em massa em múltiplas coleções ou bancos de dados, crie um ClientBulkWriteModel para cada operação. Em seguida, chame o método bulkWrite() em seu cliente e passe uma array de modelos como parâmetro.

A tabela seguinte descreve os campos que você pode configurar em um ClientBulkWriteModel para especificar uma operação de substituição:

const clientReplacements = [{
    namespace: "sample_mflix.movies",
    name: "replaceOne",
    filter: {
        title: "The Dark Knight"
    },
    replacement: {
        title: "The Dark Knight Rises",
        year: 2012,
        rating: "PG-13"
    }
}, {
    namespace: "sample_mflix.movies",
    name: "replaceOne",
    filter: {
        title: "Inception"
    },
    replacement: {
        title: "Inception Reloaded",
        year: 2010,
        rating: "PG-13"
    }
}, {
    namespace: "sample_mflix.users",
    name: "replaceOne",
    filter: {
        name: "April Cole"
    },
    replacement: {
        name: "April Franklin",
        email: "aprilfrank@example.com"
    }
}];
const clientReplaceRes = await client.bulkWrite(clientReplacements);
console.log(`Modified documents: ${clientReplaceRes.modifiedCount}`);

Modified documents: 3

Atualizações em massa de coleções

Para executar uma operação de atualização em massa na sua collection, crie um UpdateOneModel ou UpdateManyModel para cada operação. Em seguida, chame o método bulkWrite() em sua collection e passe uma array de modelos como parâmetro. Um UpdateOneModel atualiza somente um documento que corresponde a um filtro, enquanto um UpdateManyModel atualiza todos os documentos que correspondem a um filtro.

A tabela a seguir descreve os campos que você pode definir em um UpdateOneModel ou UpdateManyModel:

const updateOperations = [{
    updateOne: {
        filter: {
            title: "Interstellar"
        },
        update: {
            $set: {
                title: "Interstellar Updated",
                genre: "Sci-Fi Adventure"
            }
        },
        upsert: true
    }
}, {
    updateMany: {
        filter: {
            rated: "PG-13"
        },
        update: {
            $set: {
                rated: "PG-13 Updated",
                genre: "Updated Genre"
            }
        }
    }
}];
const updateResult = await movies.bulkWrite(updateOperations);
console.log(`Modified documents: ${updateResult.modifiedCount}`);

Modified documents: 2320

Atualizações em massa do cliente

Para executar uma operação de atualização em massa em múltiplas coleções ou bancos de dados, crie um ClientBulkWriteModel para cada operação. Em seguida, chame o método bulkWrite() em seu cliente e passe uma array de modelos como parâmetro.

A tabela seguinte descreve os campos que você pode configurar em um ClientBulkWriteModel para especificar uma operação de atualização:

const clientUpdates = [{
    namespace: "sample_mflix.movies",
    name: "updateMany",
    filter: {
        rated: "PG-13"
    },
    update: {
        $set: {
            rated: "PG-13 Updated",
            genre: "Updated Genre"
        }
    },
    upsert: false
}, {
    namespace: "sample_mflix.users",
    name: "updateOne",
    filter: {
        name: "Jon Snow"
    },
    update: {
        $set: {
            name: "Aegon Targaryen",
            email: "targaryen@example.com"
        }
    },
    upsert: false
}];
const clientUpdateRes = await client.bulkWrite(clientUpdates);
console.log(`Modified documents: ${clientUpdateRes.modifiedCount}`);

Modified documents: 2320

Exclusões em massa de collections

Para executar uma operação de exclusão em massa em sua collection, crie um DeleteOneModel ou DeleteManyModel para cada operação. Em seguida, chame o método bulkWrite() em sua collection e passe uma array de modelos como parâmetro. Um DeleteOneModel exclui apenas um documento que corresponde a um filtro, enquanto um DeleteManyModel exclui todos os documentos que correspondem a um filtro.

A tabela a seguir descreve os campos que você pode definir em DeleteOneModel ou DeleteManyModel:

const deleteOperations = [{
    deleteOne: {
        filter: {
            title: "Dunkirk"
        }
    }
}, {
    deleteMany: {
        filter: {
            rated: "R"
        }
    }
}];
const deleteResult = await movies.bulkWrite(deleteOperations);
console.log(`Deleted documents: ${deleteResult.deletedCount}`);

Deleted documents: 5538

Exclusões em massa de clientes

Para executar uma operação de exclusão em massa em várias coleções ou bancos de dados, crie um ClientBulkWriteModel para cada operação. Em seguida, chame o método bulkWrite() em seu cliente e passe uma array de modelos como parâmetro.

A tabela seguinte descreve os campos que você pode configurar em um ClientBulkWriteModel para especificar uma operação de exclusão:

const clientDeletes = [{
    namespace: "sample_mflix.movies",
    name: "deleteMany",
    filter: {
        rated: "R"
    }
}, {
    namespace: "sample_mflix.users",
    name: "deleteOne",
    filter: {
        email: "emilia_clarke@gameofthron.es"
    }
}];
const clientDeleteRes = await client.bulkWrite(clientDeletes);
console.log(`Deleted documents: ${clientDeleteRes.deletedCount}`);

Deleted documents: 5538

BulkWriteResult

O método Collection.bulkWrite() retorna um objeto BulkWriteResult, que fornece informações sobre sua operação em massa.

As tabelas a seguir descrevem os campos de um objeto BulkWriteResult :

ClientBulkWriteResult

O método MongoClient.bulkWrite() retorna um objeto ClientBulkWriteResult , que inclui informações sobre a operação de gravação em massa do cliente .

As tabelas a seguir descrevem os campos de um objeto ClientBulkWriteResult :

Exceções de gravação em massa da collection

Se alguma operação de gravação em massa chamada em uma collection não for bem-sucedida, o driver Node.js lançará um MongoBulkWriteError e não executará mais nenhuma operação se a opção ordered estiver definida como true. Se ordered estiver definido como false, ele tentará continuar com as operações subsequentes.

Um objeto MongoBulkWriteError contém as seguintes propriedades:

Exceções de gravação em massa do cliente

Se alguma operação de gravação em massa chamada em seu cliente não tiver êxito, o driver do Node.js gerará um MongoClientBulkWriteError. Por padrão, o driver não executa nenhuma operação subsequente após encontrar um erro. Se você passar a opção ordered para o método bulkWrite() e defini-la como false, o driver continuará tentando as operações restantes.

Um objeto MongoClientBulkWriteError contém as seguintes propriedades:

Documentação da API

Para saber mais sobre qualquer um dos métodos ou tipos discutidos neste guia, consulte a seguinte documentação da API:

• Collection.bulkWrite()

• MongoClient.bulkWrite()

• BulkWriteResult

• ClientBulkWriteResult

• ClientBulkWriteModel

• InsertOneModel

• InsertOne

• replaceOne

• ReplaceOneModel

• UpdateOne

• UpdateMany

• UpdateOneModel

• DeleteOne

• deleteMany

• DeleteOneModel