使用Node操作MongoDB数据库的方法_MongoDB

1.使用 MongoDB模块进行操作

首先在工作目录安装 mongodb 模块,

				?

									cnpm i mongodb//引入模块

				?

									const MongoClient = require('mongodb').MongoClient;

									//写连接字符串,我的数据库地址如下,所以当你在写的时候修改地址之后的内容就好

									const DB_CONN_STR= 'mongodb://127.0.0.1/demo';

									//记得打开mongod服务 ,不然等着一堆err吧

									//写一个插入数据的函数

									const insertData = function(db,callback){

									  let collection = db.collection('集合名');

									  let data = [{"name":"AAA","age":"19"},{"name":"BBB","age":"20"}]

									   // 向集合中添加数据

									  collection.insert(data,function(err,result){

									    if(err){

									      console.log('Error'+err);

									      return;

									    }

									    callback(result);

									  });  

									}

									//连接数据库      连接串    回调函数

									MongoClient.connect(DB_CONN_STR, function(err, db) {

									  console.log("Done");

									  //调用刚才写好的函数

									   insertData(db, function(result) {

									     //输出返回结果

									    console.log(result);

									     //关闭连接

									     db.close();

									   });

									});

2.使用 Mongoose模块进行操作

　2.1 创建文件db.js用来连接(其实这一步也有一点问题,不应该把数据库连接写到这里)

				?

									//创建文件 db.js

									// 在这之前你应该已经安装了 mongoose || cnpm install mongoose

									// 并且开启了mongod服务 

									import mongoose from 'mongoose';

									//mongoose.connect('mongodb://127.0.0.1:27017/demo'); 

									//如果只是入地址,会报一个警告,不是错误,只属于是不推荐的写法.推荐下面这么写

									mongoose.connect('mongodb://地址/数据库名',{useMongoClient: true});

									const db = mongoose.connection;

									// 

									db.on('error',console.error.bind(console,'connection error:'));

									db.once('open',function(callback){

									   console.log("connection start");

									});

									db.on('disconnected',function(){

									  console.log("connstion is disconnected");

									});

									module.exports = mongoose;

　2.2 Shema

创建文件stu.js保存操作

Mongoose中的一切来自于Schema。每个Schema都会映射到MongoDB集合(collection)并定义该集合(collection)中的文档的形状(类型)。

				?

									// 如名字所示,我们要创建的是 名字为 user 的Schmea

									//如果以后要添加其他键，请使用Schema.add({})方法。

									//引入刚才写好的模块

									import mongoose from './db'

									const Shema = mongoose.Schema;

									const UserShema = new Schema({

									  name : {type:String},

									  age : {type:Number},

									  class : {type:String}

									})

									// Schema Types内置类型如下：

									// String,Number,Boolean | Bool,Array,Buffer,Date,ObjectId | Oid,Mixed

									// 如果你发现少了什么属性,可以使用 Shame.add();追加

									UserShema.add{mail : 'String',pwd : 'String'}

									// 然后使用 Schema 创建我们的model ,再加入到模块,这一步骤很重要

									module.exports = mongoose.model('Student',UserSchema)

　　2.3 Shema 的使用(增加篇)

				?

									//

									//在 import user.js的时候 启动了 mongoose.model('Classes',ClassSchema);参见上面的最后一段代码

									import student from './stu'

									class mannager{

									  //第一种创建方式

									  add(){

									    let newStu = new student({

									    name : '张三',

									    age : 25,

									    class : '大四'

									    });

									    newStu.save(function (err) {

									    if (err) 

									      return handleError(err);

									    });

									  }

									  //第二种创建方式

									  add2(){

									    student.create({

									     name : '张三',

									     age : 25,

									     class : '大四'

									    },function(err){

									      if (err) 

									        return handleError(err);

									    }); 

									  }

									　　　}

　　Shema 的使用(查询篇)

mongoose

支持丰富的查询MongoDB语法。文件可以使用每个模型中使用 find，findById，findOne，或者where，静态方法。

				?

									//查询所有

									  findAll(){

									   return student.find(function(err,res){

									      if (err) {

									        return err;

									      }else{

									        let json = JSON.stringify(res); 

									        return res;

									      }

									    });

									  }

									  //按照条件查询

									  findByAge(age){

									    return student.find({Age : age},function(err,res){

									      if (err) {

									        return err;

									      }else{

									        let json = JSON.stringify(res); 

									        return res;

									      }

									    });

									  }

									  //多种条件

									  findTest(){

									    return Tank.find(

									      { class: '大三' }).where('Age').gt(20).exec(callback);

									  }