1.安装库
npm install mysql
2.编写db.js(用作公共模块)
//连接MySQL数据库
var mysql = require("mysql");
var pool = mysql.createPool({
host:"127.0.0.1",user:"root",password:"123456",database:"wordpress",port:3306
});
function query(sql,callback){
pool.getConnection(function(err,connection){
connection.query(sql,function (err,rows) {
callback(err,rows);
connection.release();
});
});
}
exports.query = query;
3.编写user.js(与数据库交互并对外开放接口)
顺便说下req.params、req.body、req.query的应用
req.body通常用于解析post请求数据
req.query通常用于解析get请求数据,如http://wwww.youcongtech.com/blog/user?username=youcong
req.params通常用于解析rest请求方式,如http://www.youcongtech.com/blog/user/youcong
var express = require('express');
var router = express.Router();
var URL = require('url');
var db = require('./db');
var jsonData = require('./jsonData');
var bodyParser = require('body-parser');
//定义一个post输出接口
router.post('/post',function(req,res) {
var obj = {
a: 1,b: 2
};
res.json(obj); //以json格式输出
});
//增删改查
//查询所有信息
router.get('/queryAll',res,next) {
var userLogin = req.userLogin
var querySql = 'SELECT * FROM wp_users';
db.query(querySql,rows) {
if(err){
console.log('[SELECT ERROR] - ',err.message);
return;
}
//把搜索值输出
res.send(rows);
console.log('The solution is: ',rows[0].ID);
});
});
//添加用户信息
router.post("/add",res){
var params = URL.parse(req.url,true).query;
var addSql = "INSERT INTO wp_users (user_login) VALUES('"+params.userLogin+"')";
var addSqlParams = [params.userLogin];
db.query(addSql,function(err,rows){
if(err){
res.send("添加失败 " + err);
}else {
res.send(jsonData.addInfo);
}
});
});
//更新用户信息
router.put("/update",next){
var params = URL.parse(req.url,true).query;
var displayName = params.displayName;
var id = params.id;
var sql = "update wp_users set display_name = '"+ displayName +"' where ID = " + id;
db.query(sql,rows){
if(err){
res.send("修改失败 " + err);
}else {
res.send(jsonData.updateInfo);
}
});
});
//根据ID获取用户信息
router.get("/getById/:id",res){
var id = req.params.id;
var sql = 'select * from wp_users where ID = '+id;
db.query(sql,result) {
if(err){
console.log('[SELECT ERROR] - ',err.message);
return;
}
console.log(result);
res.send(result);
});
});
//删除用户信息
router.delete('/delete/:id',next) {
var id = req.params.id;
var delSql = 'delete from wp_users where id = '+id;
db.query(delSql,result) {
if(err){
console.log('[INSERT ERROR] - ',err.message);
return;
}
res.send(jsonData.deleteInfo);
});
});
module.exports = router;
4.不要忘记在app.js配置路由
var usersRouter = require('./routes/users');
app.use('/users',usersRouter);
参考资料如下:
node.js取参四种方法req.body,req.params,req.param,req.body:https://www.cnblogs.com/jkingdom/p/8065202.html
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。