搭建koa连接mongoose数据库并进行操作

mongoose数据库
1.新建文件夹
2.npm init （package.json）
3.npm i node(node包)
4.安装 koa koa-router mongoose koa-body(解析复杂数据请求)
5.新建一个app.js

const Koa = require('koa')
const Router = require('koa-router')//路由
const mongoose = require('mongoose')//数据库
const koaBody =require('koa-body')

// 实例化koa Router
const app = new Koa()
const router = new Router()

// 连接数据库
const db=require('./config').mongodb
mongoose.connect(db,{ useNewUrlParser: true ,useUnifiedTopology:true},(res)=>{
    console.log('连接上了');
},(err)=>{
    console.log(err);
})
// 引入api文件(先把这两个给注释掉，现在用不到)
//const user=require('./router/api/users')
//router.use('/api',user)
// 简单配置路由
router.get('/',async ctx=>{
    ctx.body="hello koa"
})
// 接收post参数解析
app.use(koaBody({multipart:true}))
app.use(router.routes(),router.allowedMethods())
 
const port=3000//端口号

app.listen(port,()=>{
    console.log('正在监听端口',port);
})

6.创建config.js(这里写的是从mongoose数据库复制的)

module.exports={
    mongodb:'mongodb+srv://<name>:<password>@cluster0.1mwgh.mongodb.net/listArr?retryWrites=true&w=majority'
}

就能运行koa会返回连接成功

image.png

这里进行的就是操作数据库了

7.创建router/api/user.js

const Router= require('koa-router')
const router = new Router()
// 引入规则
const User = require('../../models/user')

router.post('/addlist', async ctx=>{
    const newUser=new User({
        name:ctx.request.body.name,
        price:ctx.request.body.price,
        introduce:ctx.request.body.introduce,
    })
    //存到数据库
    await newUser.save().then((res) => {
        ctx.body=newUser
    }).catch((err) => {
        console.log(err);
    })
})

module.exports=router.routes()

8.创建models/user.js(这个是我们王数据库里面添加数据的规则)

const mongoose = require('mongoose')
const Schema = mongoose.Schema
const userShema= new Schema({  //type:是数据类型，require:true为必填
    name:{type:String,require:true},
    price:{type:String,require:true},
    introduce:{type:String,require:true},
    date:{type:Date,default:Date.now}//每次添加成功当前的时间
})

module.exports=mongoose.model('user',userShema)

这个时候就可以把app.js中引入api文件给解除注释

// 引入api文件
const user=require('./router/api/users')
router.use('/api',user)

就能进行数据添加了