开箱即用的Node.js+Mysql模块封装实现详解
目录
- 前言
- 正文
- 项目目录
- sql.js
- dbconfig.js
- db.js
- 增
- 删
- 改
- 查一个
- 查全部
- paramList
- 如何使用
- 搞定
前言
最近在写毕设,采用的是学弟+自己的技术栈,运用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,将传入的对象给他变成一个数组返回回去 示例: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 // 接收数据 try { //看这里, 我们使用username的方式去数据库进行用户查找 const {data} = await db.dbQueryById("user",{"username":username},res) // 接下来自己想象吧 } catch (err) { res.json({ code: "500", msg: "用户不存在" }); } })
搞定
再次吐槽一下,去百度各种搜,查阅时候的痛苦,以上就是开箱即用的Node.js+Mysql模块封装实现详解的详细内容,更多关于Node.js+Mysql模块封装的资料请关注我们其它相关文章!
赞 (0)