Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- const sql = require('mysql');
- const dotenv = require('dotenv').config();
- const db = sql.createConnection({
- host: process.env.DATABASE_HOST,
- user: process.env.DATABASE_USER,
- password: process.env.DATABASE_PASSWORD,
- database: process.env.DATABASE
- // port: process.env.PORT
- });
- let instance = null;
- class dbService {
- static getDbServiceInstance() {
- return instance ? instance : new dbService();
- }
- async getAllData() {
- try {
- const response = await new Promise((resolve, reject) => {
- const query = "SELECT * FROM usersedit";
- // const query = "SELECT * FROM users";
- db.query(query, (err, results) => {
- if (err) reject(new Error(err.message));
- resolve(results)
- })
- });
- // console.log(response);
- return response;
- } catch (error) {
- console.log(error);
- }
- }
- async insertNewName(name) {
- try {
- const dateAdded = new Date();
- const insertId = await new Promise((resolve, reject) => {
- const query = "INSERT INTO usersedit (name, dateAdded) VALUES (?,?)";
- db.query(query, [name, dateAdded], (err, result) => {
- if (err) reject(new Error(err.message));
- resolve(result.insertId);
- // return reject;
- })
- });
- // console.log(response);
- // console.log(dateAdded);
- console.log(insertId);
- return {
- id: insertId,
- name: name,
- dateAdded: dateAdded
- };
- // return response;
- } catch (error) {
- console.log(error);
- }
- }
- async deleteRowById(id) {
- try {
- id = parseInt(id, 10);
- console.log('deleteRowById Debug: id=', id, typeof id);
- const response = await new Promise((resolve, reject) => {
- const query = "DELETE FROM usersedit WHERE id = ?"
- db.query(query, [id], (err, result) => {
- if (err) reject(new Error(err.message));
- // resolve(result);
- resolve(result.affectedRows);
- return reject;
- })
- });
- // console.log(response);
- return response === 1 ? true : false;
- } catch (error) {
- console.log(error);
- return false;
- }
- }
- async updateNameById(id, name) {
- try {
- id = parseInt(id, 10);
- console.log('updateNameById Debug: id=', id, typeof id);
- if (isNaN(id)) {
- console.log("Error: Invalid id");
- return false;
- }
- const response = await new Promise((resolve, reject) => {
- const query = "UPDATE usersedit SET name = ? WHERE id = ?";
- db.query(query, [name, id], (err, result) => {
- if (err) reject(new Error(err.message));
- resolve(result);
- // return reject;
- })
- });
- console.log(response);
- } catch (error) {
- console.log(error);
- return false;
- }
- }
- }
- module.exports = { db, dbService }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement