MongoDB在nodejs中的應用---小小留言本
阿新 • • 發佈:2018-12-24
最近在學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打星星啦。