欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Node.js的Mongodb使用實例

 更新時間:2016年12月30日 11:57:15   作者:Lovec  
本篇文章主要介紹了Node.js的Mongodb使用實例,具有一定的參考價值,有興趣的可以了解一下。

安裝mongodb模塊 npm install --save mongodb

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

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

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

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

插入一個文檔對象

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

//test數(shù)據(jù)庫的路徑
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函數(shù),本身返回一個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);
  //回調(diào)函數(shù)中返回的r為執(zhí)行完插入操作的對象,insertedCount屬性為已經(jīng)插入的對象個數(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();
 });
});

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

 從上面的代碼可以看出,insertMany([obj...])返回一個Promise對象,我們用.then((r)=>{})接收正常的回調(diào)值,用.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函數(shù),本身返回一個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
//創(chuàng)建一個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});
}
//查詢文檔個數(shù)
db.myCappedCollection.count()
//實際只有18個文檔id為983-1000 即新元素覆蓋了舊元素

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

相關(guān)文章

  • Node.js(v16.13.2版本)安裝及環(huán)境配置的圖文教程

    Node.js(v16.13.2版本)安裝及環(huán)境配置的圖文教程

    本文主要介紹了Node.js(v16.13.2版本)安裝及環(huán)境配置的圖文教程,文中通過圖文介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2024-05-05
  • Node.js  REPL (交互式解釋器)實例詳解

    Node.js REPL (交互式解釋器)實例詳解

    這篇文章主要介紹了Node.js REPL (交互式解釋器)實例詳解的相關(guān)資料,Node.js REPL(Read Eval Print Loop:交互式解釋器) 表示一個電腦的環(huán)境,類似 Window 系統(tǒng)的終端,我們可以在終端中輸入命令,并接收系統(tǒng)的響應(yīng),需要的朋友可以參考下
    2017-08-08
  • 利用express啟動一個server服務(wù)的方法

    利用express啟動一個server服務(wù)的方法

    下面小編就為大家?guī)硪黄胑xpress啟動一個server服務(wù)的方法。小編覺得挺不錯的,現(xiàn)在就分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2017-09-09
  • 基于websocket實現(xiàn)簡單聊天室對話

    基于websocket實現(xiàn)簡單聊天室對話

    這篇文章主要為大家詳細(xì)介紹了基于websocket實現(xiàn)簡單聊天室對話,文中示例代碼介紹的非常詳細(xì),具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2021-07-07
  • nodejs express搭建服務(wù)并熱更新文件過程詳解

    nodejs express搭建服務(wù)并熱更新文件過程詳解

    這篇文章主要為大家介紹了nodejs express搭建服務(wù)并熱更新文件過程詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪
    2023-11-11
  • 為nuxt項目寫一個面包屑cli工具實現(xiàn)自動生成頁面與面包屑配置

    為nuxt項目寫一個面包屑cli工具實現(xiàn)自動生成頁面與面包屑配置

    這篇文章主要介紹了為nuxt項目寫一個面包屑cli工具實現(xiàn)自動生成頁面與面包屑配置,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2019-09-09
  • 詳解nodejs微信jssdk后端接口

    詳解nodejs微信jssdk后端接口

    本篇文章主要介紹了詳解nodejs微信jssdk后端接口,小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2017-05-05
  • NODE.JS加密模塊CRYPTO常用方法介紹

    NODE.JS加密模塊CRYPTO常用方法介紹

    這篇文章主要介紹了NODE.JS加密模塊CRYPTO常用方法介紹,需要的朋友可以參考下
    2014-06-06
  • node.js中fs\path\http模塊的使用方法詳解

    node.js中fs\path\http模塊的使用方法詳解

    Node.js是基于Chrome V8引擎的JavaScript的運(yùn)行時(運(yùn)行環(huán)境-宿主環(huán)境),下面這篇文章主要給大家介紹了關(guān)于node.js中fs\path\http模塊的使用方法,需要的朋友可以參考下
    2023-01-01
  • node.js中的events.emitter.once方法使用說明

    node.js中的events.emitter.once方法使用說明

    這篇文章主要介紹了node.js中的events.emitter.once方法使用說明,本文介紹了events.emitter.once的方法說明、語法、接收參數(shù)、使用實例和實現(xiàn)源碼,需要的朋友可以參考下
    2014-12-12

最新評論