Nodejs连接Mysql实现增删改查接口demo

Demo目录

query ./dbconfig.js
const mysql = require('mysql')
const dbconfig = require('./dbconfig')
const pool = mysql.createPool(dbconfig);

//数据库连接池
function query(sql,params) {
return new Promise((resolve, reject) => {
pool.getConnection((err, conn) => {
if (err) {
reject(err)
return
}
// let sql = 'select *from user where id=? and name=?'
//执行sql语句
conn.query(sql, params, (err, result) => {
conn.release()
if (err) {
throw err
}
resolve(result)
})
});
});
}

module.exports=query

1
2
3

服务端 ./server.js
const url = require('url')
const http = require('http')
const routerModal = require('./router/index.js')

const getPostData = (req) => {
return new Promise((resolve, reject) => {
if (req.method !== 'POST') {
resolve({})
return
}
let postData = ''
req.on('data', chunk => {
postData += chunk;
})
req.on('end', () => {
console.log(postData)
resolve(JSON.parse(postData))
})
});
}
const server = http.createServer((req, res) => {
//设置允许跨域的域名，*代表允许任意域名跨域
res.setHeader("Access-Control-Allow-Origin","http://127.0.0.1:5501");
res.writeHead(200, { 'content-type': 'application/json;charset=UTF-8' })
getPostData(req).then((data) => {
req.body = data
let result = routerModal(req, res);
if (result) {
result.then(resultData =>{
res.end(JSON.stringify(resultData))
})
} else {
res.writeHead(404, { 'content-type': 'text/html' })
res.end('404 not found')
}
})

})

server.listen(3000, () => {
console.log('监听3000端口')
})