快捷導(dǎo)航

Node.js連接mongodb實例代碼

更新時間：2017年06月06日 08:43:12 作者：wolfy

這篇文章主要介紹了Node.js連接mongodb實例代碼，這里整理了詳細的代碼，具有一定的參考價值，感興趣的小伙伴們可以參考一下

前面介紹了node.js操作mysql以及redis的內(nèi)容，這里繼續(xù)學(xué)習(xí)操作mongodb的內(nèi)容。

安裝驅(qū)動

安裝命令

cnpm install mongodb

安裝成功

數(shù)據(jù)庫操作

因為mongodb是文檔類型的數(shù)據(jù)庫，與mysql有很大不同，mongodb會自動創(chuàng)建數(shù)據(jù)庫和集合，并不需要提前進行手動創(chuàng)建。

Insert

var MongoClient = require("mongodb").MongoClient;
var DB_CONN_STR = "mongodb://sa:sa@localhost:27017/test_db";
var insertData = function (db, callback) {
  //連接數(shù)據(jù)表my_firsrt_collection
  var collection = db.collection("my_firsrt_collection");
  var data = [{ "name": "wolfy1", "age": 20 }, { "name": "wolfy2", "age": 20 }]
  collection.insert(data, function (err, result) {
    if (err) {
      console.log("error:" + err);
      return;
    };
    callback(result);
  });
};
 MongoClient.connect(DB_CONN_STR, function (err, db) {
    if (err) {
      console.log("連接失?。? + err);
      return;
    };
    console.log("連接成功");
    insertData(db,function(result){
      console.log(result);
      db.close();
    });
  });

結(jié)果

查詢數(shù)據(jù)

var MongoClient = require("mongodb").MongoClient;
var DB_CONN_STR = "mongodb://sa:sa@localhost:27017/test_db";
 //查詢 var queryData = function (db, callback) { //連接數(shù)據(jù)表my_firsrt_collection 
var collection = db.collection("my_firsrt_collection"); //查詢條件 var where = { "name": "wolfy1" };
 collection.find(where).toArray(function (err, result) { if (err) { console.log("error:" + err); return; }; 
callback(result); }); };
 MongoClient.connect(DB_CONN_STR, function (err, db) { 
if (err) {
 console.log("連接失敗：" + err);
 return; 
}; 
console.log("連接成功");
 queryData(db, function (result) { console.log(result); db.close(); }); });

結(jié)果

更新數(shù)據(jù)

var MongoClient = require("mongodb").MongoClient;
var DB_CONN_STR = "mongodb://sa:sa@localhost:27017/test_db";
//查詢
var updateData = function (db, callback) {
  //連接數(shù)據(jù)表my_firsrt_collection
  var collection = db.collection("my_firsrt_collection");
  //查詢條件
  var where = { "name": "wolfy1" };
  var updateStr={$set:{"address":"http://www.cnblogs.com/wolf-sun/"}};
  collection.update(where,updateStr,function (err, result) {
    if (err) {
      console.log("error:" + err);
      return;
    };
    callback(result);
  });
};
MongoClient.connect(DB_CONN_STR, function (err, db) {
  if (err) {
    console.log("連接失?。? + err);
    return;
  };
  console.log("連接成功");
  updateData(db, function (result) {
    console.log(result);
    db.close();
  });
});

結(jié)果

刪除數(shù)據(jù)

var MongoClient = require("mongodb").MongoClient;
var DB_CONN_STR = "mongodb://sa:sa@localhost:27017/test_db";
//刪除
var deleteData = function (db, callback) {
  //連接數(shù)據(jù)表my_firsrt_collection
  var collection = db.collection("my_firsrt_collection");
  //查詢條件
  var where = { "name": "wolfy1" };
  collection.remove(where, function (err, result) {
    if (err) {
      console.log("error:" + err);
      return;
    };
    callback(result);
  });
};
MongoClient.connect(DB_CONN_STR, function (err, db) {
  if (err) {
    console.log("連接失敗：" + err);
    return;
  };
  console.log("連接成功");
  deleteData(db, function (result) {
    console.log(result);
    db.close();
  });
});

結(jié)果