使用Express+Node.js对mysql进行增改查操作 

// 引入 express 框架
const express = require('express')
const mysql = require("mysql");
const bodyParser = require('body-parser');

// 创建实例
const app = express();
// 解析 application/json
app.use(bodyParser.json());
// // 解析 application/x-www-form-urlencoded
// app.use(bodyParser.urlencoded());

app.all('*', function(req, res, next) {
res.header('Access-Control-Allow-Origin',
'*'); //*表示可以跨域任何域名都行（包括直接存在本地的html文件）出于安全考虑最好只设置 你信任的来源也可以填域名表示只接受某个域名
res.header('Access-Control-Allow-Headers', 'X-Requested-With,Content-Type'); //可以支持的消息首部列表
res.header('Access-Control-Allow-Methods', 'PUT,POST,GET,DELETE,OPTIONS'); //可以支持的提交方式
res.header('Content-Type', 'application/json;charset=utf-8'); //响应头中定义的类型
next();
});

const connection = mysql.createConnection({ //建立一个连接参数方法
host: 'localhost', //数据库地址
port: '3306', //端口号
user: 'root', //用户名
password: 'root', //密码
database: 'test' //数据库名称
});
//用参数与数据库进行连接
// connection.connect();
let str = '';
connection.connect(); //打开连接
// connection.end()//关闭连接 如果关闭连接第二次请求数据库连接会失败
const getBanner = (table) => { //查询数据
return new Promise(function(resolve, reject) {
let sql = `SELECT * FROM ${table}`;
try {
connection.query(sql, (err, data) => {
if (err) {
reject(err)
} else {
resolve(data)
}
})
} catch (e) {
console.log(e);
}
})
}

const addBanner = (list) => { //增加数据
// console.log(Object.values(list));
list = Object.values(list) //将对象转成数组
return new Promise(function(resolve, reject) {
// const sql = 'UPDATE `user` SET ? WHERE id = ?'
// //若sql语句中包含多个?占位符,第二个实参必须传递一个数组,并一一对应
// conn.query(sql,[user,user.id],(err,result) => {}
let addSql = `INSERT INTO banner(name,url) VALUES (?,?)`;
try {
connection.query(addSql, list, (err, result) => {
if (err) {
reject(err)
} else {
result = {
code: 200,
msg: '增加成功'
};
resolve(result)
}
})
} catch (e) {
console.log(e);
}
})
}
const deleteBanner = (list) => { //删除数据
return new Promise(function(resolve, reject) {
let deleteSql = `delete from banner where name='${list.name}'`;
try {
connection.query(deleteSql, (err, result) => {
if (err) {
reject(err)
} else {
result = {
code: 200,
msg: '删除成功'
};
// console.log(result);
resolve(result)
}
})
} catch (e) {
console.log(e);
}
})
}
const updateBanner = (list) => { //修改数据
return new Promise(function(resolve, reject) {
let updateSql = `update banner set ? where id=${list.id}`;
try {
connection.query(updateSql,list.data, (err, result) => {
if (err) {
reject(err)
} else {
result = {
code: 200,
msg: '修改成功'
};
// console.log(result);
resolve(result)
}
})
} catch (e) {
console.log(e);
}
})
}
//2.发送请求(查询)
// var insert = `INSERT INTO table_name (name,url )VALUES(${name},${url});`

app.get('/', (req, res) => {
res.send('express启动成功端口号3011');
})
app.post('/addbanner', (req, res) => { //增加
addBanner(req.body).then(re => {
console.log(re);
res.send(re)
})
})
app.post('/deletebanner', (req, res) => { //删除
deleteBanner(req.body).then(re => {
// console.log(re);
res.send(re)
})
})
app.post('/updatebanner', (req, res) => { //修改
updateBanner(req.body).then(re => {
console.log(re);
res.send(re)
})
})
app.post('/select', (req, res) => { //查询某表数据
getBanner(req.body.table).then(re => {
res.send(re);
})
})
// 监听端口
app.listen(3011, () => {
console.log("服务已经启动，3011 端口监听中...");
})