node.js 操作mongodb数据库

源代码

npmjs_mongodb

npm install mongodb  安装mongodb
npm install mongoose  安装mongoose

var mongoose = require('mongoose'); //引入模板
var db = mongoose.createConnection('mongodb://192.168.0.110:27017/test');//服务器地址  创建数据库
console.log(db);

首先要打开数据库，才能链接成功
    //启动数据库
    cd mongodb
    mkdir yangdb
    cd ..
    pwd
    cd bin
    ./mongodb -dbpath=../yangdb
    db.users.find().toArray();

//设置表
var monSchema = new mongoose.Schema({
  name:{type:String,default:'liwei'},
  age:{type:Number},
  sex:{type:String}
});

//mongodb 添加操作
    var monModel = db.model('user',monSchema);  //设为user表
    var content = {name:"小李子",age:18,sex:"男"};
    var monInser = new monModel(content);
    monInser.save(function(err){
      if(err){
        console.log(err);
      }else{
        console.log('插入成功!');
      }
      db.close();
    });

//mongodb 查询操作
    var monModel = db.model('user',monSchema);  //设为user表
    var content = {};
    var field = {name:"陈大哥"};
    monModel.find(content,field,function(err,result){
      if(err){
        console.log(err);
      }else{
        console.log(result);
      }
      db.close();
    });      

//mongodb 修改操作
  var monModel = db.model('user',monSchema);  //设为user表
  var tiaojain = {name:"张三"}; //修改的条件
  var genxindata = {$set:{name:"打不死的小强",age:'3'}};
  monModel.update(tiaojian,genxindata,function(err,result){
    if(err){
      console.log(err);
    }else{
      console.log("update is ok");
    }
    db.close();
  });

//mongodb 删除操作
var monModel = db.model('user',monSchema);  //设为user表
var shanchu = {name:"陈大哥"};
monModel.remove(shanchu,function(err){
  if(err){
    console.log(err);
  }else{
    console.log("shan chu chenggong");
  }
  db.close();
});