My Node js express server rest api sequelize orm mysql project

Author: ziaKhan1995

app.js

@@ -0,0 +1,42 @@
+const express = require("express");
+const cors = require("cors");
+
+const app = express();
+
+const corsOptions = {
+    origin: "http://localhost:8090"
+}
+app.use(cors(corsOptions));
+
+//parse request of content-type - - application/json
+app.use(express.json());
+
+//parse request of content-type - - application/ww-form-url-encoded
+app.use(express.urlencoded({ extended: true }));
+
+//default app port calling response
+app.get("/", (req, res) => {
+    res.json({ message: "Welcome To our Node JS Express Js using Rest API with Sequelze ORM and MySQL DB Connection" });
+});
+
+
+const PORT = process.env.PORT || 8090;
+app.listen(PORT, () => {
+    console.log("\nYou NodeJS Express Server App is running on the PORT " + PORT + "\n");
+});
+
+// set port, listen for requests
+require("./app/routes/routes")(app);
+//build/establish db conection by calling index.js file
+var db = require("./app/models");
+
+//let the nodejs create tables according to the models. 
+//comment this if you do not want to make tables empty on reRunning the APP in CMD.
+//This code on runnig the app will create tabees from models and delete all data if exist.
+//if you comment this line, you have to create tables in database.
+// db.sequelize.sync({ force: true }).then(() => {
+//     console.log("Db synced");
+// }).catch(() => {
+//     console.log("Fail to synce DB");
+// });
+

app/config/db.config.js

@@ -0,0 +1,13 @@
+module.exports = {
+    HOST: "localhost",
+    USER: "your_DB_user_name",
+    DB: "testdb",
+    PASSWORD: "Your _DB _PASSWORD",
+    dialect: "mysql",
+    pool: {
+        min: 0,
+        max: 5,
+        acquire: 30000,
+        idle: 10000
+    }
+};

app/controllers/customer.controller.js

@@ -0,0 +1,46 @@
+const db = require("../models");
+const Editors = db.editors;
+const Operator = db.Sequelize.Op;
+
+//create and save new editor
+
+exports.create = (req, res) => {
+    if (!req.body.fname || !req.body.lname) {
+        res.status(400).send({
+            message: "Name Should not be null"
+        });
+        return;
+    }
+    const Editor = {
+        fname: req.body.fname,
+        lname: req.body.lname,
+        contactNo: req.body.contactNo,
+        address: req.body.address,
+        status: req.body.status
+    };
+    Editors.create(Editor).then((data) => {
+        console.log("Editors data");
+        return res.send(data);
+    })
+        .catch((err) => {
+            console.log("Editors err");
+            return res.status(500).send({
+                message: err.message || "Am error occured while creating Editor"
+            });
+        });
+
+};
+
+const findAll = (req, res) => {
+    var fname = req.query.fname;
+    var whereVlause = fname ? { [Operator.like]: `${fname}` } : null;
+    Editors.findAll({ where: whereVlause }).then((data) => {
+        return res.send(data)
+    }).catch((error) => {
+        return res.status(500).send({
+            message: error.message || "An error occurred while retreiving editrs. Please try later"
+        });
+    });
+
+};
+module.exports.findAll=findAll;

app/controllers/product.controller.js

@@ -0,0 +1,46 @@
+const db = require("../models");
+const Products = db.products;
+
+const Operator = db.Sequelize.Op;
+
+const create = (req, res) => {
+
+    if (!req.body.name) {
+        let errObj = {
+            message: "Product name Shoul not be empty"
+        };
+        res.status(400).send(errObj);
+        return;
+    }
+    let product = {
+        name: req.body.name,
+        company: req.body.company,
+        category: req.body.category
+    };
+    Products.create(product).then(data => {
+        return res.send(data);
+    }).catch(err => {
+        return res.status(500).send({
+            message: err.message || "unable to get all custoomers"
+        });
+    });
+
+};
+module.exports.create = create;
+
+const findAll = (req, res) => {
+    var name = "";
+    if (req.query.name) {
+        name = req.query.name;
+    }
+    var whereClause = name ? { [Operator.like]: `${name}` } : null;
+    var whereCondition = { where: whereClause };
+    Products.findAll(whereCondition).then(data => {
+        return res.send(data)
+    }).catch(error => {
+        return res.status(500).send({
+            message: error.message || "An error occureed while getting the products"
+        });
+    });
+};
+module.exports.findAll = findAll;

