node如何封装mysql处理语句

npmimysql-S
npmiexpress-S

constmysql=require('mysql')functioncreateConnection(){
constconnection=mysql.createConnection({
host:'',//地址
user:'',//用户名
password:'',//密码
port:'',//端口
database:''//数据库名
});
returnconnection;}module.exports.createConnection=createConnection;

constmysql=require('../mysql/mysql')letconnection=null;connection=mysql.createConnection();/**
*错误消息
*/letbad_msg={
code:500,
msg:'内部错误！'}/**
*成功消息
*/letsuccess_msg={
code:200,
msg:'操作成功'}constconnections={
/**
*查询方法
*@param{*}table表名
*@param{*}condition条件
*@param{*}params参数
*@param{*}search查询条件
*@returns
*/
find(table,condition,params,search='*'){
returnnewPromise((resolve,reject)=>{
letsql=`SELECT${search}FROM${table}WHERE${condition}`
connection.query(sql,params,(err,result)=>{
if(err){
reject(bad_msg)
}else{
let_=JSON.parse(JSON.stringify(success_msg))
_.data=resultresolve(_)
}
})
})
},
/**
*插入方法
*@param{*}table表名
*@param{*}condition条件
*@param{*}params参数
*@returns
*/
insert(table,condition,params){
returnnewPromise((resolve,reject)=>{
conststr="?"
let_=str.repeat((condition.split(',')).length)
letval=(Array.from(_)).toString()
letsql=`INSERTINTO${table}(${condition})VALUES(${val})`
connection.query(sql,params,(err,result)=>{
if(err){
reject(bad_msg)
}else{
resolve(success_msg)
}
})
})
},
/**
*更新方法
*@param{*}table表名
*@param{*}val值
*@param{*}condition条件
*@param{*}params参数
*@returns
*/
update(table,val,condition,params){
returnnewPromise((resolve,reject)=>{
letsql=`UPDATE${table}SET${val}WHERE${condition}`
connection.query(sql,params,(err,result)=>{
if(err){
reject(bad_msg)
}else{
resolve(success_msg)
}
})
})
},
/**
*删除方法
*@param{*}table表名
*@param{*}condition条件
*@param{*}params参数
*@returns
*/
del(table,condition,params){
returnnewPromise((resolve,reject)=>{
letsql=`DELETEFROM${table}WHERE${condition}`
connection.query(sql,params,(err,result)=>{
if(err){
reject(bad_msg)
}else{
resolve(success_msg)
}
})
})
},}module.exports=connections

constexpress=require('express')constrouter=express.Router()constconnections=require('../../static/connection')//token生成插件模块constjwt=require('jsonwebtoken');//Token签名varsecret=''constCreatId=require('../../static/ranId')router.post('/user/details',(req,res)=>{
connections.find('user_table',`ID=?`,req.user.ID).then(resp=>{
res.send(resp)
})})router.post('/api/login',(req,res)=>{
connections.find('user_table','user=?',req.body.user).then(resp=>{
let{data}=respif(data.length!==0){
for(leti=0;i{
res.send(e)
})})router.post('/api/register',(req,res)=>{
connections.find('user_table','user=?',req.body.user).then(resp=>{
if(resp.data.length>0){
res.send({
code:202,
msg:'该用户已经存在！'
})
}else{
let_=req.bodyletid=CreatId(3)+CreatId(3)
connections.insert('user_table','ID,user,pwd,avatarUrl,location,RegisterTime,isAdmin,isDel',[id,_.user,_.pwd,'/static/userimg/user.webp',_.location,Date.now(),0,0]).then(resps=>{
//传输的token内容
lettoken=jwt免费云主机、域名.sign({ID:id},secret,{expiresIn:'72H'});
//返回结果
res.send({
code:200,
msg:'操作成功！',
token:'Bearer'+token,
})
})
}
})})module.exports=router