Mongoose Document Model.bulkWrite()函数
Mongoose API 的 Model.bulkWrite() 方法用于在一个命令中执行多个操作。它可以插入多个文档,可以更新一个或多个文档,可以替换文档,可以在一个单一命令中删除文档。相比于多个独立的创建命令,这种方式在性能上更快。
语法:
Model.bulkWrite()
参数: Model.bulkWrite() 方法接受三个参数:
- operations: 它是一个包含多个操作的对象数组。例如:insertOne、updateOne、updateMany、deleteOne、deleteMany、replaceOne等。
- options: 它是一个包含多个属性的对象。
- callback: 它是一个在执行完成后运行的回调函数。
返回值: Model.bulkWrite() 函数返回一个Promise。如果命令成功,其命名为BulkWriteOpResult。
设置Node.js应用程序:
步骤1: 使用以下命令创建一个Node.js应用程序:
npm init
步骤2: 创建NodeJS应用程序后,使用以下命令安装所需的模块:
npm install mongoose
项目结构: 项目的结构将如下所示:
数据库结构: 数据库结构将会像这样,以下文档存在集合中。
示例1: 在这个示例中,我们使用mongoose建立了一个数据库连接,并在userSchema上定义了一个模型,该模型具有两个列或字段“name”和“age”。最后,我们在User模型上使用了bulkWrite()方法,该方法具有各种操作,如insertOne,UpdateOne。我们将这些作为对象数组作为bulkWrite()方法的第一个参数提供。在这个示例中,我们插入了一个新文档并更新了现有文档。
- app.js: 将以下代码写入app.js文件中:
// Require mongoose module
const mongoose = require("mongoose");
// Set Up the Database connection
mongoose.connect("mongodb://localhost:27017/geeksforgeeks", {
useNewUrlParser: true,
useUnifiedTopology: true,
});
const userSchema = new mongoose.Schema({
name: String,
age: Number,
});
// Defining userSchema model
const User = mongoose.model("User", userSchema);
User.bulkWrite([
{
insertOne: {
document: {
name: "User4",
age: 30,
},
},
},
{
updateOne: {
filter: { name: "User1" },
update: { name: "User1 Updated" },
},
},
]).then((result) => {
console.log(result);
});
运行程序的步骤: 要运行应用程序,请从项目的根目录执行以下命令:
node app.js
输出:
BulkWriteResult {
result: {
ok: 1,
writeErrors: [],
writeConcernErrors: [],
insertedIds: [ [Object] ],
nInserted: 1,
nUpserted: 0,
nMatched: 1,
nModified: 1,
nRemoved: 0,
upserted: []
}
}
使用Robo3T GUI工具的数据库的GUI表示:
示例2: 在这个示例中,我们使用 bulkWrite() 方法执行deleteOne和deleteMany操作。在执行命令之前,集合中存在以下文档。
- app.js: 将下面的代码写在app.js文件中:
// Require mongoose module
const mongoose = require("mongoose");
// Set Up the Database connection
mongoose.connect("mongodb://localhost:27017/geeksforgeeks", {
useNewUrlParser: true,
useUnifiedTopology: true,
});
const userSchema = new mongoose.Schema({
name: String,
age: Number,
});
// Defining userSchema model
const User = mongoose.model("User", userSchema);
User.bulkWrite([
{
deleteOne: {
filter: { name: "User4" }
}
},
{
deleteMany: {
filter: { age: 20 },
}
},
]).then((result) => {
console.log(result);
});
运行程序的步骤: 要运行应用程序,请从项目的根目录执行以下命令:
node app.js
输出结果:
BulkWriteResult {
result: {
ok: 1,
writeErrors: [],
writeConcernErrors: [],
insertedIds: [],
nInserted: 0,
nUpserted: 0,
nMatched: 0,
nModified: 0,
nRemoved: 3,
upserted: []
}
}
使用Robo3T GUI工具的数据库的GUI表示:
参考: https://mongoosejs.com/docs/api/model.html#model_Model-bulkWrite