如何快速将Koa.js后端与MongoDB进行连接？

当然有，最常用且简便的方式是借助Mongoose（MongoDB的ODM对象文档映射工具），它能大幅简化数据库操作；也可以直接使用MongoDB官方原生驱动，下面分别给出两种方案的实现步骤：

方案一：使用Mongoose（推荐） #

1. 安装依赖 #

在项目根目录执行命令：

npm install koa mongoose

2. 编写数据库连接模块 #

创建db.js文件，封装连接逻辑：

const mongoose = require('mongoose');

async function connectDB() {
  try {
    // 替换成你的MongoDB连接字符串，本地默认格式为 mongodb://localhost:27017/你的数据库名
    await mongoose.connect('mongodb://localhost:27017/koa-mongo-demo');
    console.log('✅ MongoDB连接成功');
  } catch (err) {
    console.error('❌ MongoDB连接失败:', err.message);
    process.exit(1); // 连接失败时退出进程，避免服务异常运行
  }
}

module.exports = connectDB;

3. 在Koa入口文件中启动连接 #

修改app.js（你的Koa入口文件）：

const Koa = require('koa');
const connectDB = require('./db');

const app = new Koa();

// 先连接数据库，再启动Koa服务
(async () => {
  await connectDB();
  app.listen(3000, () => {
    console.log('🚀 Koa服务运行在 http://localhost:3000');
  });
})();

4. 快速使用示例（创建模型与路由） #

创建models/User.js定义数据模型：

const mongoose = require('mongoose');

const userSchema = new mongoose.Schema({
  name: { type: String, required: true },
  email: { type: String, required: true, unique: true },
  age: Number
});

module.exports = mongoose.model('User', userSchema);

安装koa-router并编写路由（可选）：

npm install koa-router

在app.js中添加路由逻辑：

const Router = require('koa-router');
const User = require('./models/User');

const router = new Router();

// 获取所有用户
router.get('/users', async ctx => {
  const users = await User.find();
  ctx.body = users;
});

// 创建新用户
router.post('/users', async ctx => {
  const newUser = new User(ctx.request.body);
  await newUser.save();
  ctx.body = { message: '用户创建成功', data: newUser };
});

app.use(router.routes());
app.use(router.allowedMethods());

方案二：使用MongoDB原生驱动 #

如果不想依赖Mongoose，直接用官方原生驱动也很简单：

1. 安装依赖 #

npm install koa mongodb

2. 连接与使用示例 #

修改app.js：

const Koa = require('koa');
const { MongoClient } = require('mongodb');

const app = new Koa();
let dbInstance; // 存储数据库实例，方便全局调用

async function connectDB() {
  const client = new MongoClient('mongodb://localhost:27017');
  await client.connect();
  dbInstance = client.db('koa-mongo-demo');
  console.log('✅ MongoDB连接成功');
}

// 启动服务
(async () => {
  await connectDB();
  app.listen(3000, () => {
    console.log('🚀 Koa服务运行在 http://localhost:3000');
  });
})();

// 简单路由示例
const router = new (require('koa-router'))();

router.get('/users', async ctx => {
  const users = await dbInstance.collection('users').find().toArray();
  ctx.body = users;
});

app.use(router.routes());

内容的提问来源于stack exchange，提问作者Thivanka Saparamadu