快捷導(dǎo)航

Node.js的Mongodb使用實(shí)例

更新時(shí)間：2016年12月30日 11:57:15 作者：Lovec

本篇文章主要介紹了Node.js的Mongodb使用實(shí)例，具有一定的參考價(jià)值，有興趣的可以了解一下。

安裝mongodb模塊 npm install --save mongodb

數(shù)據(jù)庫(kù)連接

var MongoClient = require('mongodb').MongoClient;
var assert = require('assert');

//連接test數(shù)據(jù)庫(kù)
var url = 'mongodb://localhost:27017/test';
MongoClient.connect(url, (err,db) => {
 assert.equal(null,err);
 console.log('連接成功');
 db.close();
});

插入數(shù)據(jù)

插入一個(gè)文檔對(duì)象

var MongoClient = require('mongodb').MongoClient;
var assert = require('assert');

//test數(shù)據(jù)庫(kù)的路徑
var url = 'mongodb://localhost:27017/test';

//插入文檔
var insertDocument = (db,callback) => {
 //在test庫(kù)下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)（如果沒(méi)有callback函數(shù)，本身返回一個(gè)Promise對(duì)象）

簡(jiǎn)單的insertMany操作

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

MongoClient.connect('mongodb://localhost:27017/test',(err, db) => {
 var blog = db.collection('blog');
 //新增兩個(gè)文檔對(duì)象
 blog.insertMany([{name:"shen"},{name:"fzq"}],(err,r) => {
  test.equal(null,err);
  //回調(diào)函數(shù)中返回的r為執(zhí)行完插入操作的對(duì)象，insertedCount屬性為已經(jīng)插入的對(duì)象個(gè)數(shù)
  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();
 });
});

因?yàn)閙ongodb和nodejs都是異步io的機(jī)制，所有幾乎所有耗時(shí)的操作都是以回調(diào)函數(shù)的方式完成。但是因?yàn)榛卣{(diào)函數(shù)的層次嵌套，一段代碼后面可能會(huì)跟上一大段的 });，隨著層級(jí)的增加，代碼變得不易理解和維護(hù)。所有在使用MongoDB時(shí)，推薦用Promise的方式來(lái)解決回調(diào)嵌套的問(wèn)題。

從上面的代碼可以看出，insertMany([obj...])返回一個(gè)Promise對(duì)象，我們用.then((r)=>{})接收正常的回調(diào)值，用.catch((err) => {})來(lái)抓取異常。

使用生成器（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();
});

單個(gè)文檔插入：insertOne(doc,options,callback)（如果沒(méi)有callback函數(shù)，本身返回一個(gè)Promise對(duì)象）

簡(jiǎn)單的插入操作

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是指固定大小的集合，新元素插入后會(huì)覆蓋掉舊的元素，保持整個(gè)集合的大小不變。

//在命令行中輸入mongo
//創(chuàng)建一個(gè)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});
}
//查詢文檔個(gè)數(shù)
db.myCappedCollection.count()
//實(shí)際只有18個(gè)文檔id為983-1000 即新元素覆蓋了舊元素

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: