前一段时间在学nodeJS
nodeJS对于前端人员有着很重要的意义
nodeJS让前端能够变成全栈
当然，我突然来学这个只是听说node开发很快
平时写后台一直用PHP，但是我对PHP的框架研究少，JS才是我的最爱
言归正传
这篇文章主要讲的是
1.mongodb的简单设置
2.koa2项目初始化
3.koa2-router来控制路由
4.mongodb的简单操作
5.通过接口实现增删改查
一、mongodb的安装
安装比较简单
下载之后一直下一步就好了
安装完成之后，我们需要配置数据库
我是在D盘的mongodb目录下 新建一个 data/db
这里面就是放数据文件了
然后 我们需要指定 日志文件位置
D:mongodb/data/log/mongodb.log
然后用命令指定位置
mongod --dbpath "D:mongodb\data\db" --logpath "D:\mongodb\data\log\mongodb.log"
最后用重新运行下
建议下载一个robo3T可视化操作工具，这样操作数据会方便很多
2.koa2项目初始化
首先当然是
npm init
产生一个 pack.json文件了
然后安装koa2,koa-router,mongoose
npm install --save koa koa-router mongoose
然后根目录下新建一个app.js作为入口文件
在这个文件里，我们引用一些常用的模块，同时是作为服务启动文件
我这里安装了，bluebird（promise支持），koa-logger（日志）,koa-session(session),koa-bodyparser(处理请求)
'use strict'
var fs = require('fs')
var path = require('path')
var mongoose = require('mongoose')
var db = 'mongodb://127.0.0.1:27017'
mongoose.Promise = require('bluebird')
mongoose.connect(db)
var koa = require('koa')
var logger = require('koa-logger')
var router = require('koa-router')
var session = require('koa-session')
var bodyParser = require('koa-bodyparser')
var app = new koa();
app.keys = ['imooc']
app.use(logger())
app.use(session(app))
app.use(bodyParser())
var router = require('./config/router')()
app.use(router.routes())
.use(router.allowedMethods())
app.listen(1234)
console.log("Listening 1234")
然后我们新建一个app文件夹和一个config文件夹
config下面放router.js
app里面放controller和models文件
我们在controller下新建一个 user.js
models下新建一个user.js 和counter.js
特别说明下 counter.js用来控制表的id自增。因为mongodb是没有mysql这样的自增字段的
router.js
prefix是给所以的路由加前缀
'use strict'
var Router = require('koa-router')
var User = require('../app/controller/user')
module.exports = function(){
var router = new Router({
prefix:'/api'
})
router.post('/u/adduser',User.addUser)
router.post('/u/delete',User.delete)
router.post('/u/edit',User.edit)
router.post('/u/getusers',User.findAll)
router.post('/signatrue',App.signature)
return router
}
controller下的user.js
'use strict'
const Koa = require('koa');
const app = new Koa();
const bodyParser = require('koa-bodyparser');
//自动解析参数
app.use(bodyParser());
require('../models/user')
require('../models/counter')
var xss = require('xss')
var mongoose = require('mongoose')
mongoose.connect('mongodb://root:root1234@localhost:27017/test?authSource=admin')
var User = mongoose.model('User')
var Counter = mongoose.model('Counter')
exports.addUser = async(ctx)=>{
var userid =await getNextSequenceValue("userid").then(async(data)=>{
let postData= ctx.request.body;
var user = new User({
userid:data,
nickname: postData.nickname,
avatar: postData.avatar,
phoneNumber: xss(postData.phoneNumber)
})
user = user.save()
}).then(function(){
ctx.body = {
success:true
}
})
}
exports.delete = async(ctx)=>{
let postData= ctx.request.body;
let id = postData.userid
let flag
await User.remove({userid:id}, function (err) {
console.log(err)
if (err) {
flag = false
} else {
flag = true
}
});
ctx.body = {
success: flag
}
}
exports.edit = async(ctx)=>{
let postData= ctx.request.body;
let id = postData.userid
let user = await User.update({userid: id}, {
$set: {
nickname: 1231
}
})
ctx.body = {
success: user
}
}
exports.findAll = async(ctx)=>{
let user = await User.find()
ctx.body = {
success:user
}
}
function getNextSequenceValue(sequenceName){
return new Promise((resolve,reject)=>{
var sequenceDocument = Counter.findOneAndUpdate(
sequenceName,
{$inc:{sequence_value:1}},
).exec(function(err,data){
resolve(data.sequence_value);
});
})
}
models/counter.js
这个文件每次把id更新+1来达到自增
'use strict'
var mongoose = require('mongoose')
var CounterSchema = new mongoose.Schema({
id:String,
sequence_value:Number
})
module.exports = mongoose.model('Counter',CounterSchema)
models/user.js
'use strict'
var mongoose = require('mongoose')
var UserSchema = new mongoose.Schema({
userid:String,
phoneNumber:{
unique:true,
type:String
},
areaCode:String,
verifyCode:String,
accessToken:String,
nickname:String,
gender:String,
breed:String,
age:String,
avatar:String,
meta:{
createAt:{
type:Date,
dafault:Date.now()
},
updateAt:{
type:Date,
dafault:Date.now()
},
}
})
module.exports = mongoose.model('User',UserSchema)
这些方法都只能通过ajax访问，目前没有用静态文件来发送请求
推荐一个RESTClient浏览器插件
可以填写地址和参数调用接口，来测试我们的接口是否写的正确
太忙了，先写这么多吧
