摘要：轉(zhuǎn)載先用安裝安裝成功后，繼續(xù)在上面操作創(chuàng)建的庫(kù)和表中操作插入連接到表插入數(shù)據(jù)連接成功查詢連接到表查詢數(shù)據(jù)連接成功修改連接到表更新數(shù)據(jù)連接成功刪除連接到表刪除數(shù)據(jù)連接成功調(diào)用存儲(chǔ)過程存儲(chǔ)過程調(diào)用連接成功

轉(zhuǎn)載：http://forum.foxera.com/mongo...

先用npm安裝mongodb

npm install mongodb

安裝成功后，繼續(xù)在上面操作創(chuàng)建的庫(kù)和表中操作

插入

var MongoClient = require("mongodb").MongoClient;
var DB_CONN_STR = "mongodb://localhost:27017/wilsondb1";    
var insertData = function(db, callback) {  
    //連接到表  
    var collection = db.collection("tb2");
    //插入數(shù)據(jù)
    var data = [{"name":"wilson001","age":21},{"name":"wilson002","age":22}];
    collection.insert(data, function(err, result) { 
        if(err)
        {
            console.log("Error:"+ err);
            return;
        }     
        callback(result);
    });
}
MongoClient.connect(DB_CONN_STR, function(err, db) {
    console.log("連接成功！");
    insertData(db, function(result) {
        console.log(result);
        db.close();
    });
});

查詢

var MongoClient = require("mongodb").MongoClient;
var DB_CONN_STR = "mongodb://localhost:27017/wilsondb1";  
var selectData = function(db, callback) {  
  //連接到表  
  var collection = db.collection("tb2");
  //查詢數(shù)據(jù)
  var whereStr = {"name":"wilson001"};
  collection.find(whereStr).toArray(function(err, result) {
    if(err)
    {
      console.log("Error:"+ err);
      return;
    }     
    callback(result);
  });
}
MongoClient.connect(DB_CONN_STR, function(err, db) {
  console.log("連接成功！");
  selectData(db, function(result) {
    console.log(result);
    db.close();
  });
});

修改

var MongoClient = require("mongodb").MongoClient;
var DB_CONN_STR = "mongodb://localhost:27017/wilsondb1";    
var updateData = function(db, callback) {  
    //連接到表  
    var collection = db.collection("tb2");
    //更新數(shù)據(jù)
    var whereStr = {"name":"wilson001"};
    var updateStr = {$set: { "age" : 100 }};
    collection.update(whereStr,updateStr, function(err, result) {
        if(err)
        {
            console.log("Error:"+ err);
            return;
        }     
        callback(result);
    });
}
MongoClient.connect(DB_CONN_STR, function(err, db) {
    console.log("連接成功！");
    updateData(db, function(result) {
        console.log(result);
        db.close();
    });
});

刪除

var MongoClient = require("mongodb").MongoClient;
var DB_CONN_STR = "mongodb://localhost:27017/wilsondb1";  
var delData = function(db, callback) {  
  //連接到表  
  var collection = db.collection("tb2");
  //刪除數(shù)據(jù)
  var whereStr = {"name":"wilson001"};
  collection.remove(whereStr, function(err, result) {
    if(err)
    {
      console.log("Error:"+ err);
      return;
    }     
    callback(result);
  });
}
MongoClient.connect(DB_CONN_STR, function(err, db) {
  console.log("連接成功！");
  delData(db, function(result) {
    console.log(result);
    db.close();
  });
});

調(diào)用存儲(chǔ)過程

var MongoClient = require("mongodb").MongoClient;
var DB_CONN_STR = "mongodb://localhost:27017/wilsondb1";    
var invokeProcData = function(db, callback) {  
    //存儲(chǔ)過程調(diào)用
    db.eval("get_tb2_count()", function(err, result) { 
        if(err)
        {
            console.log("Error:"+ err);
            return;
        }             
        callback(result);
    });
}
MongoClient.connect(DB_CONN_STR, function(err, db) {
    console.log("連接成功！");
    invokeProcData(db, function(result) {
        console.log(result);
        db.close();
    });
});