Node.js MongoDB客户端：集合存在校验与创建插入异常问题

问题总结 #

• 集合存在性校验逻辑失效
• 创建集合后程序卡住，无法继续执行
• 指定集合的默认数据无法插入

问题根源分析 #

1. 重复集合名与异步流程错误：初始化数组重复添加collection1，且async.each回调处理不规范，未正确捕获错误，导致异步流程阻塞。
2. 存在性校验逻辑错误：原校验代码被注释，且错误地在校验通过后调用db.close()，提前关闭连接导致后续操作无法执行。
3. 未定义变量与语法错误：插入数据时使用的data变量未定义，同时代码存在括号不匹配、代码块未闭合等语法问题，导致逻辑无法正常执行。

修复后的代码实现 #

连接函数（修正后） #

const { MongoClient } = require("mongodb");
const async = require("async");
const uri = process.env.MONGODB_URL || "mongodb://127.0.0.1:27017";

const client = new MongoClient(uri);

const onConnect = async function (callback) {
    console.log('Connecting to MongoDB...');
    try {
        await client.connect();
        const db = client.db('mydb');
        console.log('Connected to MongoDB successfully');
        callback(null, db);
    } catch (err) {
        callback(err);
    }
}

初始化函数（修正后） #

// 定义要插入的默认数据
const defaultCollection1Data = {
    name: "Default Entry",
    createdAt: new Date()
};

exports.initialize = function(callback) {
    // 去重后的集合列表，避免重复创建
    const collections = [
        "collection1"
    ];

    onConnect(function(err, db) {
        if (err) {
            return callback(err);
        }

        // 正确校验集合是否存在
        db.listCollections({ name: "collection1" }).toArray(function(err, collectionsList) {
            if (err) {
                return callback(err);
            }

            // 集合已存在则直接结束初始化
            if (collectionsList.length > 0) {
                console.log("collection1 已存在，无需初始化");
                client.close();
                return callback(null);
            }

            // 批量创建集合并插入默认数据
            async.each(collections, function(collectionName, eachCallback) {
                db.createCollection(collectionName, function(err, result) {
                    if (err) {
                        return eachCallback(err);
                    }
                    console.log(`集合 ${collectionName} 创建成功`);

                    // 仅向collection1插入默认数据
                    if (collectionName === "collection1") {
                        db.collection(collectionName).insertOne(defaultCollection1Data, function(err, insertResult) {
                            if (err) {
                                return eachCallback(err);
                            }
                            console.log("默认数据插入成功！");
                            eachCallback(null);
                        });
                    } else {
                        eachCallback(null);
                    }
                });
            }, function(err) {
                // 所有集合处理完成后关闭连接并回调
                client.close();
                if (err) {
                    return callback(err);
                }
                console.log("所有集合初始化完成");
                callback(null);
            });
        });
    });
};

关键修复点说明 #

• 集合去重：移除初始化数组中的重复集合名，避免无效重复操作。
• 正确的存在性校验：通过db.listCollections({name: "collection1"}).toArray()准确判断集合存在性，校验通过后关闭客户端连接而非数据库实例。
• 异步错误捕获：在async.each的每一步操作中添加错误处理，确保任何异常都能触发回调，避免程序卡住。
• 定义默认数据：明确声明defaultCollection1Data变量，解决插入时的未定义问题。
• 语法修复：补全缺失的括号、闭合代码块，确保代码语法合法。

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