2. 程式人生 > >node.js對mongodb的連接&增刪改查（附async同步流程控制）

node.js對mongodb的連接&增刪改查（附async同步流程控制）

阿新 • • 發佈：2017-12-21
color var literal int lba node () n! node.js

1.啟動mongodb數據庫

官網下載mongodb數據庫

在mongodb根目錄下創建文件夾：假設取名為test。
我們認為test就是mongodb新建的數據庫一枚。

創建批處理文件 xxx.bat，內容如下：

運行e盤mongodb文件夾下bin目錄下的 mongod.exe，參數為
-dbpath E:\mongodb\test。

E:\mongodb\bin\mongod.exe -dbpath E:\mongodb\test

這樣就啟動了mongodb下test數據庫的服務器。

2.加載mongodb模塊

在我們的node.js項目中直接npm入mongodb模塊

npm install mongodb --save


3.依賴mongodb模塊

在想要寫對mongodb的增刪改查邏輯的js文件下加入以下依賴

var mongo = require("mongodb");

4.通用小函數

寫了幾個通用的小函數，最後創建一個對象，將函數全都掛到對象上，最後把對象exports出去即可。

/**
 * 創建數據庫服務器並開發名為databaseName的數據庫
 * @param host ip
 * @param port 端口
 * @param databaseName
 * @return  打開失敗返回-1 ，成功返回database
 */
function openDatabase(host,port,databaseName){
    //創建數據庫所在的服務器
    var server = new mongo.Server(host, port, {auto_reconnect: true});
    var db = new mongo.Db(databaseName, server, {safe: true});
    db.open(function (err, db) {
        if (err) {
            console.log(‘打開數據庫失敗‘);
            return -1;
        }
        else {
            console.log(‘打開數據庫成功‘);

        }

    });
    return db;
}
/**
 * 連接數據集合
 * @param db 數據庫
 * @param collectionName 數據集合名稱
 * @return 成功返回collection，失敗返回-1
 */
function openCollection(db,collectionName){
    db.collection(collectionName,{safe:true},function(errcollection,collection){
        if(!errcollection){
            console.log(‘連接數據集合成功‘);
            return collection;

        }else{
            console.log(‘連接數集合失敗‘);
            return -1;
        }
    });


}
/**
 * 插入數據
 * @param collection
 * @param tmp 要插入的數據
 * @return 成功返回collection，失敗返回-1
 */
function insertCollection(collection,tmp){
    //var tmp = {username:‘hello‘,password:1};
    collection.insert(tmp,{safe:true},function(err, result){
        if(err){
            console.log(‘傳入數據集合失敗‘+tmp);
            return -1;
        }else {
            console.log(‘插入數據集合成功‘+result);

        }
    });
    return collection;
}
/**
 * 查詢數據集合 沒有條件
 * @param collection
 * @return 成功返回查詢到的數據集合內容，失敗返回-1
 */
function findCollectionNoCondition(collection){
    collection.find().toArray(function(errfind,cols){
        if(!errfind){
            console.log(‘查詢數據集合成功‘+JSON.stringify(cols));
            return JSON.stringify(cols);
        }else {
            console.log(‘查詢數據集合失敗‘);
            return -1;
        }
    });
}
/**
 * 查詢數據集合 有條件
 * @param collection
 * @return 成功返回查詢到的數據集合內容，失敗返回-1
 */
function findCollectionHasCondition(collection,tmp){
    collection.find(tmp).toArray(function(errfind,cols){
        if(!errfind){
            console.log(‘查詢數據集合成功‘+JSON.stringify(cols));
            return JSON.stringify(cols);
        }else {
            console.log(‘查詢數據集合失敗‘);
            return -1;
        }
    });
}
/**
 * 刪除數據集合
 * @param collection
 * @param tmp
 * @return 成功返回數據集合，失敗返回-1
 */
function removeCollection(collection,tmp){
    //var tmp = {username:‘hello‘,password:1};
    collection.remove(tmp,{safe:true},function(err, count){
        if(err){
            console.log(‘刪除數據集合失敗‘+tmp);
            return -1;
        }else {
            console.log(‘刪除數據集合成功‘+count);
            return collection;
        }
    });
}



