简单的nodejs + mongodb CRUD

/**
* Created by Administrator on 2015/4/22.
*/
var mongodb = require('./db'),
BSON = require('mongodb').BSONPure;

var User = function (user) {
this.firstName = user.firstName;
this.lastName = user.lastName;
};
User.prototype.AddOne = function (callback) {
var user = {
firstName: this.firstName,
lastName: this.lastName
};
mongodb.open(function (err, db) {
if (err) {
return callback(err);
}
db.collection('user', function (err, collection) {
if (err) {
return callback(err);
}
collection.insert(
user,
{safe: true},
function (err, newUser) {
mongodb.close();
if (err) {
return callback(err);
}
callback(null, newUser[0]);
}
)
});
});
};

User.prototype.UpdateById = function (Id, callback) {
Id = BSON.ObjectID.createFromHexString(Id);
var user = {
firstName: this.firstName,
lastName: this.lastName
};
mongodb.open(function (err, db) {
if (err) {
return callback(err);
}
db.collection('user', function (err, collection) {
if (err) {
mongodb.close();
return callback(err);
}
collection.update(
{_id: Id},
user,
{upsert: true, multi: false},
function (err, result) {
mongodb.close();
if (err) {
return callback(err);
}
callback(null, result);
}
);
})
});
};

User.DeleteById = function (Id, callback) {
if (!Id) {
return;
}
Id = BSON.ObjectID.createFromHexString(Id);
mongodb.open(function (err, db) {
if (err) {
return callback(err);
}
db.collection('user', function (err, collection) {
if (err) {
mongodb.close();
return callback(err);
}
collection.remove({_id: Id}, function (err, result) {
mongodb.close();
if (err) {
return callback(err);
}
return callback(null, result);
});
});
});
};

User.getAll = function (callback) {
mongodb.open(function (err, db) {
if (err) {
return callback(err);
}
db.collection('user', function (err, collection) {
if (err) {
mongodb.close();
return callback(err);
}
collection.find().toArray(function (err, docs) {
mongodb.close();
if (err) {
return callback(err);
}
callback(null, docs);
});
});
});
};

module.exports = User;

var express = require('express');
var path = require('path');
var favicon = require('serve-favicon');
var logger = require('morgan');
var cookieParser = require('cookie-parser');
var bodyParser = require('body-parser');

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

var app = express();

var settings = require('./settings');
var session = require('express-session');
var MongoStroe = require('connect-mongo')(session);
app.use(session({
resave: false,
saveUninitialized: true,
secret: settings.cookieSecret,
cookie: {maxAge: 1000 * 60 * 60 * 24 * 30},
stroe: new MongoStroe({
db: settings.db,
host: settings.host,
port: settings.port
})
}));

// view engine setup
app.set('views', path.join(__dirname, 'views'));
app.set('view engine', 'ejs');

//use flash
var flash = require('connect-flash');
app.use(flash());

// uncomment after placing your favicon in /public
//app.use(favicon(__dirname + '/public/favicon.ico'));
app.use(logger('dev'));
app.use(bodyParser.json());
app.use(bodyParser.urlencoded({extended: false}));
app.use(cookieParser());
app.use(express.static(path.join(__dirname, 'public')));

routes(app);

// catch 404 and forward to error handler
app.use(function (req, res, next) {
var err = new Error('Not Found');
err.status = 404;
next(err);
});

// error handlers

// development error handler
// will print stacktrace
if (app.get('env') === 'development') {
app.use(function (err, req, res, next) {
res.status(err.status || 500);
res.render('error', {
message: err.message,
error: err
});
});
}

// production error handler
// no stacktraces leaked to user
app.use(function (err, req, res, next) {
res.status(err.status || 500);
res.render('error', {
message: err.message,
error: {}
});
});

module.exports = app;

var User = require('../models/User');
module.exports = function (app) {

/* GET home page. */
app.get('/', function (req, res, next) {
console.log('get all the data from table user');
User.getAll(function (err, users) {
if (err) {
users = [];
}
res.render('index',
{
title: 'Node CRUD',
users: users
}
);
});
});

app.post('/', function (req, res) {
var user = {};
user.firstName = req.body.firstName;
user.lastName = req.body.lastName;
var newUser = new User(user);
newUser.AddOne(function (err, user) {
if (err) {
return;
}
req.flash('success', '添加成功');
res.redirect('/');
});
});

app.post('/delete', function (req, res) {

User.DeleteById(req.body.Id, function (err, result) {
if (err) {
//返回json的数据才会成功
res.send({data: "fail"});
}
res.send({data: "success"});
});
//User.UpdateById(1,function(err,result){
//    if(err){
//        console.log('update err:' + err);
//    }
//    console.log('update'+result);
//});
});
};

/**
* Created by Administrator on 2015/4/22.
*/
module.exports = {
cookieSecret: 'NodeCrud',
db: 'NodeCrud',
host: 'localhost',
port: '27017'
}

/**
* Created by Administrator on 2015/4/22.
*/

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

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