Mongoose Aggregate.prototype.exec()函数
Aggregate .prototype.exec() 方法是Mongoose API的一部分,用于执行聚合任务。它允许我们在当前模型上执行聚合管道。它接受一个回调函数作为参数,并返回一个promise。
语法:
aggregate.exec( callback )
参数: 此方法接受一个参数,如下所述:
- callback: 用于处理方法返回的promise。
返回值: 此方法返回一个promise,可以使用回调函数或使用async-await进行处理。
设置Node.js应用程序:
步骤1: 使用以下命令创建一个Node.js应用程序:
npm init
步骤2: 创建NodeJS应用程序后,使用以下命令安装所需的模块:
npm install mongoose
项目结构: 项目结构将如下所示:
数据库结构:
数据库的结构将如下所示,下列文档存在于集合中。
示例1: 在这个示例中,我们使用mongoose建立了一个数据库连接,并在cricketerSchema上定义了一个模型,该模型包含三个列或字段“_id”、“name”和“nationality”。最后,我们添加了管道操作来从集合中选择“name”字段。我们调用 exec() 方法来获取结果集。
文件名: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 cricketerSchema = new mongoose.Schema({
_id: Number,
name: String,
nationality: String
});
const Cricketer = mongoose.model('Cricketers', cricketerSchema);
Cricketer
.aggregate([{ $project: { name: 1 } }])
.exec((error, result) => {
if (error) {
console.log(error);
} else {
console.log(result);
}
})
运行程序的步骤: 从项目的根目录运行以下命令来运行应用程序:
node app.js
输出:
[
{ _id: 3, name: 'Ben Stokes' },
{ _id: 2, name: 'David Warner' },
{ _id: 5, name: 'Aaron Finch' },
{ _id: 7, name: 'K L Rahul' },
{ _id: 6, name: 'Hardik Pandya' },
{ _id: 1, name: 'Virat Kohli' },
{ _id: 4, name: 'Rohit Sharma' }
]
示例2: 在这个示例中,我们使用mongoose建立了一个数据库连接,并定义了一个名为cricketerSchema的模型,该模型有三列或字段“_id”,“name”和“nationality”。最后,我们使用异步函数和await关键字处理通过exec()方法返回的promise。
文件名: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 cricketerSchema = new mongoose.Schema({
_id: Number,
name: String,
nationality: String
});
const Cricketer = mongoose.model('Cricketers', cricketerSchema);
const execExample = async () => {
const result = await Cricketer
.aggregate([{
$project: { nationality: 1, _id: 0, name: 1 }
}])
.exec();
console.log(result);
}
execExample();
运行程序的步骤: 要运行应用程序,请从项目的根目录执行以下命令:
node app.js
输出:
[
{ name: 'Ben Stokes', nationality: 'England ' },
{ name: 'David Warner', nationality: 'Australia' },
{ name: 'Aaron Finch', nationality: 'Australia ' },
{ name: 'K L Rahul', nationality: 'India ' },
{ name: 'Hardik Pandya', nationality: 'India ' },
{ name: 'Virat Kohli', nationality: 'India' },
{ name: 'Rohit Sharma', nationality: 'India ' }
]
参考: https://mongoosejs.com/docs/api/aggregate.html#aggregate_Aggregate-exec