nodejs操作mongodb数据库

NodeJs为什么要用mongoose操作mongodb

直接用mongodb本身直接操作数据库,有时候会遇到这个错误：

    Error: db object already connecting, open cannot be called multiple times

出现这个问题的原因是：刷新得太快，或者多个用户同时访问数据库，数据库没来得及关闭，那个Error就会出现。访问数据库的时候都会用到db.open().访问完还得db.close(),所以大量访问会造成错误。
用mongoose就可以解决这个错误，一旦连接好数据库，db就会处于open状态，不存在访问时要打开，然后又要关闭的规则，所有mongodb部分改为mongoose，代码量也少些！

安装mongose

     npm install mongoose

扩展知识

mongo --dbpath=/data--port 27017 //修改数据库端口
mongodb--dbpath=../db--storageEnaine=mmapv1 //解决错误--JOURNAL--

连接到mongodb数据库

需要定义一个连接。如果只使用一个数据库，可以使用mongoose.connect，如果需要创建附加数据库连接，使用mongoose.createConnection。
connect和createConnection都能连接mongodb数据库，支持以URI或参数（host，database，port）的形式。

   varmongoose=require('mongoose')
   mongoose.connect('mongodb://主机名/端口')

连接一旦建立成功，该连接实例的open事件就被触发。如果你使用的是mongoose.connect方式，连接对象为mongoose.connection；否则，mongoose.createConnection返回的是Connection对象。
Mongoose在与数据库真正建立连接之前便缓存了所有的命令，这就意味着在定义模型、执行查询时不必非要确认与MongoDB数据库的连接是否已经建立。

定义模型

模型是通过模式接口（Schema interface）定义的，如：
interface）定义的，如：
var monSchema=new mongoose.Schema({ //设置数据类型 name:{type:String,default:'liuhengyu'}, age:{type:Number}, sex:(type:String) });
除了定义文档结构和你要存储的数据类型外，模式（Schema）还用于以下定义：
Validators （异步和同步）
Defaults - 默认值
Getters -方法
Setters -方法
Indexes - 索引
Middleware - 中间件
Methods definition - 方法定义
Statics definition - 静态定义
Plugins - 插件

插入数据

    //调用模块 
     var mongoose=require('mongoose') 
     //创建一个变量连接数据库以及选择数据库test 
     var db=mongoose.createConnection('mongodb://192.168.182.128:27017/test'); 
    //定义一个变量接收Schema方法
     var monSchema=new mongoose.Schema({  name:{type:String,default:'liuhengyu'}, age:{type:Number}, sex:(type:String) }); 
    //设置一个集合user，数据库默认在后边加s成为users 
     var monModel=db.model('user',monSchema); 
   //插入数据的值 
    var content={name:"刘恒宇",age:18,sex:'男'}; 
   //插入数据 
   var monInsert=new monModel(content); 
   //执行写入，设置回调函数。 最后关闭数据库。
   monInsert.save(function(err){ 
    if(err){ 
            console.log(err); 
      } else { 
      console.log('输入成功') 
      } 
      //关闭数据库 
      db.close(); });

查找数据

    //调用模块 
     var mongoose=require('mongoose') 
     //创建一个变量连接数据库以及选择数据库test 
     var db=mongoose.createConnection('mongodb://192.168.182.128:27017/test'); 
    //定义一个变量接收Schema方法
     var monSchema=new mongoose.Schema({  name:{type:String,default:'liuhengyu'}, age:{type:Number}, sex:(type:String) }); 
    //设置一个集合user，数据库默认在后边加s成为users 
     var monModel=db.model('user',monSchema); 
   //设置查的内容 
    var content={name:"刘恒宇"};
   //定义查询的字段
     var field={name:1,age:1,sex:1}; 
   //设置
   var monInsert=new monModel(content); 
   //执行查找，设置回调函数。 最后关闭数据库。
   monInsert.find(content,field,function(err,result){ 
    if(err){ 
            console.log(err); 
      } else { 
      console.log('result') 
      } 
      //关闭数据库 
      db.close(); });

删除数据

    //调用模块 
     var mongoose=require('mongoose') 
     //创建一个变量连接数据库以及选择数据库test 
     var db=mongoose.createConnection('mongodb://192.168.182.128:27017/test'); 
    //定义一个变量接收Schema方法
     var monSchema=new mongoose.Schema({  name:{type:String,default:'liuhengyu'}, age:{type:Number}, sex:(type:String) }); 
    //设置一个集合user，数据库默认在后边加s成为users 
     var monModel=db.model('user',monSchema); 
   //设置删除的内容 
    var content={name:"刘恒宇"};
   //设置
   var monInsert=new monModel(content); 
   //执行删除，设置回调函数。 最后关闭数据库。
   monInsert.remove(content,function(err,result){ 
    if(err){ 
            console.log(err); 
      } else { 
      console.log('result') 
      } 
      //关闭数据库 
      db.close(); });

修改数据

    //调用模块 
     var mongoose=require('mongoose') 
     //创建一个变量连接数据库以及选择数据库test 
     var db=mongoose.createConnection('mongodb://192.168.182.128:27017/test'); 
    //定义一个变量接收Schema方法
     var monSchema=new mongoose.Schema({  name:{type:String,default:'liuhengyu'}, age:{type:Number}, sex:(type:String) }); 
    //设置一个集合user，数据库默认在后边加s成为users 
     var monModel=db.model('user',monSchema); 
   //设置查询条件
    var content={name:"刘恒宇"};
   //定义修改内容
     var hahaha={$set:{name:'帅哥哥'}}; 
   //设置
   var monInsert=new monModel(content);
   //执行查找，设置回调函数。 最后关闭数据库。
   monInsert.update(content,hahaha,function(err,result){ 
    if(err){ 
            console.log(err); 
      } else { 
      console.log('result') 
      } 
      //关闭数据库 
      db.close(); });