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

项目结构： 项目的结构将如下所示：

Mongoose Document Model.bulkWrite()函数

数据库结构： 数据库结构将会像这样，以下文档存在集合中。

Mongoose Document Model.bulkWrite()函数

示例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表示：

Mongoose Document Model.bulkWrite()函数

示例2： 在这个示例中，我们使用 bulkWrite() 方法执行deleteOne和deleteMany操作。在执行命令之前，集合中存在以下文档。

Mongoose Document Model.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([ 
    { 
        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: []
  }
}