5.async模塊解決node.js異步架構下同步邏輯的實現

看到《超實用的node.js代碼段》這本書上，講到Node.js是異步I/O驅動，所以在我們順序運行上面的幾個函數的時候，一定會遇到一個問題：如果前面de函數耗時長，那麽後面的函數不會等前面的函數運行完，而是直接運行。但是我的前一個函數的運行結果是要被後一個函數使用的呀。

這時候就需要在異步I/O下進行串行控制流控制。

書中介紹了async模塊，手續愛你第三方引入。

npm install async --save
  • 1

require進來

var async=require("async");
  • 1

使用方法：
Nodejs異步流程控制Async

我這裏使用的是waterfall瀑布模式流程控制
github waterfall機制使用demo

然後我就天真的使用了

 //使用async瀑布模型流程控制執行 數據庫的連接查詢
    async.waterfall([
        function(callback){
            var db;
            db=user.openDatabase("localhost",27017,"test");
            callback(null,db);
        },
        function(db,callback){
            var collection;
            if(db!=-1){
                collection=user.openCollection(db,‘users‘);
            }
            callback(null,collection);
        },
        function(collection,callback){
            var res;
            if(collection!=-1){
                res=user.findCollectionNoCondition(collection);
                console.log(res);
                callback(null,3);
            }
        }
    ],function(err,result){
        console.log("async瀑布模型流程控制執行成功"+result);
    })
結果還是第二個函數先於第一個函數運行成功，導致第三個函數不能正確運行。

**********************************************************************
一、使用模塊Q的promise機制實現數據庫操作的同步問題

1.install

npm install q --save

2.require

var Q=require(‘q‘);

3.重寫數據庫CRUD操作方法

/**
 * 創建數據庫服務器並開發名為databaseName的數據庫
 * @param host ip
 * @param port 端口
 * @param databaseName
 * @return  打開失敗返回-1 ，成功返回database
 */
function openDatabase(host,port,databaseName,collectionName){
    //創建數據庫所在的服務器

    var deferred = Q.defer();
    var server = new mongo.Server(host, port, {auto_reconnect: true});
    var db = new mongo.Db(databaseName, server, {safe: true});
    db.open(function (err, db) {
        if (err) {
            console.log(‘打開數據庫失敗‘);
            deferred.reject(err);
        }
        else {
            console.log(‘打開數據庫成功‘);
            deferred.resolve([db,collectionName]);

        }

    });
    return deferred.promise;
}
/**
 * 連接數據集合
 * @param db 數據庫
 * @param collectionName 數據集合名稱
 * @return 成功返回collection，失敗返回-1
 */
function openCollection(db,collectionName){
    var deferred = Q.defer();
    db.collection(collectionName,{safe:true},function(errcollection,collection){
        if(!errcollection){
            console.log(‘連接數據集合成功‘);
            deferred.resolve(collection);

        }else{

            console.log(‘連接數集合失敗‘);
            deferred.reject(errcollection);
        }
    });
    return deferred.promise;

}
/**
 * 插入數據
 * @param collection
 * @param tmp 要插入的數據
 * @return 成功返回collection，失敗返回-1
 */
function insertCollection(collection,tmp){
    //var tmp = {username:‘hello‘,password:1};
    collection.insert(tmp,{safe:true},function(err, result){
        if(err){
            console.log(‘傳入數據集合失敗‘+tmp);
            return -1;
        }else {
            console.log(‘插入數據集合成功‘+result);

        }
    });
    return collection;
}
/**
 * 查詢數據集合 沒有條件
 * @param collection
 * @return 成功返回查詢到的數據集合內容，失敗返回-1
 */
function findCollectionNoCondition(collection){
    var deferred = Q.defer();
    collection.find().toArray(function(errfind,cols){
        if(!errfind){
            console.log(‘查詢數據集合成功‘+JSON.stringify(cols));
            deferred.resolve(JSON.stringify(cols));
        }else {
            console.log(‘查詢數據集合失敗‘);
            deferred.reject(errfind);
        }
    });

    return deferred.promise;
}
/**
 * 查詢數據集合 有條件
 * @param collection
 * @return 成功返回查詢到的數據集合內容，失敗返回-1
 */
