前言
最近在写毕设，采用的是学弟+自己的技术栈，运用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模块封装的资料请关注编程网其它相关文章！
