Nodejs MongoDB Pagination Example

Author: loizenai

Nodejs-MongoDB-Pagination-Example/app/config/mongodb.config.js

@@ -0,0 +1,3 @@
+module.exports = {
+  url: 'mongodb+srv://loizenai:loizenai@cluster0.esvi3.mongodb.net/loizenaidb'
+}

Nodejs-MongoDB-Pagination-Example/app/controllers/customer.controller.js

@@ -0,0 +1,151 @@
+const Customer = require('../models/customer.model.js');
+ 
+// POST a Customer
+exports.create = (req, res) => {
+
+    const customer = new Customer({
+                          firstname: req.body.firstname,
+                          lastname: req.body.lastname,
+                          age: req.body.age,
+                          address: req.body.address,
+                        });
+ 
+    // Save a Customer in the MongoDB
+    customer.save().then(data => {
+                    // send uploading message to client
+                    res.status(200).json({
+                      message: "Upload Successfully a Customer to MongoDB with id = " + data.id,
+                      customer: data,
+                    });
+                }).catch(err => {
+                    res.status(500).json({
+                      message: "Fail!",
+                      error: err.message
+                    });
+                });
+};
+
+exports.filteringByAge = (req, res) => {
+  const age = parseInt(req.query.age);  
+
+  Customer.find({age:age}).select("-__v")
+    .then(results => {
+      res.status(200).json({
+        "message": "Get all Customers with age = " + age,
+        "size": results.length,
+        "customers": results
+      });  
+    }).catch(err => {
+      console.log(err);
+      res.status(500).json({
+        message: "Error!",
+        error: err
+      });
+    });
+}
+
+exports.pagination = async (req, res) => {
+
+  try {
+
+    const page = parseInt(req.query.page);
+    const limit = parseInt(req.query.limit); // Make sure to parse the limit to number
+    
+    const offset = page ? page * limit : 0;
+  
+    // We are using the '3 layer' architecture explored on the 'bulletproof node.js architecture'
+    // Basically, it's just a class where we have our business logic
+    
+    let results = await Customer.find({})  // You may want to add a query
+                      .skip(offset) // Always apply 'skip' before 'limit'
+                      .limit(limit)
+                      .select("-__v"); // This is your 'page size'
+        
+    let numOfCustomer = await Customer.countDocuments({});
+  
+    res.status(200).json({
+      "message": "Paginating is completed! Query parameters: page = " + page + ", limit = " + limit,
+      "totalPages": Math.ceil(numOfCustomer / limit),
+      "totalItems": numOfCustomer,
+      "limit": limit,
+      "currentPageSize": results.length,
+      "customers": results
+    });      
+  } catch (error) {
+    res.status(500).send({
+      message: "Error -> Can NOT complete a paging request!",
+      error: error.message,
+    });    
+  }
+
+}
+
+exports.pagination_v2 = async (req, res) => {
+
+  try {
+
+    const page = parseInt(req.query.page);
+    const limit = parseInt(req.query.limit); // Make sure to parse the limit to number
+    
+    const offset = page ? page * limit : 0;
+  
+    // We are using the '3 layer' architecture explored on the 'bulletproof node.js architecture'
+    // Basically, it's just a class where we have our business logic
+    
+    let results = await Customer.aggregate([
+                          { $match: {} },    // This is your query
+                          { $skip: offset },   // Always apply 'skip' before 'limit'
+                          { $limit: limit }, // This is your 'page size'
+                      ]).select("-__v")  
+        
+    let numOfCustomer = await Customer.countDocuments({});
+  
+    res.status(200).json({
+      "message": "Paginating is completed! Query parameters: page = " + page + ", limit = " + limit,
+      "totalPages": Math.ceil(numOfCustomer / limit),
+      "totalItems": numOfCustomer,
+      "limit": limit,
+      "currentPageSize": results.length,
+      "customers": results
+    });      
+  } catch (error) {
+    res.status(500).send({
+      message: "Error -> Can NOT complete a paging request!",
+      error: error.message,
+    });    
+  }
+
+}
+
+exports.paginationfilterandsort = async (req, res) => {
+  try {
+    const page = parseInt(req.query.page);
+    const limit = parseInt(req.query.limit); // Make sure to parse the limit to number
+    const age = parseInt(req.query.age);
+    
+    const offset = page ? page * limit : 0;
+    
+    let results = await Customer.find({age: age})  // You may want to add a query
+                      .skip(offset) // Always apply 'skip' before 'limit'
+                      .limit(limit)
+                      .sort({"firstname": 1, "lastname": -1})
+                      .select("-__v"); // This is your 'page size'
+        
+    let numOfCustomer = await Customer.countDocuments({age: age});
+
+    res.status(200).json({
+      "message": "Paginating is completed! Query parameters: page = " + page + ", limit = " + limit,
+      "totalPages": Math.ceil(numOfCustomer / limit),
+      "totalItems": numOfCustomer,
+      "limit": limit,
+      "age-filtering": age,
+      "currentPageSize": results.length,
+      "customers": results
+    });    
+  } catch (error) {
+    res.status(500).send({
+      message: "Error -> Can NOT complete a paging + filtering + sorting request!",
+      error: error.message,
+    });
+  }
+};

Nodejs-MongoDB-Pagination-Example/app/models/customer.model.js

@@ -0,0 +1,19 @@
+const mongoose = require('mongoose');
+ 
+const CustomerSchema = mongoose.Schema({
+    firstname: String,
+    lastname: String,
+    address: String,
+    age: { 
+      type: Number, 
+      min: 18, 
+      max: 65, 
+      required: true 
+    },
+    copyrightby: {
+      type: String,
+      default: 'https://loizenai.com'
+    }
+});
+
+module.exports = mongoose.model('Customer', CustomerSchema);

Nodejs-MongoDB-Pagination-Example/app/routes/customer.router.js

@@ -0,0 +1,14 @@
+module.exports = function(app) {
+ 
+  var customers = require('../controllers/customer.controller.js');
+
+  // Create a new Customer
+  app.post('/api/customer/create', customers.create);
+
+  app.get('/api/customer/filteringbyage', customers.filteringByAge);
+
+  app.get('/api/customer/pagination', customers.pagination);
+  app.get('/api/customer/pagination_v2', customers.pagination);
+
+  app.get('/api/customer/pagefiltersort', customers.paginationfilterandsort);
+}