Advertisement
Grossos

dasdsa

Dec 2nd, 2023
942
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
  1. const sql = require('mysql');
  2. const dotenv = require('dotenv').config();
  3. const db = sql.createConnection({
  4.     host: process.env.DATABASE_HOST,
  5.     user: process.env.DATABASE_USER,
  6.     password: process.env.DATABASE_PASSWORD,
  7.     database: process.env.DATABASE
  8.     // port: process.env.PORT
  9. });
  10. let instance = null;
  11.  
  12. class dbService {
  13.     static getDbServiceInstance() {
  14.         return instance ? instance : new dbService();
  15.     }
  16.  
  17.     async getAllData() {
  18.         try {
  19.             const response = await new Promise((resolve, reject) => {
  20.                 const query = "SELECT * FROM usersedit";
  21.                 //  const query = "SELECT * FROM users";
  22.  
  23.                 db.query(query, (err, results) => {
  24.                     if (err) reject(new Error(err.message));
  25.                     resolve(results)
  26.                 })
  27.             });
  28.             // console.log(response);
  29.             return response;
  30.  
  31.         } catch (error) {
  32.             console.log(error);
  33.         }
  34.     }
  35.  
  36.     async insertNewName(name) {
  37.         try {
  38.             const dateAdded = new Date();
  39.             const insertId = await new Promise((resolve, reject) => {
  40.                 const query = "INSERT INTO usersedit (name, dateAdded) VALUES (?,?)";
  41.  
  42.                 db.query(query, [name, dateAdded], (err, result) => {
  43.                     if (err) reject(new Error(err.message));
  44.                     resolve(result.insertId);
  45.                     //  return reject;
  46.                 })
  47.             });
  48.             // console.log(response);
  49.             // console.log(dateAdded);
  50.             console.log(insertId);
  51.             return {
  52.                 id: insertId,
  53.                 name: name,
  54.                 dateAdded: dateAdded
  55.             };
  56.             // return response;
  57.         } catch (error) {
  58.             console.log(error);
  59.         }
  60.  
  61.     }
  62.     async deleteRowById(id) {
  63.         try {
  64.             id = parseInt(id, 10);
  65.             console.log('deleteRowById Debug: id=', id, typeof id);
  66.             const response = await new Promise((resolve, reject) => {
  67.                 const query = "DELETE FROM usersedit WHERE id = ?"
  68.  
  69.                 db.query(query, [id], (err, result) => {
  70.                     if (err) reject(new Error(err.message));
  71.                     // resolve(result);
  72.                     resolve(result.affectedRows);
  73.                     return reject;
  74.                 })
  75.             });
  76.             // console.log(response);
  77.             return response === 1 ? true : false;
  78.         } catch (error) {
  79.             console.log(error);
  80.             return false;
  81.         }
  82.     }
  83.  
  84.     async updateNameById(id, name) {
  85.         try {
  86.             id = parseInt(id, 10);
  87.  
  88.             console.log('updateNameById Debug: id=', id, typeof id);
  89.             if (isNaN(id)) {
  90.                 console.log("Error: Invalid id");
  91.                 return false;
  92.             }
  93.  
  94.             const response = await new Promise((resolve, reject) => {
  95.                 const query = "UPDATE usersedit SET name = ? WHERE id = ?";
  96.  
  97.                 db.query(query, [name, id], (err, result) => {
  98.                     if (err) reject(new Error(err.message));
  99.                     resolve(result);
  100.                     //   return reject;
  101.                 })
  102.             });
  103.  
  104.             console.log(response);
  105.         } catch (error) {
  106.             console.log(error);
  107.             return false;
  108.         }
  109.     }
  110.  
  111.  
  112. }
  113. module.exports = { db, dbService }
  114.  
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement