Node.js的Mongodb使用实例

安装mongodb模块 npm install --save mongodb

数据库连接

var MongoClient = require('mongodb').MongoClient;var assert = require('assert');//连接test数据库var url = 'mongodb://localhost:27017/test';MongoClient.connect(url, (err,db) => { assert.equal(null,err); console.log('连接成功'); db.close();});

插入数据

插入一个文档对象

var MongoClient = require('mongodb').MongoClient;var assert = require('assert');//test数据库的路径var url = 'mongodb://localhost:27017/test';//插入文档var insertDocument = (db,callback) => { //在test库下blog集合中 新增json文档 db.collection('blog').insertOne({  name:"xiaos",  age:22 }, (err, result) => {  assert.equal(err,null);  console.log('新增文档成功');  callback(); });}; //插入操作MongoClient.connect(url, (err,db) => { assert.equal(null,err); insertDocument(db, ()=>{  db.close(); });});

批量插入操作：insertMany(doc,options,callback)（如果没有callback函数，本身返回一个Promise对象）

简单的insertMany操作

var MongoClient = require('mongodb').MongoClient, test = require('assert');MongoClient.connect('mongodb://localhost:27017/test',(err, db) => { var blog = db.collection('blog'); //新增两个文档对象 blog.insertMany([{name:"shen"},{name:"fzq"}],(err,r) => {  test.equal(null,err);  //回调函数中返回的r为执行完插入操作的对象，insertedCount属性为已经插入的对象个数  test.equal(2,r.insertedCount);  db.close(); });}); 

使用Promise的批量插入操作！

var MongoClient = require('mongodb').MongoClient, test = require('assert');MongoClient.connect('mongodb://localhost:27017/test', (err,db) => { var blog = db.collection('blog'); blog.insertMany([{name:"xiaosGG"},{name:"fzqDD"}]).then((r) => {  test.equal(2,r.insertedCount);  db.close(); });});

因为mongodb和nodejs都是异步io的机制，所有几乎所有耗时的操作都是以回调函数的方式完成。但是因为回调函数的层次嵌套，一段代码后面可能会跟上一大段的 });，随着层级的增加，代码变得不易理解和维护。所有在使用MongoDB时，推荐用Promise的方式来解决回调嵌套的问题。

 从上面的代码可以看出，insertMany([obj...])返回一个Promise对象，我们用.then((r)=>{})接收正常的回调值，用.catch((err) => {})来抓取异常。

使用生成器（Generator）的批量插入操作

var MongoClient = require('mongodb').MongoClient, test = require('assert'), co = require('co'); co(function*(){ var db = yield MongoClient.connect('mongodb://localhost:27017/test'); var blog = db.collection('blog'); var r = yield blog.insertMany([{name:"xiaosBB"},{name:"fzqMM"}]); test.equal(2,r.insertedCount); db.close();});