使用Node操作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();

    });

});

//创建文件 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;

// 如名字所示,我们要创建的是 名字为 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)

//

//在 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);

     });

   }

　　　}

//查询所有

   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);

   }