applied sequelize and mongoDB aggregation

add.js

@@ -0,0 +1,4 @@
+function sum(a, b) {
+    return a + b;
+  }
+module.exports = sum;

add.test.js

@@ -0,0 +1,5 @@
+const sum = require('./add');
+
+test('adds 1 + 2 to equal 3', () => {
+  expect(sum(1, 2)).toBe(3);
+});

config/config.js

@@ -11,4 +11,8 @@ exports.EMAIL_FROM = process.env.emailFrom
 exports.EMAIL_TO = process.env.emailTo
 exports.URL = process.env.url
 exports.URL1 = process.env.url1
-exports.snapURL = process.env.snapurl
+exports.snapURL = process.env.snapurl
+exports.EMAIL_PASS = process.env.pass
+exports.DB = process.env.database
+exports.USERNAME = process.env.username
+exports.PASS = process.env.password

controllers/userController.js

@@ -152,4 +152,12 @@ exports.snapdealTshirt = async (req,res)=>{
   }catch(error){
     res.status(401).send({success: "false", message: "userdata not found" ,error});
   }
-};
+};
+exports.aggregate = async (req,res) => {
+  try {
+    const data = await userServices.findByAggregate()
+    res.status(201).send({success: "true", message: "userdata found", Data : data });
+  } catch (error) {
+    res.status(401).send({success: "false",error});
+  }
+}

dbconnection.js

@@ -1,12 +1,19 @@
-const mongoose = require("mongoose");
-const { db_url } = require("./config/config");
+const { Sequelize } = require("sequelize");
+const config = require("./config/config");
 
-const db_connect = async ()=>{
-    try {
-        await mongoose.connect(db_url)
-        console.log("Database connected");
-    } catch (error) {
-        console.log("DB connection failed");
-    }
+const sequelize = new Sequelize(config.DB, 'root',config.PASS, {
+  host: 'localhost',
+  dialect: 'mysql',
+});
+
+const connectdb= async () => {
+try {
+  await sequelize.authenticate();
+  console.log("Connection has been established successfully.");
+} catch (error) {
+  console.error("Unable to connect to the database:", error);
+}
 }
-db_connect();
+connectdb();
+
+module.exports = sequelize

index.js

@@ -2,12 +2,14 @@ const express = require("express");
 const app = express();
 const config = require("./config/config")
 const userRoute = require("./routes/register.js");
+const User = require("./model/register");
 
 require("./dbconnection");
 app.use(express.json());
 
 app.use("/user", userRoute)
 
+User.sync()
 
 app.listen(config.portNo,()=>{
     console.log("server is running");

middleware/mid_register.js

@@ -3,9 +3,10 @@ const users = require("../model/userModel")
 const jwt = require("jsonwebtoken");
 const config = require("../config/config");
 const multer = require("multer")
+const User = require("../model/register")
 
 exports.REG_MIDDLE = async (req, res, next) => {
-  const userData = await users.findOne({ email: req.body.email });
+  const userData = await User.findOne({where:{ email: req.body.email }});
 
   if (userData) {
     return res.status(409).send({ success: false, msg: "Email already exist" });

model/DummyData.js

@@ -0,0 +1,30 @@
+const mongoose=require("mongoose");
+const user = mongoose.Schema({
+    name:{
+        name: String,
+    },
+    country:{
+        type:String
+    },
+    region:{
+        type:String
+    },
+    email:{
+        type:String
+    },
+    phone:{
+        type:String
+    },
+    currency:{
+        type:Number
+    },
+    numberrange:{
+        type:Number
+    },
+    postalZip:{
+        type:Number
+    }
+}
+);
+
+module.exports = mongoose.model("dummydatas",user)

model/register.js

@@ -0,0 +1,38 @@
+const { DataTypes } = require("sequelize");
+const sequelize = require("../dbconnection");
+const User = sequelize.define("User",
+  {
+    username: {
+      type: DataTypes.STRING,
+      allowNull: false,
+    },
+    firstname: {
+      type: DataTypes.STRING,
+      allowNull: false,
+    },
+    lastname: {
+      type: DataTypes.STRING,
+    },
+    email: {
+      type: DataTypes.STRING,
+    },
+    password: {
+      type: DataTypes.STRING,
+    },
+    mobile: {
+      type: DataTypes.STRING,
+    },
+    address: {
+      type: DataTypes.STRING,
+    }
+  },
+  {
+    tableName: "users",
+    timestamps: true,
+  }
+);
+
+// `sequelize.define` also returns the model
+console.log(User === sequelize.models.User); // true
+
+module.exports = User;

model/userToken.js

@@ -1,15 +1,24 @@
-const mongoose = require("mongoose");
-const user = mongoose.Schema({
-    userId:{
-        type:Object
+const { DataTypes } = require("sequelize");
+const sequelize = require("../dbconnection");
+
+const userToken = sequelize.define("userToken",
+  {
+    userId: {
+      type: DataTypes.STRING,
+      allowNull: false,
     },
-    token:{
-        type:String,
-        required:true
+    token: {
+      type: DataTypes.STRING,
+      allowNull: false,
     },
-    expiry:{
-        type:String
+    expiry: {
+      type: DataTypes.STRING,
     }
-});
+  },
+  {
+    tableName: "userToken",
+    timestamps: true,
+  }
+);
 
-module.exports = mongoose.model("usertoken",user)
+module.exports = userToken;