function findCollectionHasCondition(collection,tmp){
    collection.find(tmp).toArray(function(errfind,cols){
        if(!errfind){
            console.log(‘查詢數據集合成功‘+JSON.stringify(cols));
            return JSON.stringify(cols);
        }else {
            console.log(‘查詢數據集合失敗‘);
            return -1;
        }
    });
}
/**
 * 刪除數據集合
 * @param collection
 * @param tmp
 * @return 成功返回數據集合，失敗返回-1
 */
function removeCollection(collection,tmp){
    //var tmp = {username:‘hello‘,password:1};
    collection.remove(tmp,{safe:true},function(err, count){
        if(err){
            console.log(‘刪除數據集合失敗‘+tmp);
            return -1;
        }else {
            console.log(‘刪除數據集合成功‘+count);
            return collection;
        }
    });
}

裏面的關鍵點是：

  • 定義defered對象var deferred = Q.defer();
  • 定義函數成功執行的resolve對象deferred.resolve(JSON.stringify(cols));
  • 定義函數成功失敗的error對象 deferred.reject(errfind);
  • 最後返回一個新的promise對象，用來return deferred.promise;

4.鏈式調用

  user.openDatabase("localhost",27017,"test","users")
        .then(function(data){
            return user.openCollection(data[0],data[1])
        })
        .then(user.findCollectionNoCondition)
        .done(function(data){
            console.log(‘promise執行成功‘);
        },function(err){
           console.log("promise執行失敗:"+err);
        });

5.log打印結果

GET / 304 55.922 ms - -
打開數據庫成功
連接數據集合成功
GET /stylesheets/style.css 304 6.048 ms - -
查詢數據集合成功[{"_id":"57731d3a239f75379769ce31","username":"liuchen","password":"12345"},{"_id":"577328ab5c8d6cf43b3e214d","username":"hello","password":1},{"_id":"577331f35c8d6cf43b3e214e","username":"hello","password":1},{"_id":"57733bf400a7090c35122844","username":"hello","password":1},{"_id":"57733c0300a7090c35122845","username":"hello","password":1},{"_id":"57733c0af8d7813443d51c27","username":"hello","password":1}]
promise執行成功
















node.js對mongodb的連接&增刪改查（附async同步流程控制）

相關推薦

node.js對mongodb的連接&增刪改查（附async同步流程控制）

color var literal int lba node () n! node.js 1.啟動mongodb數據庫 官網下載mongodb數據庫 在mongodb根目錄下創建文件夾：假設取名為test。 我們認為test就是mongodb新建的數據庫一枚。 創建批處理文

node.js對mongodb的連線&增刪改查（附async同步流程控制）

最近嘗試了node.js和mongodb的使用。下面來一波步驟。 1.啟動mongodb資料庫 官網下載mongodb資料庫 在mongodb根目錄下建立資料夾：假設取名為test。 我們認為test就是mongodb新建的資料庫一枚。 建立批處理

java 連接mysql增刪改查

isp gif 數據庫驅動 java 語句 select name nal cti 1、創建mysql測試表 2、按下圖創建3個文件夾與3個類 3、三個類的代碼 PersionDao ：目錄(Data Access Object), 數據訪

python3連接mysql--增刪改查

cut varchar erro .exe bsp back roo 這一 rom ps:MYSQLdb只適用於python2.x python3不支持MYSQLdb,取而代之的是pymysql 運行會報：ImportError：No module named ‘MYSQL

tp3後臺文章的增刪改查（帶縮圖上傳）

