mongod --dbpath=c:\mongodbInfo\ --port 27017

npm install mongodb

  "dependencies": {"cookie-parser": "~1.3.3","debug": "~2.0.0","body-parser": "~1.8.4","express": "~4.9.8","jade": "~1.6.0","mongodb": "~1.3.23","morgan": "~1.3.2","serve-favicon": "~2.1.7"}

//文档地址：http://mongodb.github.io/node-mongodb-native/1.4/
//mongodb已经更新到了2.0了,我勒个去;
var  mongodb = require('mongodb');
//数据库连接的配置
var MONGOURL = "mongodb://localhost:27017/";var open = function(name, callback) {/*//1.2版本和1.4版本mongodb的连接方式;,2.0的mongodb连接有向前兼容;var  server  = new mongodb.Server('localhost', 27017, {auto_reconnect:true});var  db = new mongodb.Db(name, server, {safe:true});db.open(function(err, db){if(!err){console.log('connect db');callback&&callback(db);};});*/// 这样的连接方式还是比较好理解的;var MongoClient = require('mongodb').MongoClient;// name为数据库的名字;var url = MONGOURL+ name;MongoClient.connect(url, function(err, db) {console.log('connect db');callback&&callback(db);});
};/*
*   @param dbName;
*       instance    @method create(colname, callback);
*       instance    @method remove(colname, callback);
*       instance    @method getDb();
*/
var Col = function(name,callback) {//连接数据库；open( name,function(_db) {this.db = _db;console.log("new db is done!")callback&&callback( _db );}.bind(this) );
};Col.prototype = {constructor : Col,create : function( name, callback) {this.db.createCollection( name, {safe:true}, function(err, collection){if(err) {console.log(err);}else{callback&&callback(collection);};});},remove : function( name, callback) {this.db.dropCollection(name, {safe:true}, function(err,result) {if(err) {console.log(err);return;};callback&&callback(result);});},getDb : function() {return this.db;}
};module.exports = Col;

//文档地址：http://mongodb.github.io/node-mongodb-native/1.4/
//mongodb已经更新到了2.0了,我勒个去;var Crud = function(db) {this.db = db;
};
Crud.prototype  = {constructor : Crud,noop : function(){},//增加insert : function(col, val, cb) {cb = cb || this.noop;return this.db.collection(col).insert(val,cb);},//更新update : function(col, search, val, cb) {cb = cb || this.noop;return this.db.collection(col).update(search, {$set : val}, cb);},//删除remove : function(col,key,cb) {cb = cb || this.noop;//console.log(this.db.collection(col).remove);return this.db.collection(col).remove(key,cb);},find : function(col,keyword,cb) {cb = cb || this.noop;this.db.collection(col).find(keyword).toArray(function(err, docs) {cb(docs);});},findBy_id : function(col,id, cb) {this.db.collection(col).find({},{_id : id}, function(err, docs){docs.toArray(function(err,doc){cb(doc)})})},findOne : function(col,keyword,cb) {cb = cb || this.noop;this.db.collection(col).findOne(keyword,function(err, docs) {cb(docs);})}
};/*需要把题目的数据库实例放进来;var crud = new Crud(db);var result = crud.insert("nono" [{xx:xx}] , callback);var result = crud.update("nono", {hehe1 : 1} , { lala : "lala" },function(){console.log("update Done")});var result = crud.remove("nono", {hehe : 0} ,function() {console.log("remove Done")});var result = crud.find("nono", {hehe1 : 1} ,function(doc) {}*/
module.exports =  function(db) {return new Crud(db);
};

var express = require('express');
var Col = require("../mongodb/Col.js");
var Crud = require("../mongodb/Crud.js");
var ObjectID = require('mongodb').ObjectID;//路由是把第一个err给拿掉了;
var router = express.Router();//初始化crud
var crud;
//新建DB并获取;
var db =new Col("todo",function(db){//数据库连接完毕...//创建一个RESTFUL对象;crud = new Crud( db, function(){} );
});
/*
var data = {title : "t0do",lists : []
};
*///这个可以理解为app.get("/",function(req, res, next){});
/* GET 获取所有的列表. */
router.get('/', function(req, res) {//因为db的新建连接是异步的,所以你如果新建数据库连接以后马上getDb不会失效,你获取的是undefined;crud.find("todos",{},function(docs) {console.log( docs );res.render('index', {title : "todos", lists : docs});});
});/* GET 用户选择是否删除指定ID. */
router.get('/del/:id', function(req, res) {res.render("delete",{id : req.params.id});
});//用户确认删除指定id的todo
router.get("/del/ok/:id", function(req, res) {var crud = new Crud(db.getDb());var id = new ObjectID(req.params.id);crud.remove("todos",{_id : id}, function() {res.redirect("../../");});
});//获取编辑的todo信息界面
router.get('/modify/:id', function(req, res, next) {var _id = new ObjectID( req.params.id );crud.findOne("todos",{ _id : _id}, function(doc) {doc.id = doc._id;res.render("modify",doc);});
});//更新用户信息并重定向到主界面
router.post('/modify', function(req, res, next) {var body = req.body;console.log(body);crud.update("todos",{_id : new ObjectID(body.id)}, {_id:new ObjectID(body.id),title:body.title,content:body.content},function() {console.log("done");});res.redirect("../");
});/* GET add listing. */
router.get('/add', function(req, res) {res.render("add",{});
});//默认的post值为新建, 从add界面调过来的;
router.post("/add",function(req, res) {crud.insert("todos",[ {title : req.body.title, content : req.body.content }], function() {console.log("success");});res.redirect("./");
});module.exports = router;