nodejs操作mongodb的填刪改查模塊的制作及引入實(shí)例

發(fā)布時(shí)間：2020-09-07 12:44:02 來源：腳本之家閱讀：163 作者：專注前端30年欄目：web開發(fā)

安裝相關(guān)模塊

如果使用這個(gè)的話，你需要先自己安裝一下他需要的模塊，在根目錄輸入

npm install mongodb --save

進(jìn)行模塊安裝，安裝成功以后就可以進(jìn)行以下的步驟。

文件的引入

以下是我書寫的相關(guān)代碼，放到你可以引用的相關(guān)目錄，本人放到了express的根目錄

function Mongo(options) {
 this.settings = {
  url: 'mongodb://localhost:27017/jk',
  MongoClient:require('mongodb').MongoClient,
  assert:require('assert')
 };
 for(let i in options){
  this.settings[i] = options[i];
 }
 this._run = function (fun) {
  let that = this;
  let settings = this.settings;
  this.settings.MongoClient.connect(this.settings.url, function (err, db) {
   settings.assert.equal(null, err);
   console.log("Connected correctly to server");
   fun(db, function () {
    db.close();
   });
  });
 };
 this.insert = function (collectionName, data, func) {
  //增加數(shù)據(jù)
  let insertDocuments = function (db, callback) {
   let collection = db.collection(collectionName);
   collection.insertMany([
    data
   ], function (err, result) {
    if (!err) {
     func(true);
    } else {
     func(false);
    }
    callback(result);
   });
  };
  this._run(insertDocuments);
 };
 this.update = function (collectionName, updateData, data, func) {
  //更新數(shù)據(jù)
  let updateDocument = function (db, callback) {
   let collection = db.collection(collectionName);
   collection.updateOne(updateData
    , {$set: data}, function (err, result) {
     if (!err) {
      func(true);
     } else {
      func(false);
     }
     callback(result);
    });
  };
  this._run(updateDocument);
 };
 this.delete = function (collectionName, data, func) {
  //刪除數(shù)據(jù)
  let deleteDocument = function (db, callback) {
   let collection = db.collection(collectionName);
   collection.deleteOne(data, function (err, result) {
    if (!err) {
     func(true);
    } else {
     func(false);
    }
    callback(result);
   });
  };
  this._run(deleteDocument);
 };
 this.find = function (collectionName, data, func) {
  //查找數(shù)據(jù)
  let findDocuments = function (db, callback) {
   // Get the documents collection
   let collection = db.collection(collectionName);
   // Find some documents
   collection.find(data).toArray(function (err, docs) {
    if (!err) {
     func(true,docs);
    }
    else {
     func(false, err);
    }
    callback(docs);
   });
  };
  this._run(findDocuments);
 };
}
module.exports = Mongo;

我存入到了一個(gè)名字叫server.js的文件名內(nèi)

使用

我們?cè)谛枰褂庙撁嫦葘⒛K引入，比如我在路由文件index.js里面引入：

const Server = require("../server.js");

然后需要實(shí)例化對(duì)象，如下：

let server = new Server();

如果需要配置相關(guān)信息，可以在實(shí)例化的時(shí)候傳入一個(gè)對(duì)象配置，可以配置數(shù)據(jù)庫的地址：

let server = new Server({url:"mongodb://localhost:27017/mydb"});

里面封裝了四個(gè)方法，添刪改查，分別是

添加方法

server.insert(數(shù)據(jù)表名,需要插入的數(shù)據(jù)（鍵值對(duì)的對(duì)象）,回調(diào)函數(shù));

更新方法

server.update(數(shù)據(jù)表名,查詢的數(shù)據(jù)（對(duì)象）,更新的數(shù)據(jù)（對(duì)象）,回調(diào)函數(shù));

刪除方法

server.delete(數(shù)據(jù)表名,查詢的數(shù)據(jù)（對(duì)象）,回調(diào)函數(shù));

查找方法

server.find(數(shù)據(jù)表名,查詢的數(shù)據(jù)（對(duì)象）,回調(diào)函數(shù));

回調(diào)函數(shù)都會(huì)返回兩個(gè)值，第一個(gè)布爾類型，是否處理成功，第二個(gè)值，查找返回查找到的個(gè)數(shù)，別的都返回處理成功的個(gè)數(shù)（現(xiàn)在一次只處理一條）

使用案例

比如我需要在一個(gè)路由里面查找數(shù)據(jù)，我就需要這樣：

server.find("users",{username:"username"},function (bool,data) {
  if(bool){
   console.log("查詢到數(shù)據(jù)為"+data.length+"條");
  }
  else{
   console.log(data);
  }
 });
});

上面的代碼是查詢了users表里面username為username的字段的數(shù)據(jù)，如果成功，后面data就會(huì)返回一個(gè)數(shù)組，如果出現(xiàn)錯(cuò)誤，就直接返回data錯(cuò)誤。

以上這篇nodejs操作mongodb的填刪改查模塊的制作及引入實(shí)例就是小編分享給大家的全部?jī)?nèi)容了，希望能給大家一個(gè)參考，也希望大家多多支持億速云。

向AI問一下細(xì)節(jié)

nodejs操作mongodb的填刪改查模塊的制作及引入實(shí)例

猜你喜歡

最新資訊

相關(guān)推薦

相關(guān)標(biāo)簽