增 模型 <?php namespace Admin\Model; use Think\Model; class ArticleModel extends Model { protected $_validate = array( array('ar_title',

MySQL資料庫學習筆記（十一）----DAO設計模式實現資料庫的增刪改查（進一步封裝JDBC工具類）

系列文章並非本人原創。 在這裡我想討論的一個問題是：在PersonDaoImpl這個實現類中，我們可以看到 public void add(Person p) throws SQLException { 26 Connection conn

SpringMVC增刪改查（附原始碼，新手學SpringMVC最好的辦法就是自己寫一套增刪改查）

最近在自學SpringMVC，有Spring的基礎，但不是很深，僅存在於表面。當前在手書籍有《SpringMVC學習指南》 個人認為學習一種MVC框架時，當入了個門之後可以自己寫一套增刪改查，這樣可以

使用CoreData進行資料增刪改查（附Demo）

       本文主要介紹簡單CoreData的使用，從建立工程到進行資料的增刪改查，關於CoreData中的名詞解釋什麼的不做過多介紹。        首先，建立一個CoreData工程，在建立工程的選項處勾選Use CoreData，建立成功後，會在AppDelegat

thinkphp5 文章基本的增刪改查（包含圖片上傳功能）

控制器 <?php namespace app\admin\controller; use app\admin\controller\Base; use think\Db; use app\admin\model\Article as ArticleModel;

DAO設計模式實現資料庫的增刪改查（進一步封裝JDBC工具類）

一、DAO模式簡介 DAO即Data Access Object，資料訪問介面。資料訪問：故名思義就是與資料庫打交道。夾在業務邏輯與資料庫資源中間。 DAO模式實際上是兩個模式的組合，即Data Accessor (資料訪問者)模式和 Active Domain Ob

使用 Spring Boot 搭建一套增刪改查（無多余代碼）

param tar rim project posit 編輯 word lec char 前言 這是我學習 Spring Boot 的第三篇文章，終於可以見到效果了。錯過的同學可以看看之前的文章 我們為什麽要學習 Spring Boot Spring Boot

Node.js對MongoDB進行增刪改查操作

osql document 更新 courses 大量數據 connected func ret gen MongoDB簡介 MongoDB是一個開源的、文檔型的NoSQL數據庫程序。MongoDB將數據存儲在類似JSON的文檔中，操作起來更靈活方便。NoSQL數據庫中的

node.js中mysql連接池的使用

lease package lba ref table mysql mod select something https://cnodejs.org/topic/58378543bde2b59e06141f5a 起初的做法是創建一個連接然後使用，後來發現一段時間後會出現

Javaweb實現對mongodb的增刪改查（附帶源代碼）

bubuko 增刪 web .com image ODB htm ava read 運行截圖： 刪除後的信息 項目源代碼：https://www.cnblogs.com/post/readauth?url=/zyt-bg/p/9807396.html

vue實現對表格數據的增刪改查

bsp bin targe blank umeng com ref tps bing http://www.cnblogs.com/xumengxuan/p/7144580.html 原文地址:　https://www.xiabingbao.com/vue/2017/0

Mongodb基本操作入門,增刪改查和索引

less multi zhang 一個 attribute var sin 第一個 base 主要進程 mongod.exe為啟動數據庫實例的進程。 mongo是一個與mongod進程進行交互的JavaScript shell進程，它提供了一些交互的接口函數用戶

MongoDB基本操作1增刪改查篇

ODB 終端 方法 copy 文件中 一定的 dir 過濾 man mongoDB邏輯存結構 MongoDB的邏輯只要由文檔(document) 集合(collection) 數據庫(database)三部分組成。 其中文檔的是MongoDB核心概念，它是MongoDB邏輯

python連線MongoDB資料庫方法及增刪改查等操作小結。

Y9   建議安裝MongoDB視覺化工具“Robo 3T”，可以很直觀的看到對MongoDB操作後的資料。 1、‘Robo 3T’的安裝，網上很多途徑可下載，在此分享我使用的版本： 連結：https://pan.baidu.com/s/1EcjmUVkXz1GQeTXy2fMk

Zookeeper JavaAPI對節點進行增刪改查（詳細步驟）

import java.io.IOException; import java.util.List; import org.apache.zookeeper.CreateMode; import org.apache.zookeeper.KeeperException; import org.ap

純JavaScript寫一個對錶格的簡單增刪改查操作

功能:     新增表格資料，   修改表格資料，  刪除表格資料。 不完善區:  刪除資料之後序號沒有做處理 ，表單驗證簡單的提示警告， 沒有文字提醒。 介面: 線上檢視 下面是程式碼: