Mongoose Aggregate.prototype.pipeline()函数

The Aggregate API.prototype.pipeline() 方法是Mongoose API用于执行聚合任务的方法。它允许我们以数组的形式获取当前的管道操作对象。它对于获取所有当前的管道操作或我们已经应用于执行聚合任务的管道方法非常有用。

语法：

aggregate().project( specifications ).pipeline();

参数： 此方法不接受任何参数。

返回值： 此方法返回当前流水线对象的数组。

设置 Node.js Mongoose 模块：

步骤1： 使用以下命令创建一个 Node.js 应用：

npm init

步骤2： 创建NodeJS应用程序后，使用以下命令安装所需模块：

npm install mongoose

项目结构：

项目的结构将如下所示：

示例1： 在这个示例中，我们使用mongoose建立了一个数据库连接，并定义了userSchema模型，它有三个列或字段：“_id”，“name”和“bornYear”。最后，我们调用 pipleline() 方法来获取当前管道操作的状态。

文件名：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, 
    bornYear: Number 
}); 
  
const User = mongoose.model('User', userSchema); 
  
const currentPipeline = User 
    .aggregate([{ $project: { _id: 0, bornYear: 1 } }]) 
    .pipeline() 
console.log(currentPipeline)

运行程序的步骤： 从项目的根目录中执行以下命令来运行应用程序：

node app.js

输出：

[ { '$project': { _id: 0, bornYear: 1 } } ]

示例2： 在这个示例中，我们使用mongoose建立了数据库连接，并对userSchema定义了模型，其中有三个列或字段“_id”，“name”和“bornYear”。在这个示例中，我们有两个管道操作 project 和 sortByCount。 通过使用 pipeline() 方法，我们得到了这两个管道操作的结果。

// 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, 
    bornYear: Number 
}); 
  
const User = mongoose.model('User', userSchema); 
  
const currentPipeline = User 
    .aggregate() 
    .project({ name: 1 }) 
    .sortByCount({ 'bornYear': 1 }) 
    .pipeline() 
console.log(currentPipeline)

运行程序的步骤： 从项目的根目录执行以下命令以运行应用程序：

node app.js

输出：

[ { 'project': { name: 1 } }, { 'sortByCount': { bornYear: 1 } } ]

参考：https://mongoosejs.com/docs/api/aggregate.html#aggregate_Aggregate-pipeline