How the engine optimizes pipelines in MongoDB - Try It Yourself

Understanding How the MongoDB Engine Optimizes Pipelines

📖 Scenario: You are working with a MongoDB database that stores information about a bookstore's sales. You want to analyze sales data efficiently by using aggregation pipelines. MongoDB's engine optimizes these pipelines to run faster and use fewer resources.

🎯 Goal: Build a simple aggregation pipeline step-by-step to understand how MongoDB optimizes the stages for better performance.

📋 What You'll Learn

Create a collection called sales with sample documents representing book sales.

Add a configuration variable to filter sales by a minimum quantity.

Build an aggregation pipeline that filters and groups sales data.

Complete the pipeline by sorting the results to show the best-selling books first.

💡 Why This Matters

🌍 Real World

Aggregation pipelines are used in real-world applications to analyze and summarize large datasets efficiently, such as sales reports, user activity, or inventory management.

💼 Career

Understanding how to build and optimize MongoDB aggregation pipelines is a valuable skill for database developers, data analysts, and backend engineers working with NoSQL databases.

1

DATA SETUP: Create the sales collection with sample documents

Insert these exact documents into a MongoDB collection called sales: { book: "MongoDB Basics", quantity: 5, price: 20 }, { book: "Advanced MongoDB", quantity: 3, price: 35 }, { book: "MongoDB Basics", quantity: 2, price: 20 }, { book: "Data Science with MongoDB", quantity: 4, price: 40 }.

MongoDB

// Insert the exact documents into the sales collection
// Your code here

Need a hint?

Use db.sales.insertMany([...]) with the exact documents listed.

2

CONFIGURATION: Define a minimum quantity filter variable

Create a variable called minQuantity and set it to 3 to filter sales with quantity greater or equal to this value.

MongoDB

db.sales.insertMany([
  { book: "MongoDB Basics", quantity: 5, price: 20 },
  { book: "Advanced MongoDB", quantity: 3, price: 35 },
  { book: "MongoDB Basics", quantity: 2, price: 20 },
  { book: "Data Science with MongoDB", quantity: 4, price: 40 }
])

// Create minQuantity variable and set it to 3
// Your code here

Need a hint?

Use const minQuantity = 3 to define the filter variable.

3

CORE LOGIC: Build an aggregation pipeline to filter and group sales

Create a variable called pipeline that contains an aggregation pipeline array with these stages: a $match stage to filter documents where quantity is greater or equal to minQuantity, and a $group stage to group by book and sum the quantity as totalQuantity.

MongoDB

db.sales.insertMany([
  { book: "MongoDB Basics", quantity: 5, price: 20 },
  { book: "Advanced MongoDB", quantity: 3, price: 35 },
  { book: "MongoDB Basics", quantity: 2, price: 20 },
  { book: "Data Science with MongoDB", quantity: 4, price: 40 }
])

const minQuantity = 3

// Create the pipeline array with $match and $group stages
// Your code here

Need a hint?

Use $match to filter and $group to sum quantities by book.

4

COMPLETION: Add a $sort stage to the pipeline to order by totalQuantity descending

Add a $sort stage to the pipeline array that sorts the results by totalQuantity in descending order.

MongoDB

db.sales.insertMany([
  { book: "MongoDB Basics", quantity: 5, price: 20 },
  { book: "Advanced MongoDB", quantity: 3, price: 35 },
  { book: "MongoDB Basics", quantity: 2, price: 20 },
  { book: "Data Science with MongoDB", quantity: 4, price: 40 }
])

const minQuantity = 3

const pipeline = [
  { $match: { quantity: { $gte: minQuantity } } },
  { $group: { _id: "$book", totalQuantity: { $sum: "$quantity" } } }
]

// Add a $sort stage to pipeline to sort by totalQuantity descending
// Your code here

Need a hint?

Add { $sort: { totalQuantity: -1 } } as the last stage in the pipeline array.