1. 程式人生 > >MongoDB在nodejs中的應用---小小留言本

MongoDB在nodejs中的應用---小小留言本

最近在學node跟MongoDB,覺得MongoDB對前端開發者來說真的很友好,沒有什麼SQL語句,寫法也跟js很相像,並且json格式傳輸資料,資料沒有任何結構化的限制,API詳細。
mongoDB的api

mac環境安裝MongoDB

由於官網的下載十分繁瑣,又要註冊又要幹嘛的,所以我們直接採取brew這個工具進行安裝

安裝brew工具  開啟控制檯
/usr/bin/ruby -e "$(curl -fsSL https://raw.githubusercontent.com/Homebrew/install/master/install)"
使用brew 安裝MongoDB
brew install mongodb
安裝完成後控制檯直接輸入 mongo看執行情況 

這裡寫圖片描述

至此我們的電腦就可以使用mongoDB了,shell語法我就不過多介紹,官方API寫得很詳細,介紹一個開機命令mongod
本地開發的時候,需要mongoDB一直處於開機狀態,新開啟一個控制檯視窗。

//更改資料來源的存放路徑 
mongod --path "路徑" 
//輸入完成後保持控制檯視窗的開啟狀態

封裝MongoDB API 的db.js (增刪改查)

// 封裝所有對資料庫的常用操作
// 不管資料庫的什麼操作都要先連結資料庫
var MongoClient = require("mongodb").MongoClient;
const url = "mongodb://localhost:27017"
;//本地資料庫URL const dbname = "test" //要操作的資料庫名稱 function _connectDB(cb){//連結資料庫 MongoClient.connect(url,function(err,db){ cb(err,db) }) } // 插入一條資料 exports.insertOne = function(collectionName,jsonData){//collectionName 集合名 jsonData 插入的json物件 // 注意:無論成功還是失敗操作完成後都要關閉資料庫 var p = new Promise(function(resolve, reject)
{
//使用promise來處理回撥 _connectDB(function(err,db){//資料庫連結完成後進行操作 if(err){ reject(err); db.close(); } db.db(dbname).collection(collectionName).insertOne(jsonData,function(err,result){ if(err){ reject(err); db.close(); } resolve(result) db.close(); }) }); }) return p; } // 查詢所有匹配資料 (遍歷列表) exports.findAll = function(collectionName,data){ //若data什麼都不傳則代表查全部 var data = data || { page:0, size:0, params:{} }; var result = []; var cursor; //定義查詢遊標 var p = new Promise(function(resolve, reject){ _connectDB(function(err,db){ if(err){ reject(err); db.close(); } /* 老版本寫法 利用遊標遍歷 新版本可以直接生成一個數組 cursor = db.db(dbname).collection(collectionName).find(data.params).limit(data.size).skip((data.page-1)*data.size); // skip 表示從第幾條開始數 cursor.each(function(err,doc){ if(err){ reject(err); } if(doc != null){ result.push(doc) }else{ resolve(result) } }) */ // 分頁 通過limit(一頁顯示多少條) 跟skip( 跳過多少條資料) 來處理(代表從第幾頁開始查詢) // skip 0 limit 0 代表查所有 result = db.db(dbname).collection(collectionName).find(data.params).limit(data.size).skip((data.page-1)*data.size).toArray(); resolve(result); db.close(); }); }) return p; } // 刪除所有資料 exports.delectMany = function(collectionName,jsonData){ var p = new Promise(function(resolve, reject){ _connectDB(function(err,db){ if(err){ reject(err); db.close(); } //該方法會刪除所有的匹配項 db.db(dbname).collection(collectionName).deleteMany(jsonData,function(err,result){ if(err){ reject(err); db.close(); } resolve(result) db.close(); }) }); }) return p; } // 修改資料 exports.updateMany = function(collectionName,oldJson,newJson){//oldJson條件 newJson 修改成什麼 var p = new Promise(function(resolve, reject){ _connectDB(function(err,db){ if(err){ reject(err); db.close(); } var params = {$set:newJson}; db.db(dbname).collection(collectionName).updateMany(oldJson,params,function(err,result){ if(err){ reject(err); db.close(); } resolve(result) db.close(); }) }); }) return p; }

express 搭一個伺服器

var express = require("express");
var app = express();
var db = require("./model/db.js");
var MongoClient = require("mongodb").MongoClient;//引入mongo
var bodyParser = require("body-parser");//用於處理post請求的外掛
//解析application/x-www-form-urlencoded 請求 並將傳遞的引數返回到req.body裡
app.use(bodyParser.urlencoded({extended:false}));
app.set("view engine","ejs");//使用ejs模板引擎
//此命令代表 使用者訪問"/"路徑 即首頁時,先查詢資料來源,然後將資料來源渲染
app.get("/",function(req,res){  
  db.findAll("txt").then(function(data){
    res.render("index",{
      list:data
    });
  }).catch(function(err){
    res.send("查詢失敗")
  })
})
//提供查詢介面 以json格式返回資料
app.get("/find",function(req,res){
    //若什麼都不傳則預設不分頁
  var params = {
    page:req.query.page || 0,
    size:req.query.size || 0,
    params:{}
  }
  db.findAll("txt",params).then(function(result){
    //result 為查詢成功返回的陣列
    res.json({
      "code":0,
      "data":result
    })
  }).catch(function(err){
    res.json({
      "code":-1,
      "message":"查詢失敗"
    })
  })
})
//提供新增資料介面 傳遞完整的 json物件{"user":xxx,"content":xxx};
app.post("/add",function(req,res){
  // console.log();
  var params = req.body
  db.insertOne("txt",params).then(function(result){
    res.json({
      "code":0,
      "message":"新增成功"
    })
  }).catch(function(err){
    res.json({
      "code":-1,
      "message":"插入失敗"
    })
  })

})
//提供刪除介面 傳遞user引數即可
app.post("/del",function(req,res){
  var params = req.body
  db.delectMany("txt",params).then(function(result){
    res.json({
      "code":0,
      "message":"刪除成功"
    })
  }).catch(function(err){
    res.json({
      "code":-1,
      "message":"刪除失敗"
    })
  })
})
//提供修改介面  傳遞user引數 跟content引數 user引數供查詢,content引數供修改
app.post("/update",function(req,res){
  var oldJson = {
    "user":req.body.user
  };
  var newJson ={
    "content":req.body.content
  }
  db.updateMany("txt",oldJson,newJson).then(function(result){
    res.json({
      "code":0,
      "message":"修改成功"
    })
  }).catch(function(err){
    res.json({
      "code":-1,
      "message":"修改失敗"
    })
  })
})
//監聽 127.0.0.1:8012路徑
app.listen(8012,"127.0.0.1",function(){
  console.log("伺服器已啟動,地址為127.0.0.1:8012")
})

資料表結構如下:
這裡寫圖片描述

至於前端,可通過ajax可直接掉介面,我不再過多贅述,希望大家多多支援,覺得好的話,GitHub打星星啦。