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

单个文档插入：insertone(doc,options,callback)（如果没有callback函数，本身返回一个promise对象）

简单的插入操作

var mongoclient = require('mongodb').mongoclient,
 test = require('assert');
mongoclient.connect('mongodb://localhost:27017/test',(err,db)=>{
 var blog = db.collection('blog');
 blog.insertone({name:"xiaos"},(err,r) => {
  test.equal(null,err);
  test.equal(1,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.insertone({name:"xiaos"}).then((r)=>{
  test.equal(1,r.insertedcount);
  db.close();
 });
});

使用生成器的插入操作

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.insertone({name:"xiaosbb"});
 test.equal(1,r.insertedcount);
 db.close();
});

mapreduce(map,reduce,options,callback) return promise if no callback

var mongoclient = require('mongodb').mongoclient,
 test = require('assert');

mongoclient.connect()

iscapped(callback) return promise if no callback

var mongoclient = require('mongodb').mongoclient,
 test = require('assert');
mongoclient.connect('mongodb://localhost:27017/test',(err,db) => {
 db.createcollection('newblog',{'capped':true,'size':1024},(err,collection) => {
  test.equal('newblog',collection.collectionname);  
  collection.iscapped((err,capped) => {
   test.equal(true,capped);
   db.close();
  });
 });
});

capped collection是指固定大小的集合，新元素插入后会覆盖掉旧的元素，保持整个集合的大小不变。

//在命令行中输入mongo
//创建一个1024大小的mycappedcollection集合
db.createcollection('mycappedcollection',{'capped':true,'size':1024});
//插入1000条记录
for (var i = 1;i <= 1000;i++){
 db.mycappedcollection.save({id:i,name:'xiaos'+i});
}
//查询文档个数
db.mycappedcollection.count()
//实际只有18个文档id为983-1000 即新元素覆盖了旧元素

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。