最近在学node跟MongoDB，觉得MongoDB对前端开发者来说真的很友好，没有什么SQL语句，写法也跟js很相像，并且json格式传输数据，数据没有任何结构化的限制，API详细。
附 mongoDB的api
demo 小展示
这里写图片描述
项目源码 ：https://github.com/lc941015/littleTXT
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 "路径"
//输入完成后保持控制台窗口的打开状态
参考：http://www.mongoing.com/docs/tutorial/install-mongodb-on-os-x.html
封装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打星星啦。
