008-第八天 Nodejs操作mongodb(增刪改查)

Nodejs操作mongodb
mongoose模塊幫助 https://www.npmjs.com/package/mongoose

前提
* 安裝mongodb模塊
npm install mongodb --save
注：--save參數(shù)：將mongodb添加到package.json中，這樣遷移項目的時候就可以使用npm install 直接進行模塊安裝

* 安裝mongoose模塊
npm install mongoose

mongoose 是操作mongodb數(shù)據(jù)庫的客戶端
`mongoose`需要`mongodb`的支持

服務端操作

1. 創(chuàng)建數(shù)據(jù)庫目錄

mkdir /home/scort/mongodb/data_db

2. 開啟mongodb數(shù)據(jù)庫服務

/home/scort/mongodb/bin/mongod --dbpath=/home/scort/mongodb/data_db

增

//引入mongoose模塊
var mongoose = require('mongoose');
//創(chuàng)建連接
var db = mongoose.createConnection("mongodb://127.0.0.1:27017/test");

//定義格式 => 表結(jié)構(gòu)
var monSchema = new mongoose.Schema({
  name : {type:String, default:'test'},
  age : {type: Number}
  });

//定義model 指定表名
var monModel = db.model('user', monSchema);

//定義插入內(nèi)容
var content = {
  name : "小明",
  age : 90
};

//初始化model
var monInsert = new monModel(content);
//執(zhí)行插入
monInsert.save(function(err, result){
  if(err){
    console.log(err);
  }else{
    console.log('insert ok');
  }

  //關閉連接
  db.close();
});

刪

//引入mongoose模塊
var mongoose = require('mongoose');
//創(chuàng)建連接
var db = mongoose.createConnection("mongodb://127.0.0.1:27017/test");

//定義格式 => 表結(jié)構(gòu)
var monSchema = new mongoose.Schema({
  name : {type:String, default:'test'},
  age : {type: Number}
  });

//定義model 指定表名
var monModel = db.model('user', monSchema);

//條件
var myWhere = {name:"小明"};

//執(zhí)行刪除
monModel.remove(myWhere, function(err){
  if(err){
    console.log(err);
  }else{
    console.log('remove ok');
  }

  //關閉連接
  db.close();
});

改

//引入mongoose模塊
var mongoose = require('mongoose');
//創(chuàng)建連接
var db = mongoose.createConnection("mongodb://127.0.0.1:27017/test");

//定義格式 => 表結(jié)構(gòu)
var monSchema = new mongoose.Schema({
  name : {type:String, default:'test'},
  age : {type: Number}
  });

//定義model 指定表名
var monModel = db.model('user', monSchema);

//條件
var myWhere = {name:"小明"};

//設置新值
var newValue = {$set : {age:19, name:"小紅"}};

//執(zhí)行刪除
monModel.update(myWhere, newValue, function(err, result){
  if(err){
    console.log(err);
  }else{
    console.log('update ok');
  }

  //關閉連接
  db.close();
});

查

//引入mongoose模塊
var mongoose = require('mongoose');
//創(chuàng)建連接
var db = mongoose.createConnection("mongodb://127.0.0.1:27017/test");

//定義格式 => 表結(jié)構(gòu)
var monSchema = new mongoose.Schema({
  name : {type:String, default:'test'},
  age : {type: Number}
  });

//定義model 指定表名
var monModel = db.model('user', monSchema);

//條件
var myWhere = {name:"小明"};

//指定字段
var fields = {name:1, age:1};

//執(zhí)行刪除
monModel.find(myWhere, function(err, result){
  if(err){
    console.log(err);
  }else{
    console.log(result);
  }

  //關閉連接
  db.close();
});