开箱即用的Node.js+Mysql模块封装实现详解

目录

前言

最近在写毕设,采用的是学弟+自己的技术栈,运用Vue3+ElementPlus搞前端,Node.js express做后端,毕竟,java那东西确实不在我技术栈里。

于是乎,我抱着能CV就不要自己敲的心态,前去了某C站,C回了一个封装好了看上去存在可用性的基础sql模块,结果,踩了大坑。

痛定思痛,我采用了学弟+腾讯会议的debug方式,于事发当天下午,花费了一个小时,成功搭建出了一个简单易用,小学难度的一个操作数据库的小模块。

领略过下雨的痛,所以勇敢站出来为别人打伞,如果你只是想单纯的用他做一些简单的东西,那么大胆用,CV用!

正文

项目目录

只是单独把数据库模块拎出来了

├─index.js
├─db
| ├─db.js //封装的操作函数
| ├─dbconfig.js //数据库配置
| └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

数据库的配置,服务器上的就写服务器的,本地的就写本地的,都可以都可以

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的第二个参数要求传数组,为了怕bug,将传入的对象给他变成一个数组返回回去 示例:

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 // 接收数据
    try {
       //看这里, 我们使用username的方式去数据库进行用户查找
      const {data} = await db.dbQueryById("user",{"username":username},res)
      // 接下来自己想象吧
    } catch (err) {
      res.json({
        code: "500",
        msg: "用户不存在"
      });
    }
})

搞定

再次吐槽一下,去百度各种搜,查阅时候的痛苦,以上就是开箱即用的Node.js+Mysql模块封装实现详解的详细内容,更多关于Node.js+Mysql模块封装的资料请关注其它相关文章!

原文地址:https://juejin.cn/post/7188008161218363429
15人参与, 0条评论 登录后显示评论回复

你需要登录后才能评论 登录/ 注册