如何使用MongoDB查询所有匹配指定postID的全部文档

MongoDB Node.js驱动中find()方法返回的是查询游标对象，而非直接的匹配文档集合，直接序列化游标对象返回前端无法得到预期的文档列表。

1. 接口查询逻辑修改 #

在find()调用后追加toArray()方法，将游标转换为实际的文档数组，同时补充异常处理逻辑避免服务异常无响应，修改后的接口代码如下：

app.get('/comments/:id', async (req,res)=>{
    try {
        const db = await connect();
        const id = req.params.id;
        // 调用toArray将查询游标转换为文档数组
        const results = await db.collection('comments').find({postID: id}).toArray();
        res.json(results);
    } catch (err) {
        console.error('评论查询失败:', err);
        res.status(500).json({ error: '查询评论数据失败' });
    }
});

2. 可选：ObjectId类型适配 #

如果你存储的postID是MongoDB默认的ObjectId类型而非字符串，需要先将传入的路由参数转换为ObjectId再查询，否则会出现类型不匹配无结果的问题，修改查询逻辑如下：

// 代码开头引入ObjectId
const { ObjectId } = require('mongodb');

// 查询时做类型转换
const results = await db.collection('comments').find({postID: ObjectId(id)}).toArray();

3. 可选：数据库连接逻辑优化 #

原连接代码存在逻辑冗余问题，在已有数据库实例的情况下，resolve后没有终止逻辑执行，会重复触发client.connect，建议调整：

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

const connection_string = 'mongodb+srv://user:pass@host/myFirstDatabase?retryWrites=true&w=majority';

const client = new MongoClient(connection_string, {
    useNewUrlParser: true,
    useUnifiedTopology: true
});

let db = null

export default () => {
    return new Promise((resolve, reject) =>{
        if (db){
            // 加return避免重复执行后续连接逻辑
            return resolve(db)
        }
        client.connect(err => {
            if(err){
                reject("连接出错: " + err)
            }
            else{
                console.log("连接成功!")
                db = client.db("posts")
                resolve(db)
            }
        });
    })
}; 

内容的提问来源于stack exchange，提问作者Jan Tuđan