koa如何连接MongoDB

淡淡的烟草味﹌ 2023-01-17 03:12 146阅读 0赞

这个方法，node，express，koa连接MongoDB都是一样的方法，我们利用mongoose模块来连接

注意我的版本

这是我的目录

这个方法，node，express，koa连接MongoDB都是一样的方法，我们利用mongoose模块来连接

我的安装的依赖版本：

"dependencies": {
       "koa": "^2.6.2",
       "mongoose": "^5.3.12",
     }`

## 1.连接MongoDB ##

// db/db.js
    const mongoose = require('mongoose')
    
    const DB_URL = 'mongodb://localhost:27017/test'
    
    mongoose.connect(DB_URL)
    
    mongoose.connection.on('connected',function() {
       console.log('Mongoose connection open to '+DB_URL);
    });
    /**
    * 连接异常 error 数据库连接错误
    */
    mongoose.connection.on('error',function(err) {
      console.log('Mongoose connection error: '+ err);
    });
    /**
    * 连接断开 disconnected 连接异常断开
    */
    mongoose.connection.on('disconnected',function() {
      console.log('Mongoose connection disconnected');
    });
    
    module.exports = mongoose

## 2.设置需要操作的集合 ##

// db/index.js
    const mongoose = require('./db')
    const Schema = mongoose.Schema;
    
    const ceshiSchema = new Schema({
      name: String
    });
    
    const MyModel = mongoose.model('user', ceshiSchema);
    
    
    class Mongodb {
      constructor () {
    
      }
    // 查询
      query () {
         return new Promise((resolve, reject) => {
           MyModel.find({}, (err, res) => {
             if(err) {
               reject(err)
             }
             resolve(res)
           })
         })
      }
    // 保存
      save (obj) {
         const m = new MyModel(obj)
         return new Promise((resolve, reject)=> {
           m.save((err, res) => {
             if (err) {
               reject(err)
             }
             resolve(res)
             console.log(res)
           })
         })
         
      }
    }
    module.exports = new Mongodb()

这里就简单举例了查询和保存方法，还是其他方法，可以具体去看文档

## 3.设置服务器 ##

// index.js
    const Koa = require('koa')
    const ModelDb = require('./db')
    
    const app =  new Koa()
    
    // app.use(async (ctx) => {
    //   let data = await ModelDb.save({"name": "hahah"})
      
    //  ctx.body = "99999"
     
    // })
    
    
    app.use(async (ctx) => {
         let data = await ModelDb.query()
    
        ctx.body = data
        
    })
    
    
    app.listen(3000)
    
    console.log(`listening on port ${3000}`)

## 4.启动服务器 ##

打开浏览器，就可以看的查询出来的结果

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NpbmF0XzE3Nzc1OTk3_size_16_color_FFFFFF_t_70][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NpbmF0XzE3Nzc1OTk3_size_16_color_FFFFFF_t_70 1][]

注意：前提在ceshi结合要有文档，也就是要有数据

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NpbmF0XzE3Nzc1OTk3_size_16_color_FFFFFF_t_70]: /images/20221022/661fed93a15240ae96e4b2c3bc407f2f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NpbmF0XzE3Nzc1OTk3_size_16_color_FFFFFF_t_70 1]: /images/20221022/a2f317b683a1476cadab636a9f684862.png