nodejs 简单对mongodb 操作

路由到了 index.js

/*
 * GET home page.  控制器
 */exports.index = function(req, res){
 // res.render('index', { title: 'Express 主页' });
  //读取数据
    var mongodb = require('mongodb');
    var server = new mongodb.Server('localhost',27017,{auto_reconnect:true});
    var db = new mongodb.Db('mydb',server,{safe:true});   db.open(function(err,db){
    if(!err)
    {
      db.collection('mycoll',{safe:true},function(err,collection){          collection.find().toArray(function(err,docs){
              console.log('find');
              console.log(docs);
             // res.send(docs);
              res.render('index', { title: 'Express 主页' ,list : docs});
          });
          /*
          collection.findOne(function(err,doc){
              console.log('findOne');
              console.log(doc);
          });
          */
      });
    }
   });};// 提交数据页面
exports.post = function(req, res){  res.render('post', { title: '提交数据' });
/*
var mongodb = require('mongodb');
var server = new mongodb.Server('localhost',27017,{auto_reconnect:true});
var db = new mongodb.Db('mydb',server,{safe:true});
db.open(function(err,db){
    if(!err)
    {
        db.collection('mycoll',{safe:true},function(err,collection){
            var tmp1={title:'hello',number:1};
            collection.insert(tmp1,{safe:true},function(err,result){
                console.log(result);//终端打印
                res.send(result);//客户端请求响应
            });        });    }else{
        console.log(err);
        res.send("error");
    }   });*/};
// 提交数据处理 页面
exports.postdata = function(req, res){
    /*
    require('../models/content');
    var newContent = new Content({
        title: req.body.title,
        content: req.body.content,
    });
    //根据内容模型保存数据
    newContent.save(function(err) {
    if (err) {
        req.flash('error', err);
        return res.redirect('/post');
    }        req.flash('success', '提交成功');
        res.redirect('/');
    });     console.log(title);
     res.send(title);
    */var mongodb = require('mongodb');
var server = new mongodb.Server('localhost',27017,{auto_reconnect:true});
var db = new mongodb.Db('mydb',server,{safe:true});
db.open(function(err,db){
    if(!err)
    {
        db.collection('mycoll',{safe:true},function(err,collection){
            var tmp1={title:req.body['title'],content:req.body['content']};
            collection.insert(tmp1,{safe:true},function(err,result){
                console.log(result);//终端打印
                //res.send(result);//客户端请求响应
                res.redirect('/post');
            });        });    }else{
        console.log(err);
        res.send("error");
    }   });};
// 单独读取页面
exports.view = function(req, res){
  res.render('view', { title: '预览' });
};