第八天 Nodejs操作mongodb(增删改查)

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

Nodejs操作mongodb
mongoose模块帮助 https://www.npmjs.com/package/mongoose

前提
* 安装mongodb模块
npm install mongodb --save
注：--save参数：将mongodb添加到package.json中，这样迁移项目的时候就可以使用npm install 直接进行模块安装

* 安装mongoose模块
npm install mongoose

mongoose 是操作mongodb数据库的客户端
`mongoose`需要`mongodb`的支持

服务端操作

1. 创建数据库目录

mkdir /home/scort/mongodb/data_db

2. 开启mongodb数据库服务

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

增

//引入mongoose模块
var mongoose = require('mongoose');
//创建连接
var db = mongoose.createConnection("mongodb://127.0.0.1:27017/test");

//定义格式 => 表结构
var monSchema = new mongoose.Schema({
  name : {type:String, default:'test'},
  age : {type: Number}
  });

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

//定义插入内容
var content = {
  name : "小明",
  age : 90
};

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

  //关闭连接
  db.close();
});

删

//引入mongoose模块
var mongoose = require('mongoose');
//创建连接
var db = mongoose.createConnection("mongodb://127.0.0.1:27017/test");

//定义格式 => 表结构
var monSchema = new mongoose.Schema({
  name : {type:String, default:'test'},
  age : {type: Number}
  });

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

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

//执行删除
monModel.remove(myWhere, function(err){
  if(err){
    console.log(err);
  }else{
    console.log('remove ok');
  }

  //关闭连接
  db.close();
});

改

//引入mongoose模块
var mongoose = require('mongoose');
//创建连接
var db = mongoose.createConnection("mongodb://127.0.0.1:27017/test");

//定义格式 => 表结构
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:"小红"}};

//执行删除
monModel.update(myWhere, newValue, function(err, result){
  if(err){
    console.log(err);
  }else{
    console.log('update ok');
  }

  //关闭连接
  db.close();
});

查

//引入mongoose模块
var mongoose = require('mongoose');
//创建连接
var db = mongoose.createConnection("mongodb://127.0.0.1:27017/test");

//定义格式 => 表结构
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};

//执行删除
monModel.find(myWhere, function(err, result){
  if(err){
    console.log(err);
  }else{
    console.log(result);
  }

  //关闭连接
  db.close();
});