一个极简版的nodejs增删改查

json版

var express = require('express');
var fs = require("fs");

var app = express();


app.get("/", function(req, res){

    res.send("Hello , welcome to index!<br>"+
        "<a href='http://localhost:8081/addUser'>增</a><br>"+
        "<a href='http://localhost:8081/update/1'>改 +id,  默认1</a><br>"+
        "<a href='http://localhost:8081/delUser/1'>删 + id,  默认1</a><br>"+
        "<a href='http://localhost:8081/1'>id查询 +id， 默认1</a><br>"+
        "<a href='http://localhost:8081/listUsers'>list查询</a><br>"
        );
});

// 新增
var user = {
   "user4" : {
      "name" : "mohit",
      "password" : "password4",
      "profession" : "teacher",
      "id": 4
   }
}
app.get('/addUser', function(req, res) {
    fs.readFile( __dirname + "/" + "users.json", 'utf8', function (err, data) {
        data = JSON.parse(data);
        data["user4"] = user["user4"];
        console.log( data );
        res.end( JSON.stringify(data) );
   });
});

// 删除
app.get('/delUser/:id', function (req, res) {
   fs.readFile( __dirname + "/" + "users.json", 'utf8', function (err, data) {
       data = JSON.parse( data );
       delete data["user" + req.params.id];
       
       console.log( data );
       res.end( JSON.stringify(data));
   });
})
// 修改
var updateUser = {
   "user" : {
      "name" : "zhangsan",
      "password" : "mypassword",
      "profession" : "programer",
      "id": 0
   }
}
app.get('/update/:id', function (req, res) {
    fs.readFile( __dirname + "/" + "users.json", 'utf8', function (err, data) {
        data = JSON.parse( data );
        delete data["user" + req.params.id];
        data["user" + req.params.id] = updateUser["user"];
        console.log( data );
        res.end( JSON.stringify(data) );
   });
})

// 列表查询
app.get('/listUsers', function (req, res) {
    fs.readFile( __dirname + "/" + "users.json", 'utf8', function (err, data) {
        console.log( data );
        res.end( data );
   });
})

// id查询
// 模拟数据的id和user+id对应
app.get('/:id', function (req, res) {
   fs.readFile( __dirname + "/" + "users.json", 'utf8', function (err, data) {
       data = JSON.parse( data );
       var user = data["user" + req.params.id] 
       console.log( user );
       res.end( JSON.stringify(user));
   });
})






var server = app.listen(8081, function () {
    
  console.log("访问地址: http://localhost:8081")

})

users.json

{
   "user1" : {
      "name" : "mahesh",
      "password" : "password1",
      "profession" : "teacher",
      "id": 1
   },
   "user2" : {
      "name" : "suresh",
      "password" : "password2",
      "profession" : "librarian",
      "id": 2
   },
   "user3" : {
      "name" : "ramesh",
      "password" : "password3",
      "profession" : "clerk",
      "id": 3
   }
}

mysql版

var express = require('express');
var fs = require("fs");
var mysql      = require('mysql');


var connection = mysql.createConnection({
  host     : 'localhost',
  user     : 'root',
  password : '123456',
  port: '3306',
  database : 'test'
});

var app = express();
connection.connect();

app.get("/", function(req, res){

    res.send("Hello , welcome to index!<br>"+
        "<a href='http://localhost:8081/addUser'>增</a><br>"+
        "<a href='http://localhost:8081/update/1'>改 +id,  默认1</a><br>"+
        "<a href='http://localhost:8081/delUser/1'>删 + id,  默认1</a><br>"+
        "<a href='http://localhost:8081/1'>id查询 +id， 默认1</a><br>"+
        "<a href='http://localhost:8081/listUsers'>list查询</a><br>"
        );
});

// 新增
app.get('/addUser', function(req, res) {

  var addSql = "INSERT INTO users(id,name,password,profession) VALUES(?,?,?,?)";
  var addSqlParams = [4, "赵六", "password4", "actor"];
  connection.query(addSql,addSqlParams,function (err, result) {
    if(err){
      return res.end('[SELECT ERROR] - '+err.message);
    }        
    if (result.affectedRows == 1) {
      res.send("添加成功！");
    }
  });

});

// 删除
app.get('/delUser/:id', function (req, res) {

  var delSql = 'DELETE FROM users where id='+req.params.id;
  connection.query(delSql,function (err, result) {
    if(err){
      console.log('[DELETE ERROR] - ',err.message);
      return;
    }        
    if (result.affectedRows == 1) {
      res.send("删除成功");
    }
  });

})


// 修改
app.get('/update/:id', function (req, res) {

  var modSql = 'UPDATE users SET name = ?,profession = ? WHERE id = ?';
  var modSqlParams = ['老贾', '摆小摊的',req.params.id];
  connection.query(modSql,modSqlParams,function (err, result) {
    if(err){
      return res.end('[SELECT ERROR] - '+err.message);
    }
    if (result.affectedRows == 1) {
      res.send("修改成功");
    }        

  });

})

// 列表查询
app.get('/listUsers', function (req, res) {

  var  sql = 'SELECT * FROM users';
  connection.query(sql,function (err, result) {
    if(err){
      return res.end('[SELECT ERROR] - '+err.message);
    }
    res.send( result );
  });


})


// id查询
// 模拟数据的id和user+id对应
app.get('/:id', function (req, res) {

  var sql = "SELECT * FROM users where id="+req.params.id;
  connection.query(sql,function (err, result) {
    if(err){
      return res.end('[SELECT ERROR] - '+err.message);
    }
    res.send( result );
  });

})






var server = app.listen(8081, function () {
    
  console.log("访问地址: http://localhost:8081")

})

users.sql

/*
 Navicat MySQL Data Transfer

 Source Server         : 127.0.0.1
 Source Server Version : 50621
 Source Host           : localhost
 Source Database       : TaoYuan

 Target Server Version : 50621
 File Encoding         : utf-8

 Date: 05/18/2016 11:44:07 AM
*/

SET NAMES utf8;
SET FOREIGN_KEY_CHECKS = 0;

-- ----------------------------
--  Table structure for `users`
-- ----------------------------
DROP TABLE IF EXISTS `users`;
CREATE TABLE `users` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `name` varchar(20) NOT NULL DEFAULT '' COMMENT '名字',
  `password` varchar(20) NOT NULL DEFAULT '' COMMENT '密码',
  `profession` varchar(20) NOT NULL DEFAULT '0' COMMENT '职业',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=6 DEFAULT CHARSET=utf8;

-- ----------------------------
--  Records of `users`
-- ----------------------------
BEGIN;
INSERT INTO `users` VALUES ('1', '张三', 'password1', 'teacher'), ('2', '李四', 'password2', 'programer'), ('3', '王五', 'password3', 'librarian');
COMMIT;

SET FOREIGN_KEY_CHECKS = 1;