開箱即用的Node.js+Mysql模塊封裝實現(xiàn)詳解

更新時間：2023年01月13日 14:48:22 作者：是乃德也是Ned

這篇文章主要為大家介紹了開箱即用的Node.js+Mysql模塊封裝實現(xiàn)詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪

前言

最近在寫畢設(shè)，采用的是學(xué)弟+自己的技術(shù)棧，運用Vue3+ElementPlus搞前端，Node.js express做后端，畢竟，java那東西確實不在我技術(shù)棧里。

于是乎，我抱著能CV就不要自己敲的心態(tài)，前去了某C站，C回了一個封裝好了看上去存在可用性的基礎(chǔ)sql模塊，結(jié)果，踩了大坑。

痛定思痛，我采用了學(xué)弟+騰訊會議的debug方式，于事發(fā)當(dāng)天下午，花費了一個小時，成功搭建出了一個簡單易用，小學(xué)難度的一個操作數(shù)據(jù)庫的小模塊。

領(lǐng)略過下雨的痛，所以勇敢站出來為別人打傘，如果你只是想單純的用他做一些簡單的東西，那么大膽用，CV用！

正文

項目目錄

只是單獨把數(shù)據(jù)庫模塊拎出來了

├─index.js
├─db
| ├─db.js //封裝的操作函數(shù)
| ├─dbconfig.js //數(shù)據(jù)庫配置
| └sql.js  //sql語句

sql.js

主要是存放一些操作表的sql語句，這里只是放了一個表，多個表也可以~

//單純的栗子
let user = {
  insert: "INSERT INTO user(id, name, age) VALUES(?,?,?)",
  update: "UPDATE user SET name=?, age=? WHERE id=?",
  delete: "DELETE FROM user WHERE id=?",
  queryById: "SELECT * FROM user WHERE id=?",
  queryAll: "SELECT * FROM user",
};
module.exports = {
  user,
};

dbconfig.js

數(shù)據(jù)庫的配置，服務(wù)器上的就寫服務(wù)器的，本地的就寫本地的，都可以都可以

let mysqlConfig = {
    host: "1.2.3.4",
    user: "******",
    password: "******",
    port: "******",
    database: "******",
  };
module.exports = mysqlConfig

db.js

先引入

const mysql = require("mysql");
const $dbConfig = require("./dbconfig.js"); //注意改成自己項目中的路徑
const sql = require("./sql.js"); 
const pool = mysql.createPool($dbConfig); // 使用連接池

增

let dbAdd = (table, req, res, next) => {
  return new Promise((resolve,reject)=>{
    pool.getConnection((err, connection) => {
      let paramValue = paramList(req);
      connection.query(sql[table].insert, [...paramValue], (err, result) => {
        if(err){
          reject(err)
        }
        resolve(result)
        connection.release();
      });
    });
  })
};

刪

let dbDelete = (table, req, res, next) => {
  let paramValue = paramList(req);
  return new Promise((resolve,reject)=>{
    pool.getConnection((err, connection) => {
      connection.query(sql[table].delete, [...paramValue], (err, result) => {
        if(err){
          reject(err)
        }
        resolve(result)
        connection.release();
      });
    });
  })
};

改

let dbUpdate = (table, req, res, next) => {
  let paramValue = paramList(req);
  return new Promise((resolve,reject)=>{
    pool.getConnection((err, connection) => {
      connection.query(sql[table].update, [...paramValue], (err, result) => {
        if(err){
          reject(err)
        }
        resolve(result)
        connection.release();
      });
    });
  })
};

查一個

let dbQueryById = (table, req, res, next) => {
  let paramValue = paramList(req);
  return new Promise((resolve,reject)=>{
    pool.getConnection((err, connection) => {
      connection.query(sql[table].queryById, [...paramValue], (err, result) => {
        if(err){
          reject(err)
        }
        resolve(result)
        connection.release();
      });
    });
  })
};

查全部

let dbQueryAll = (table, req, res, next) => {
  return new Promise((resolve,reject)=>{
    pool.getConnection((err, connection) => {
      connection.query(sql[table].queryAll, (err, result) => {
        if(err){
          reject(err)
        }
        resolve(result)
        connection.release();
      });
    });
  })
};

paramList

connection.query的第二個參數(shù)要求傳數(shù)組，為了怕bug，將傳入的對象給他變成一個數(shù)組返回回去示例：mysqljs-https://github.com/mysqljs/mysql#custom-format

let paramList = (obj) => {
  let paramArr = [];
  for (let key in obj) {
    if (obj[key]) {
      paramArr.push(obj[key]);
    }
  }
  return paramArr;
};

如何使用

下面移步到index.js，引入我就不在寫一次了，大家自己引入就好。

app.post("/login",async (req,res) =>{
  const {username,password} = req.body // 接收數(shù)據(jù)
    try {
       //看這里， 我們使用username的方式去數(shù)據(jù)庫進行用戶查找
      const {data} = await db.dbQueryById("user",{"username":username},res)
      // 接下來自己想象吧
    } catch (err) {
      res.json({
        code: "500",
        msg: "用戶不存在"
      });
    }
})