Connecting MongoDB with Node.js

# CHAPTER 24

Connecting MongoDB with Node.js #

1. Introduction #

2. Learning Objectives #

• Install the official mongodb NPM package.

• Establish a connection using the MongoClient class.

• Understand the necessity of async / await in database operations.

• Execute basic CRUD queries in Node.js.

• Cleanly integrate the database connection with an Express.js server.

3. Installing the Node.js Driver #

npm init -y
npm install mongodb dotenv

*(We also install dotenv to securely manage our Connection URI).*

Create a .env file in your root directory:

MONGO_URI=mongodb+srv://webapp_user:WebAppPassword99!@cluster0.xyz.mongodb.net/

4. Establishing the Connection (MongoClient) #

const { MongoClient } = require('mongodb');
require('dotenv').config();

const uri = process.env.MONGO_URI;
const client = new MongoClient(uri);

async function connectDB() {
    try {
        // Wait for the network connection to establish
        await client.connect();
        console.log("Successfully connected to MongoDB!");
        
        // Return a specific database reference
        return client.db("ecommerce_db");
    } catch (error) {
        console.error("Connection Failed:", error);
        process.exit(1); // Kill the server if the DB is unreachable
    }
}

module.exports = connectDB;

5. Executing CRUD in Node.js #

const connectDB = require('./database');

async function run() {
    const db = await connectDB();
    const usersCollection = db.collection("users");

    // CREATE
    const insertResult = await usersCollection.insertOne({ 
        name: "Alice", 
        role: "Admin" 
    });
    console.log("Inserted ID:", insertResult.insertedId);

    // READ
    const user = await usersCollection.findOne({ name: "Alice" });
    console.log("Found User:", user);

    // UPDATE
    await usersCollection.updateOne(
        { name: "Alice" }, 
        { $set: { status: "Active" } }
    );

    // DELETE
    await usersCollection.deleteOne({ name: "Alice" });
}

run();

6. Integrating with Express.js #

const express = require('express');
const connectDB = require('./database');
const app = express();
app.use(express.json());

let db; // Global variable to hold the DB reference

// Define a GET route
app.get('/users', async (req, res) => {
    try {
        // Fetch all users and convert the Cursor to an Array!
        const users = await db.collection("users").find().toArray();
        res.json(users);
    } catch (error) {
        res.status(500).json({ error: "Database query failed" });
    }
});

// Boot the Application
async function startServer() {
    db = await connectDB(); // Connect to Mongo First!
    
    app.listen(3000, () => {
        console.log("Express API is running on port 3000");
    });
}

startServer();

7. The toArray() Requirement #

8. Mini Project: Handling ObjectIds from URL Params #

const { ObjectId } = require('mongodb');

app.delete('/users/:id', async (req, res) => {
    try {
        // Convert the URL string to a BSON ObjectId!
        const targetId = new ObjectId(req.params.id);
        
        const result = await db.collection("users").deleteOne({ _id: targetId });
        
        if (result.deletedCount === 1) {
            res.json({ message: "User deleted" });
        } else {
            res.status(404).json({ error: "User not found" });
        }
    } catch (err) {
        res.status(400).json({ error: "Invalid ID format" });
    }
});

9. Common Mistakes #

• Forgetting await: If you write const user = collection.findOne(), Node.js will instantly assign a pending "Promise" object to the variable, not the actual user data. You MUST write await collection.findOne().

• Opening Connections inside Routes: Never write const client = new MongoClient() *inside* your app.get() route. If 1,000 users visit the page, you will spawn 1,000 unique network connections, instantly crashing MongoDB. Establish the connection once at startup, and reuse the db variable!

10. Best Practices #

• Mongoose ORM: While the official Native Driver is fantastic, 90% of enterprise Node.js applications use an abstraction library called Mongoose. Mongoose allows you to define strict Schemas and Models in JavaScript, handling all the ObjectId conversions automatically!

11. Exercises #

1. 1. What Node.js keyword must be used to pause execution and wait for a MongoDB query to finish resolving over the network?

1. 2. What cursor method must be chained to a find() query to extract the results into a standard JavaScript array?

12. MongoDB Challenges #

app.post('/products', async (req, res) => {
    const result = await db.collection("products").insertOne(req.body);
    res.status(201).json({ id: result.insertedId });
});

13. MCQ Quiz with Answers #

14. Interview Questions #

• Q: Explain the necessity of asynchronous programming (async/await) when executing MongoDB queries in a Node.js environment. What happens if you forget the await keyword?

• Q: If an Express route receives an ID via req.params.id, explain why executing collection.findOne({ _id: req.params.id }) will fail to find the document, and provide the programmatic solution.

15. FAQs #

16. Summary #

17. Next Chapter Recommendation #