npm install MysqL

//连接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;

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;

var usersRouter = require('./routes/users');

app.use('/users',usersRouter);