[Node.js]连接mongodb

 

 

摘要

前面介绍了node.js操作mysql以及redis的内容，这里继续学习操作mongodb的内容。

安装驱动

安装命令

cnpm install mongodb

安装成功

数据库操作

 因为mongodb是文档类型的数据库，与mysql有很大不同，mongodb会自动创建数据库和集合，并不需要提前进行手动创建。

Insert

var MongoClient = require("mongodb").MongoClient;
var DB_CONN_STR = "mongodb://sa:sa@localhost:27017/test_db";
var insertData = function (db, callback) {
   //连接数据表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();
       });
   });

结果

查询数据

var MongoClient = require("mongodb").MongoClient;

var DB_CONN_STR = "mongodb://sa:sa@localhost:27017/test_db";
  //查询 var queryData = function (db, callback) 
{ 
//连接数据表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();
             });
         });
结果

结果

更新数据

var MongoClient = require("mongodb").MongoClient;
var DB_CONN_STR = "mongodb://sa:sa@localhost:27017/test_db";
//查询
var updateData = function (db, callback) {
   //连接数据表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();
   });
});

结果

删除数据

var MongoClient = require("mongodb").MongoClient;
var DB_CONN_STR = "mongodb://sa:sa@localhost:27017/test_db";
//删除
  var deleteData = function (db, callback) {
    //连接数据表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();
   });
});

结果