Nodejs请教一个查询MongoDB报错问题

Nodejs请教一个查询MongoDB报错问题

Status.get = function get(query, callback) {
mongodb.open(function(err, db) {
if(err) {
return callback(err);
}
db.collection(‘Status’, function(err, collection) {
if(err) {
mongodb.close();
return callback(err);
}
collection.aggregate({$match:query}, {$group:{_id:"$result", cnt:{$sum:1}}}, function(err, docs) {
mongodb.close();
console.log(docs);  //此处没问题，输出的是一个object，其实是个数组
callback(null, docs);  //只要有这句话就报错TypeError, number if not a function
});
});
});
};

请问这个错误到底是什么造成的，现在无法返回查询结果。


4 回复

根据你提供的代码片段，你的问题是由于在调用 collection.aggregate 方法时传递的参数不正确。aggregate 方法需要一个包含多个聚合阶段的数组作为参数，而不是单独的阶段。此外，你需要确保在回调函数中正确处理错误和响应。

以下是修正后的代码：

Status.get = function get(query, callback) {
    mongodb.open(function(err, db) {
        if (err) {
            return callback(err);
        }
        db.collection('Status', function(err, collection) {
            if (err) {
                db.close(); // 应该使用 db.close() 而不是 mongodb.close()
                return callback(err);
            }
            collection.aggregate([
                { $match: query },
                { $group: { _id: "$result", cnt: { $sum: 1 } } }
            ], function(err, docs) {
                db.close();
                if (err) {
                    return callback(err);
                }
                console.log(docs);
                callback(null, docs);
            });
        });
    });
};

解释：

  1. 参数传递：aggregate 方法需要一个包含多个聚合阶段的数组。将 { $match: query } 和 { $group: { _id: "$result", cnt: { $sum: 1 } } } 放在一个数组中。
  2. 错误处理：在 callback 中添加了对 err 的检查，以确保在出现错误时能够正确地传递错误信息。
  3. 数据库关闭：确保在所有操作完成后关闭数据库连接。这里使用 db.close() 而不是 mongodb.close()。

示例查询：

假设你想查询 Status 集合中的文档，并按 result 字段分组并计数：

Status.get({ field: "value" }, function(err, result) {
    if (err) {
        console.error("Error:", err);
        return;
    }
    console.log("Result:", result);
});

这样修改后，你应该能够正确地执行聚合查询并返回结果，而不会遇到 TypeError。


是不是callback有问题？

是的，就是callback的问题，但是我不知道哪里出了问题。o(╯□╰)o

根据你提供的代码片段，错误提示 TypeError: number is not a function 很有可能是由于 MongoDB 聚合操作中的语法错误所导致的。在 MongoDB 的聚合框架中，多个阶段应该放在一个数组中，而不是单独传递。

以下是修正后的代码示例：

Status.get = function get(query, callback) {
    mongodb.open(function(err, db) {
        if (err) { 
            return callback(err); 
        }

        db.collection('Status', function(err, collection) {
            if (err) {
                db.close();  // 应该使用 close 方法而非 mongodb.close()
                return callback(err);
            }

            collection.aggregate([
                { $match: query },
                { $group: { _id: "$result", cnt: { $sum: 1 } } }
            ], function(err, docs) {
                db.close();
                if (err) {
                    return callback(err);
                }
                console.log(docs);  
                callback(null, docs);
            });
        });
    });
};

关键修改点：

  1. 聚合管道格式：将 $match 和 $group 放在一个数组中，表示它们是聚合操作的不同阶段。
  2. 关闭数据库连接：应调用 db.close() 而不是 mongodb.close() 来关闭数据库连接。
  3. 错误处理：在 callback 中增加错误检查逻辑以确保只在没有错误时返回数据。

通过这些调整，你的代码应该能够正确地执行 MongoDB 的聚合查询，并返回查询结果。

回到顶部