Node.js Express 从入门到菜鸟（三）——node.js+express+mongodb 操作数据库

    过了个五一，回来又开始搞这个系列。

    看完之前的系列，咱们已经可以完成一个简单的不需要数据库的网站了。当然，不连数据库的网站挺少的，咱们接下来就讲一下node.js与mongodb的结合

    在开始之前，假设咱们已经安装并掌握了mongodb的安装与简单使用以及简单的node.js操作mongodb。如果没有的话，请移步《mongodb权威指南》或Node.js与MongoDB实战教程

   

    本篇博客不讲简单的node.js操作数据库的crud，咱们讲的是node.js与mongodb的结合。如果对这句话有疑问的话，试着做一个简单的登录网站就明白了。习惯了asp.net面向对象编程的我在最初接触js的函数式异步编程模式时，真是吃尽了苦头。

    我所理解的函数式异步编程，是一种符合人的思维习惯的编程方式。简单的说，就是完成操作A后根据我传入的函数再去完成操作B。话不多说，看例子。

    这是一个有登录，注册，修改密码功能的小例子。技术点有mongodb，session

    按照之前讲过的方法，安装express

    修改app.js文件如下

    根目录下添加setting.js文件如下

module.exports = {
  cookieSecret: 'microblogbyvoid',
  db: 'mydb',
  host: 'localhost',
  port:'27017'
};

    在route目录下添加logon.js文件如下

 var user=require('../modules/user');
exports.index = function(req, res){
    res.render('logon/index',{title:'Logon'});
};

exports.logon = function(req, res){
    var userService=new user({username:req.body.username,password:req.body.pwd});
    userService.logon(function(err,doc){
        if(err)
        {
            res.send('db error'+err);
        }
        if(doc)
        {
            req.session.userInfo=doc;
            res.send('ok');
        }
        else
        {
            res.send('false');
        }
    });
};

exports.register = function(req, res){
    res.render('logon/register', { title: '注册新用户' });
};

exports.processRegister = function(req, res){
    var userService=new user({username:req.body.username,password:req.body.pwd});

       userService.get(function(err,result){
        if(err)
        {
            res.send('db error'+err);
        }
        if(result)
        {
            res.send('用户名已存在');
        }
        else
        {
            userService.add(function(err,result){
                if(err)
                {
                    res.send('db error'+err);
                }
                if(result)
                {
                    res.send('ok');
                }
                else
                {
                    res.send('添加失败，请重试');
                }
            });
        }
    });
};

exports.changePwd = function(req, res){
    res.render('logon/changePwd', { title: '修改密码',username:req.session.userInfo.username });
};

exports.processChangePwd = function(req, res){
     var userSevice=new user({username:req.session.userInfo.username,password:req.body.currPwd});

     userSevice.get(function(err,doc){
          if(err)
          {
              res.send('db error'+err);
          }
          if(doc)
          {
              userSevice.updatePwd(req.body.newpwd,function(err,doc){
                     if(err)
                     {
                         res.send('db error'+err);
                     }
                     if(doc)
                     {
                         res.send('ok');
                     }
                     else
                     {
                        res.send('修改失败');
                     }
              });
          }
         else
          {
              res.send(doc);
          }
     })
};

    添加module文件夹，在该文件夹下添加db.js及user.js文件如下

var settings = require('../setting');
var Db = require('mongodb').Db;
var Connection = require('mongodb').Connection;
var Server = require('mongodb').Server;

module.exports = new Db(settings.db, new Server(settings.host, settings.port, {auto_reconnect:true}),{safe:true});

var db=require('./db');

function user(newUser)
{
    this.username=newUser.username;
    this.password=newUser.password;
};
module.exports=user;

user.prototype.get=function(callback){
     var userTemp=new user({username:this.username,password:this.password});
     db.open(function(err,db){
         if(err)
         {
             db.close();
             callback(err);
         }
         else
         {
             db.collection('users',function(err,collection){
                 if(err)
                 {
                     db.close();
                     callback(err);
                 }
                 else
                 {
                     var msg={username:userTemp.username};
                     collection.findOne(msg,function(err,doc){
                         db.close();
                         if(doc)
                         {
                             var userTemp=new user({username:doc.username,password:doc.password});
                             callback(err,userTemp);
                         }
                         else
                         {
                             callback(err,null);
                         }
                     })
                 }
             });
         }
     });
}

user.prototype.add=function(callback){
    var userTemp=new user({username:this.username,password:this.password});
    db.open(function(err,db){
        if(err)
        {
            db.close();
            callback(err);
        }
        else
        {
            var msg={ username:userTemp.username,password:userTemp.password };
            db.collection('users',function(err,collection){
                collection.insert(msg,{safe:true},function(err,result){
                    db.close();
                    callback(err,result);
                });
            });
        }
    });
}

user.prototype.logon=function(callback){
    var userTemp=new user({username:this.username,password:this.password});
    db.open(function(err,db){
        if(err)
        {
              db.close();
              callback(err);
        }
        else
        {
            db.collection('users',function(err,collection){
                if(err)
                {
                    db.close();
                    callback(err);
                }
                else
                {
                    var msg={username:userTemp.username,password:userTemp.password};
                    //不知道为什么，加了{safe:true}这个选项后，只返回id
                    collection.findOne(msg,function(err,doc){
                        db.close();
                        if(err)
                        {
                            callback(err)
                        }
                        else
                        {
                            callback(err,doc);
                        }
                    });
                }
            });
        }

    });
}

user.prototype.update=function(msg,updatamsg,callback){
    db.open(function(err,db){
        if(err)
        {
            db.close();
            return callback(err);
        }
        db.collection('users',function(err,collection){
            if(err)
            {
                db.close();
                return callback(err);
            }
            collection.update(msg,updatamsg,function(err,doc){
                db.close();
                callback(err,doc);
            })
        })
    })
}

user.prototype.updatePwd=function(newPwd,callback){
    var userTemp=new user({username:this.username,password:this.password});
    var msg={"username":userTemp.username}
    var updatamsg={"$set":{"password":newPwd}};
    userTemp.update(msg,updatamsg,callback);
}

   这是项目的结构截图

   

        祝大家玩的愉快～～～～