nodeJS+bootstarp+mongodb整一个TODO小例子

  "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;