Node+Express+MySql实现简单增删改查和登录

October 26, 2018 · 2 min · jiezi

var express = require(’express’);var mysql = require(‘mysql’);var app = express();var bodyParser = require(‘body-parser’);//链接数据库var connection = mysql.createConnection({ host: ’localhost’, user: ‘root’, password: ‘123456’, database: ‘school’});connection.connect();// 创建 application/x-www-form-urlencoded 编码解析(post方法)var urlencodedParser = bodyParser.urlencoded({ extended: false })//设置跨域访问app.all(’’, function (req, res, next) { res.header(“Access-Control-Allow-Origin”, “”); res.header(“Access-Control-Allow-Headers”, “X-Requested-With”); res.header(“Access-Control-Allow-Methods”, “PUT,POST,GET,DELETE,OPTIONS”); res.header(“Content-Type”, “application/json;charset=utf-8”); next();});//登录app.post(’/login’,urlencodedParser, function (req, res) { var username = req.body.username; var password = req.body.password; var sql = select * from login where username = '${username}' and password = '${password}'; connection.query(sql, function (err, result) { console.log(result) if (err || result.length == 0) { res.status(200), res.json(“登陆失败”) } else { res.status(200), res.json(“登陆成功”) } });})//查询app.get(’/query’, function (req, res) { var sql = ‘select * from student’; connection.query(sql, function (err, result) { if (err) { console.log(’err:’, err.message); } console.log(result); res.status(200), res.json(result) });});//修改app.get(’/change’, function (req, res) { var SNO = req.query.SNO; var SNAME = req.query.SNAME; var SDEPT = req.query.SDEPT; var sql = update student set SNAME = '${SNAME}',SDEPT = '${SDEPT}' where SNO = '${SNO}'; connection.query(sql, function (err, result) { if (err) { console.log(’err:’, err.message); } console.log(result); res.status(200), res.json(“修改成功”) });})//添加app.get(’/add’, function (req, res) { console.log(req.query) var SNO = req.query.SNO; var SNAME = req.query.SNAME; var SDEPT = req.query.SDEPT; var sql = insert into student values ('${SNO}','${SNAME}','${SDEPT}'); connection.query(sql, function (err, result) { if (err) { console.log(’err:’, err.message); } console.log(result); res.status(200), res.json(“添加成功”) });})//删除app.get(’/delete’, function (req, res) { console.log(req.query) var SNO = req.query.SNO; var sql = delete from student where SNO='${SNO}'; connection.query(sql, function (err, result) { if (err) { console.log(’err:’, err.message); } console.log(result); res.status(200), res.json(“删除成功”) });})// connection.end();//配置服务端口var server = app.listen(8080, function () { var host = server.address().address; var port = server.address().port; console.log(‘http://’, host, port);})github：https://github.com/Rossy11/no…