app/models/customer.model.js

@@ -0,0 +1,21 @@
+module.exports=(sequelize,Sequelize)=>{
+    const Customer=sequelize.define("Customer",{
+        fname:{
+            type:Sequelize.STRING
+        },
+        lname:{
+            type:Sequelize.STRING
+        },
+        address:{
+            type:Sequelize.STRING
+        },
+        contactNo:{
+            type:Sequelize.STRING
+        },
+        status:{
+            type:Sequelize.STRING
+        }
+    });
+
+    return Customer;
+};

app/models/index.js

@@ -0,0 +1,29 @@
+const dbConfig = require("../config/db.config");
+const Sequelize = require("sequelize");
+
+const sequelize = new Sequelize(
+    dbConfig.DB, dbConfig.USER, dbConfig.PASSWORD, {
+    HOST: dbConfig.HOST,
+    dialect: dbConfig.dialect,
+    operatorAlliases: true,
+
+    pool: {
+        min:dbConfig.min,
+        max:dbConfig.max,
+        acquire:dbConfig.acquirem,
+        idle:dbConfig.idle
+    }
+}
+);
+
+const db={};
+
+db.sequelize=sequelize;
+db.Sequelize=Sequelize;
+
+db.editors=require("../models/customer.model.js")(sequelize,Sequelize);
+db.products=require("../models/product.model.js")(sequelize,Sequelize);
+
+module.exports=db;
+
+

app/models/product.model.js

@@ -0,0 +1,14 @@
+module.exports = (sequelize, Sequelize) => {
+    const Product = sequelize.define("Product", {
+        name: {
+            type: Sequelize.STRING
+        },
+        category: {
+            type: Sequelize.STRING
+        },
+        company: {
+            type: Sequelize.STRING
+        }
+    });
+    return Product;
+};

app/routes/routes.js

@@ -0,0 +1,16 @@
+module.exports=app =>{
+const CustomerControll=require("../controllers/customer.controller.js");
+const ProductControll=require("../controllers/product.controller.js");
+const router=require("express").Router();
+
+//customers
+router.post("/save/customer",CustomerControll.create);
+router.get("/get/customer",CustomerControll.findAll);
+
+//Products
+router.post("/save/product",ProductControll.create);
+router.get("/get/products",ProductControll.findAll);
+
+
+app.use("/v1",router)
+};

appjs(serverjs)-coding-steps.txt

@@ -0,0 +1,20 @@
+=> Import express server
+
+=> import cors
+
+=> create app using imported Import express constrcutor
+
+=> declare cors origin use app cors origin
+
+=> use app res json to parse requests of content-type - application/json
+
+=> use app url-encoded to parse requests of content-type - application/x-www-form-urlencoded
+
+=> build/establish db conection by calling index.js file
+
+=> define app default path i.e app.get
+
+=> Import the routes file path
+
+=> call listening to port function
+

controller-coding-steps.txt

@@ -0,0 +1,9 @@
+=> create and initialize DB
+
+
+=> create and initialize Model 
+
+=> import other necessary stuffs like Operators which are returned by db.Sequelize.op;
+
+=> create and initialize fuctions 
+

db-config-coding-steps.txt

@@ -0,0 +1,16 @@
+export module with information of database like this
+
+module.export= {
+
+db_name,
+psd,
+user,
+localhost,
+dialect,
+pool: {
+    max:
+    min:
+    acquire: 
+    idle: 
+  }
+};

indexjs-coding-steps.txt

@@ -0,0 +1,16 @@
+=> import db config
+
+=> import Sequelize
+
+=> create sequelize connection using Sequelize constructor and define body
+
+=> after body, initailze empty db 
+
+=> Assign db.Sequelize value
+
+=> Assign db.seuqelize value
+
+=> Assign db.models(models is collection of tables) value
+
+=> export db varaible
+

model-coding-steps.txt

@@ -0,0 +1,7 @@
+=> module export type function with parametrs sequelize and Sequelize
+
+=> Inside  module export type function, declare Model and directlt initialze body by passing the table name.
+
+=> inside body write tables columns.
+
+=> After the body of model return the model.