Fastify集成MongoDB：数据未存储与认证失败问题求助

问题一：无认证MongoDB下接口异常 #

现象 #

• GET /books 返回 {"_events":{},"_eventsCount":0}
• POST /books 返回 {"message":"book added"}，但未返回预期的insertId，数据未实际存储且无报错

原因 #

1. GET接口：find()方法返回的是MongoDB的游标对象，无法直接被Fastify序列化为JSON，仅会序列化游标内部的事件属性，导致返回异常结果。
2. POST接口：
   • 错误使用了result.insertId字段，MongoDB insertOne操作返回结果中的插入ID字段实际为insertedId。
   • 未等待Fastify的MongoDB插件注册完成就启动服务，导致数据库连接未就绪，操作未实际执行。

解决步骤 #

1. 修复GET接口：将游标转换为可序列化的数组，使用toArray()方法：

   fastify.get('/books', async(request, reply) => {
       const books = await fastify.mongo.db
           .collection('books')
           .find()
           .toArray();
   
       reply.send(books);
   });
   

2. 修复POST接口：修正插入ID的字段名：

   fastify.post('/books', async(request, reply) => {
       const result = await fastify
           .mongo.db
           .collection('books')
           .insertOne(request.body);
   
       reply.send({
           message: 'book added',
           id: result.insertedId
       });
   });
   

3. 确保数据库连接就绪：使用异步启动方式，等待插件注册完成后再启动服务：

   const fastify = require('fastify')({logger: true});
   
   async function start() {
       await fastify.register(require('@fastify/mongodb'), {
           forceClose: true,
           url: 'mongodb://localhost:27017/library'
       });
   
       // 定义所有路由...
   
       await fastify.listen({port: 3000});
   }
   
   start().catch(err => {
       fastify.log.error(err);
       process.exit(1);
   });
   

问题二：Docker Compose带认证MongoDB连接失败 #

现象 #

• 未修改连接URL时，接口返回认证错误：command insert requires authentication
• 修改URL为mongodb://root:example@localhost:27017/library后，出现MongoServerError: Authentication failed

原因 #

MongoDB的root用户是在admin数据库下创建的，默认连接时会使用当前指定的数据库（library）进行认证，但root用户并不存在于library数据库中，导致认证失败。

解决步骤 #

方案一：指定认证数据库（快速解决）

在连接URL中添加authSource=admin参数，明确告诉MongoDB使用admin数据库进行认证：

fastify.register(require('@fastify/mongodb'), {
    forceClose: true,
    url: 'mongodb://root:example@localhost:27017/library?authSource=admin'
});

方案二：创建数据库专用用户（更安全）

1. 进入MongoDB容器：

   docker exec -it <容器名或容器ID> mongosh -u root -p example --authenticationDatabase admin
   

2. 切换到library数据库并创建专用用户：

   use library;
   db.createUser({
       user: "library_user",
       pwd: "your_secure_password",
       roles: [{ role: "readWrite", db: "library" }]
   });
   

3. 修改Fastify的连接URL为专用用户信息：

   fastify.register(require('@fastify/mongodb'), {
       forceClose: true,
       url: 'mongodb://library_user:your_secure_password@localhost:27017/library'
   });
   

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