bzyaocom的gravatar头像
bzyaocom 2017-12-09 09:16:44
nodejs连接mongodb示例,实现对数据的增删改查操作(跳过不必要的坑) Windows版

第一步:安装nodejs

1.1.官网下载 版本:nodejs v6.9.2(对应npm v3.10.9)下载地址:https://nodejs.org/dist/

1.2.详细安装步骤,请参考https://www.cnblogs.com/sese/p/5182783.html

 

第二步:安装mongodb及驱动(注意版本兼容)

2.1.官网下载版本:mongodb v3.0.0 驱动版本:v2.2.33 下载地址:https://www.mongodb.com/download-center?jmp=nav#community

2.2.mongodb详细安装步骤,请参考https://www.cnblogs.com/wyhlightstar/p/6271251.html

2.3.驱动安装 

首先打开nodejs进行全局安装mongodb驱动器 输入命令npm install mongodb -g

再在新建的项目安装中 命令 npm install mongodb --save 此步骤安装时还需要配置package.json文件(请放在项目的根目录下)

package.json 内容如下:

{
  "name": "nodejs02",
  "version": "0.0.0",
  "private": true,
  "scripts": {
    "start": "node ./bin/www"
  },
  "dependencies": {
    "body-parser": "~1.15.2",
    "cookie-parser": "~1.4.3",
    "debug": "~2.2.0",
    "ejs": "~2.5.2",
    "express": "^4.14.1",
    "mongodb": "^2.2.33",
    "morgan": "~1.7.0",
    "serve-favicon": "~2.3.0"
  }
}

第三步:nodejs操作mongodb 实现增删改查示例

nodejs和mongodb已经全部安装完毕,所需驱动模板mongodb也已安装,下面开始利用nodejs来操作mongodb吧

3.1.在项目的根目录下新建一个app.js文件实现增加

//引入mongodb模块,获得客户端对象
var MongoClient = require('mongodb').MongoClient;
//连接字符串
var DB_CONN_STR = 'mongodb://localhost:27017/gomall';    

//定义函数表达式,用于操作数据库并返回结果
var insertData = function(db, callback) {  
    //获得指定的集合 
    var collection = db.collection('users');
    //插入数据
    var data = [{_id:7,"name":'rose',"age":21},{_id:8,"name":'mark',"age":22}];
    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("连接成功!");
    //执行插入数据操作,调用自定义方法
    insertData(db, function(result) {
        //显示结果
        console.log(result);
        //关闭数据库
        db.close();
    });
});

运行结果:

连接成功!
{ result: { ok: 1, n: 2 },
  ops: 
   [ { _id: 7, name: 'rose', age: 21 },
     { _id: 8, name: 'mark', age: 22 } ],
  insertedCount: 2,
  insertedIds: [ 7, 8 ] }

3.2 修改操作示例

//引入mongodb模块,获得客户端对象
var MongoClient = require('mongodb').MongoClient;
//连接字符串
var DB_CONN_STR = 'mongodb://localhost:27017/gomall';    

//定义函数表达式,用于操作数据库并返回结果
var updateData = function(db, callback) {  
    //获得指定的集合 
    var collection = db.collection('users');
    //要修改数据的条件,>=10岁的用户
    var  where={age:{"$gte":10}};
    //要修改的结果
    var set={$set:{age:95}};
    collection.updateMany(where,set, function(err, result) { 
        //如果存在错误
        if(err)
        {
            console.log('Error:'+ err);
            return;
        } 
        //调用传入的回调方法,将操作结果返回
        callback(result);
    });
}

3.3 查询示例


//引入mongodb模块,获得客户端对象
var MongoClient = require('mongodb').MongoClient;
//连接字符串
var DB_CONN_STR = 'mongodb://localhost:27017/gomall';    

//定义函数表达式,用于操作数据库并返回结果
var findData = function(db, callback) {  
    //获得指定的集合 
    var collection = db.collection('users');
    //要查询数据的条件,<=10岁的用户
    var  where={age:{"$lte":10}};
    //要显示的字段
    var set={name:1,age:1};
    collection.find(where,set).toArray(function(err, result) { 
        //如果存在错误
        if(err)
        {
            console.log('Error:'+ err);
            return;
        } 
        //调用传入的回调方法,将操作结果返回
        callback(result);
    });
}

//使用客户端连接数据,并指定完成时的回调方法
MongoClient.connect(DB_CONN_STR, function(err, db) {
    console.log("连接成功!");
    //执行插入数据操作,调用自定义方法
    findData(db, function(result) {
        //显示结果
        console.log(result);
        //关闭数据库
        db.close();
    });
});

3.4删除示例

//引入mongodb模块,获得客户端对象
var MongoClient = require('mongodb').MongoClient;
//连接字符串
var DB_CONN_STR = 'mongodb://localhost:27017/gomall';    

//定义函数表达式,用于操作数据库并返回结果
var findData = function(db, callback) {  
    //获得指定的集合 
    var collection = db.collection('users');
    //要删除数据的条件,_id>2的用户删除
    var  where={_id:{"$gt":2}};
    collection.remove(where,function(err, result) { 
        //如果存在错误
        if(err)
        {
            console.log('Error:'+ err);
            return;
        } 
        //调用传入的回调方法,将操作结果返回
        callback(result);
    });
}

//使用客户端连接数据,并指定完成时的回调方法
MongoClient.connect(DB_CONN_STR, function(err, db) {
    console.log("连接成功!");
    //执行插入数据操作,调用自定义方法
    findData(db, function(result) {
        //显示结果
        console.log(result);
        //关闭数据库
        db.close();
    });
});

打赏

已有1人打赏

最代码官方的gravatar头像
最近浏览
孟陆同学  LV7 2018年3月20日
Evil_dong  LV4 2018年3月7日
上世纪风景  LV11 2018年1月12日
zyl  LV34 2018年1月8日
KimOHHH  LV5 2018年1月3日
jeremygilbert  LV21 2017年12月26日
yikong  LV8 2017年12月21日
hjy100200  LV6 2017年12月20日
水心木支  LV4 2017年12月18日
tianlin1995  LV3 2017年12月17日
顶部 客服 微信二维码 底部
>扫描二维码关注最代码为好友扫描二维码关注最代码为好友