node.js連接MongoDB數據庫,db.collection is not a function完美解決


解決方法一、

mongodb數據庫版本回退:

這個錯誤是出在mongodb的庫中,在nodejs里的寫法和命令行中的寫法不一樣,3.0的api已經更新和以前的版本不不一樣,我們在npm中沒指定版本號的安裝就默認安裝的是3.0版本。

可以參考3.0的api文檔:http://mongodb.github.io/node-mongodb-native/3.0/api/

在項目中找到package.json文件,這個文件中記錄着我們項目的信息及引用的模塊,就像我圖片中那樣,我原來是3.1.1版本的,我們找到mongodb將其版本改為2.3.33。

打開命令行在項目根路徑下: npm install,更新一下,我們就可以使用2.3.33版本的mongodb模塊了。

解決方法二、

nodejs連接mongodb新寫法

1、封裝數據庫的增刪改查的操作並向外暴露

module.exports = {

	//插入數據
	insertData : function(db, tableName, insertData, callback) {  
	    //連接到表 dynamic
	    var collection = db.collection(tableName);
	    
	    collection.insert(insertData, function(err, result) { 
        if(err)
        {
          console.log('Error:'+ err);
          return;
        }     
        callback(result);
	    });
	},
	//查詢數據
	selectData : function(db, tableName, whereStr, callback) {  
    //連接到表  
    var collection = db.collection(tableName);
    collection.find(whereStr).toArray(function(err, result) {
	    if(err)
	    {
	      console.log('Error:'+ err);
	      return;
	    }     
	    callback(result);
	  });
	},
	//更新數據
	updateData : function(db, tableName, whereStr, updateStr, callback) {  
    //連接到表  
    var collection = db.collection(tableName);
    
    collection.update(whereStr,updateStr, function(err, result) {
      if(err)
      {
        console.log('Error:'+ err);
        return;
      }     
      callback(result);
    });
  },
  //刪除數據
  delData : function(db, tableName, whereStr, callback) {  
	  //連接到表  
	  var collection = db.collection(tableName);
	  collection.remove(whereStr, function(err, result) {
	    if(err)
	    {
	      console.log('Error:'+ err);
	      return;
	    }     
	    callback(result);
	  });
	}
}

  
2、引入需要的包

let MongoClient = require('mongodb').MongoClient;
//連接字符串
let DB_CONN_STR = 'mongodb://localhost:27017/gomall';  
let database = require("./3.0_actiondb");//3.0_actiondb上述的文件名
let dbName = 'gomall';

//runoob是表的名稱

MongoClient.connect(DB_CONN_STR, function(err, client) {
	    let whereStr = {}
	    console.log("連接成功!" + client);
	    let db = client.db(dbName)
	    database.selectData(db, "runoob", whereStr, function(result) {
	        console.log(result);
  				res.send(JSON.stringify(result));
	        client.close();
	    });
	});

  
總結:建議使用第二中方法,個人認為應該追隨技術的更新,不斷學習,不被社會淘汰。

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM