全栈工程师 08 笔记

Node.js操作MongoDB数据库（增、删、改、查）

1. 先安装组件

mongodb模块：https://www.npmjs.com/package/mongodb
mongoose模块：https://www.npmjs.com/package/mongoose
Node.js 官方自带一套MongoDB的组件
这里我们采用mongoose 来对MongoDB数据库进行操作，但操作Mongoose必须先把MongoDB安装上

    安装mongodb模块
     npm install mongodb --save
    注：--save参数：将mongodb添加到package.json中，为了项目合并时，所需模块，
    不需要进行模块包的合并，使用 npm install package.json 里的所又模块都会安装
    
    安装mongoose模块
     npm install mongoose
     mongoose 是操作mongodb数据库的客户端;`mongoose`需要`mongodb`的支持

2. 创建目录开启数据库
   mkdir /home/jingyue/mongodb/data_db

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

3. 插入数据
   // 引入mongoose模块
   var mongoose = require('mongoose');
   //创建链接
   var db = mongoose.createConnection('mongodb://127.0.0.1:27017/user');
   //定义格式
   var monSchema = new mongoose.Schema({
   name:{type:String,default:'name'},
   age:{type:Number}
   });
   //创建表
   var monModel = db.model('user', monSchema);
   //要插入内容
   var content = {
   name : "阿文",
   age : 18
   };
   //初始化model
   var monInsert = new monModel(content);
   //执行插入
   monInsert.save(function(err, result){
   if(err){
   console.log(err);
   }else{
   console.log('写入数据成功');
   }
   //关闭连接
   db.close();
   });

4. 删除数据
   // 引入mongoose模块
   var mongoose = require('mongoose');
   //创建链接
   var db = mongoose.createConnection('mongodb://127.0.0.1:27017/user');
   //定义格式
   var monSchema = new mongoose.Schema({
   name:{type:String,default:'name'},
   age:{type:Number}
   });
   //定义model 指定表名
   var monModel = db.model('user', monSchema);

   //条件
    var where = {name:"阿文"};
   
   //执行删除
    monModel.remove(where, function(err){
      if(err){
        console.log(err);
      }else{
        console.log('删除成功');
      }
     //关闭连接
      db.close();
    });
   

5. 更新数据
   // 引入mongoose模块
   var mongoose = require('mongoose');
   //创建链接
   var db = mongoose.createConnection('mongodb://127.0.0.1:27017/user');
   //定义格式
   var monSchema = new mongoose.Schema({
   name:{type:String,default:'name'},
   age:{type:Number}
   });

   //定义model 指定表名
    var monModel = db.model('user', monSchema);
   
   //条件
    var where = {name:'小月月'};
   
   //设置新值
    var newData = {$set : {age:19, name:"文文"}};
   
   //执行删除
    monModel.update(where, newData, function(err, result){
       if(err){
          console.log(err);
       }else{
          console.log('更新成功');
       }
   
      //关闭连接
       db.close();
    });
   

6. 查询数据
   // 引入mongoose模块
   var mongoose = require('mongoose');
   //创建链接
   var db = mongoose.createConnection('mongodb://127.0.0.1:27017/user');
   //定义格式
   var monSchema = new mongoose.Schema({
   name:{type:String,default:'name'},
   age:{type:Number}
   });

   //定义model 指定表名
    var monModel = db.model('user', monSchema);
   
   //条件
    var where = {name:"阿文"};
   
   //指定要查出来的字段
    var fields = {name:1, age:1};
   
   //查询
    monModel.find(where,fields, function(err, result){
        if(err){
          console.log(err);
        }else{
          console.log(result);
        }
   
        //关闭连接
        db.close();
    });