使用koa+react+sequelize搭建博客系统，这篇文章讲述koa+sequelize的开发过程。支持增删改查等功能。
代码放到了github：https://github.com/liangchaofei/cms上，可以直接下载运行
先看下系统界面
koa使用狼叔提供的koa-generate脚手架工具。
安装koa-generate
npm install -g koa-generator
建立项目并初始化
koa cms_blog cd cms_blog npm install
安装成功后项目目录如下：
运行并在浏览器打开:即可
npm run dev
开始项目搭建：采用MVC模式
- 在根目录下创建controllers,modules,schema,config文件夹
- controllers:写控制逻辑部分
- modules：写sql部分
- schema：写数据表部分
- config：写数据库配置部分
数据库用nodejs的ORM数据库：Sequelize
- 在config目录下创建db.js，配置数据库
const Sequelize = require(&#;sequelize&#;)
const sequelize = new Sequelize(&#;koa&#;,&#;root&#;,&#;&#;,{
host:&#;localhost&#;,
dialect:&#;mysql&#;,
operatorsAliases:false,
dialectOptions:{
//字符集
charset:&#;utf8mb4&#;,
collate:&#;utf8mb4_unicode_ci&#;,
supportBigNumbers: true,
bigNumberStrings: true
},
pool:{
max: 5,
min: 0,
acquire: ,
idle:
},
timezone: &#;+:&#; //东八时区
})
module.exports = {
sequelize
}
- 创建一个文章表article
名称类型长度主键idint11truetitlevarchar255falseauthorevarchar255falsecontentvarchar255falsecreatedAtdatetime0falseupdatedAtdatetime0false
- 在schema文件夹下创建article.js
const blog = (sequelize, DataTypes) => {
return sequelize.define(&#;blog&#;,{
id:{
type:DataTypes.INTEGER,
primaryKey:true,
allowNull:true,
autoIncrement:true
},
title: {
type: DataTypes.STRING,
allowNull: false,
field: &#;title&#;
},
author: {
type: DataTypes.STRING,
allowNull: false,
field: &#;author&#;
},
content: {
type: DataTypes.STRING,
allowNull: false,
field: &#;content&#;
},
createdAt:{
type:DataTypes.DATE
},
updatedAt:{
type:DataTypes.DATE
}
},{
/**
* 如果为true，则表示名称和model相同，即user
* 如果为fasle，mysql创建的表名称会是复数，即users
* 如果指定的表名称本身就是复数，则形式不变
*/
freezeTableName: false
})
}
module.exports = blog
数据库部分配置好后，开始接口开发，采用restful api模式
get请求：数据查询
- 在routes目录下创建article.js
const router = require(&#;koa-router&#;)() // 使用koa-router 来指定接口路由 const BlogControll = require(&#;../controllers/blog&#;) // 引入Control部分 // 使用router.get 提供get请求 router.get(&#;/blog&#;, BlogControll.getAllBlog)
- 在controllers目录下创建article.js
const BlogModel = require(&#;../modules/blog&#;) // 引入model
static async getAllBlog(ctx) {
const { query } = ctx.request; // 获取前端传来的参数
try {
let data = await BlogModel.getAllBlog(query) // 获取查询的数据
ctx.response.status = ;
ctx.body = {
code: ,
msg: &#;success&#;,
data,
count: data.length
}
} catch (err) {
ctx.response.status = ;
ctx.body = {
code: ,
msg: &#;error&#;,
err,
}
}
}
- 在modules目录下创建article.js
const db = require(&#;../config/db&#;) // 引入数据库配置
const Sequelize = db.sequelize; // 使用sequelize
const Blog = Sequelize.import(&#;../schema/blog.js&#;)
Blog.sync({force: false})
static async getAllBlog(query){
// 通过使用sequelize 的findAll 来查询数据
// 根据query参数实现查询关键词功能
return await Blog.findAll({
where: {
...query
},
order:[
[&#;id&#;,&#;DESC&#;]
],
})
}
- 至此一个get请求的接口就写好了，运行npm run dev，打开浏览器运行http://:/api/v1/blog 就可以看到数据了。
- 可以在后台系统中查看
post请求：数据添加
- 在routes/article.js
router.post(&#;/blog&#;, BlogControll.addBlog)
- 在controllers/article.js
static async addBlog(ctx) {
let req = ctx.request.body;
if (req.title && req.author && req.content) {
try {
let data = await BlogModel.addBlog(req)
ctx.response.status =
ctx.body = {
code: ,
msg: &#;success&#;,
data
}
} catch (err) {
ctx.response.status =
ctx.body = {
code: ,
msg: &#;error&#;,
err
}
}
} else {
ctx.response.status =
ctx.body = {
code: ,
msg: &#;参数不全&#;,
}
}
}
- 在module/article.js
static async addBlog(data){
return await Blog.create({
title: data.title,
author: data.author,
content: data.content,
})
}
- 至此添加文章接口就写好了，可以在后台系统添加
delete请求：删除文章
- 在routes/article.js
router.delete(&#;/blog/:id&#;,BlogControll.deleteBlog)
- 在controllers/article.js
static async deleteBlog(ctx) {
let id = ctx.params.id; // 根据id删除
if (id) {
try {
let data = await BlogModel.deleteBlogs(id)
ctx.response.status = ;
ctx.body = {
code: ,
msg: &#;success&#;,
}
} catch (err) {
ctx.response.status = ;
ctx.body = {
code: ,
msg: &#;err&#;,
err
}
}
} else {
ctx.response.status = ;
ctx.body = {
code: ,
msg: &#;缺少id&#;,
}
}
}
- 在module/article.js
static async deleteBlogs(id){
return await Blog.destroy({
where:{
id
}
})
}
- 至此删除文章接口就写好了，可以在后台系统删除
put请求：编辑文章
- 在routes/article.js
router.put(&#;/blog&#;, BlogControll.updateBlog)
- 在controllers/article.js
static async updateBlog(ctx) {
let req = ctx.request.body;
try {
let data = await BlogModel.updateBlog(req)
ctx.response.status = ;
ctx.body = {
code: ,
msg: &#;success&#;,
}
} catch (err) {
ctx.response.status = ;
ctx.body = {
code: ,
msg: &#;error&#;,
err
}
}
}
- 在module/article.js
static async updateBlog(data){
const {id,title,author,content} = data;
console.log(&#;id&#;,id)
return await Blog.update(
{
title,
author,
content,
id
},
{
where:{
id
}
}
)
}
- 至此更新文章接口就写好了，可以在后台系统更新
总结：以上通过koa+sequelize实现了增删改查的接口。代码放到了github：https://github.com/liangchaofei/cms上，可以直接下载运行。如果这篇文章对您有帮助，感谢star