使用Koa和Node.js实现简单的CRUD API

本示例通过Koa和Node.js实现了一个简单的CRUD API接口，包括对MongoDB数据库进行CRUD操作，其中包含了对post请求体进行解析和错误处理等功能。

const Koa = require('koa');
const Router = require('koa-router');
const bodyParser = require('koa-bodyparser');
const { MongoClient, ObjectId } = require('mongodb');

const app = new Koa();
const router = new Router();
const dbUrl = 'mongodb://localhost:27017';
const dbName = 'demo';
const client = new MongoClient(dbUrl);

app.use(bodyParser());

router.get('/api/users', async (ctx) => {
  const { limit, skip } = ctx.query;
  const db = client.db(dbName);
  const users = await db.collection('users').find().sort({ _id: -1 }).limit(+limit).skip(+skip).toArray();
  ctx.body = users;
});

router.get('/api/users/:id', async (ctx) => {
  const { id } = ctx.params;
  const db = client.db(dbName);
  const user = await db.collection('users').findOne({ _id: ObjectId(id) });
  ctx.body = user;
});

router.post('/api/users', async (ctx) => {
  const db = client.db(dbName);
  const result = await db.collection('users').insertOne(ctx.request.body);
  ctx.body = result.insertedId;
});

router.put('/api/users/:id', async (ctx) => {
  const { id } = ctx.params;
  const db = client.db(dbName);
  const result = await db.collection('users').updateOne({ _id: ObjectId(id) }, { $set: ctx.request.body });
  ctx.body = result.modifiedCount;
});

router.delete('/api/users/:id', async (ctx) => {
  const { id } = ctx.params;
  const db = client.db(dbName);
  const result = await db.collection('users').deleteOne({ _id: ObjectId(id) });
  ctx.body = result.deletedCount;
});

app.use(router.routes());

client.connect().then(() => {
  app.listen(3000, () => console.log(`Server started on http://localhost:3000`));
});

免责申明：文章和图片全部来源于公开网络，如有侵权，请通知删除 server@dude6.com