MongoDB集合含大量记录但查询返回空数组的问题求助

针对你遇到的重构后MongoDB查询返回空数组的问题，结合你的代码和场景，整理以下排查方向和解决方案：

一、核心问题：全局MongoClient连接复用异常 #

你的代码中全局实例化了MongoClient，但每次调用connectToDatabase都会执行await client.connect()。虽然MongoClient支持重复调用connect()，但多次触发连接可能导致状态异常，进而影响查询结果。

修复方案：确保MongoClient仅初始化连接一次 #

修改$lib/mongodb/db.ts中的连接逻辑，添加连接状态判断：

const url = MONGODB_URI;
const client = new MongoClient(url);
const dbName = 'Destinations';
let isConnected = false; // 标记连接状态

export async function connectToDatabase(coll: string) {
    if (!isConnected) {
        await client.connect();
        console.log('Successfully connected to the server');
        isConnected = true;
    }
    const db = client.db(dbName);
    const collection = db.collection(coll);
    return collection;
}

二、验证数据库与集合的正确性 #

1. 集合名称大小写检查：MongoDB集合名称区分大小写，确认代码中'Countries'与数据库中实际集合名称完全一致（比如是否是小写的'countries'）。
2. 数据库名称验证：确认dbName = 'Destinations'是你存储数据的目标数据库，避免重构时误改数据库名。

三、添加调试日志定位问题 #

在connectToDatabase中添加日志，确认当前操作的数据库、集合以及文档数量，快速判断数据是否存在：

export async function connectToDatabase(coll: string) {
    if (!isConnected) {
        await client.connect();
        console.log('Successfully connected to the server');
        isConnected = true;
    }
    const db = client.db(dbName);
    console.log('当前操作数据库:', db.databaseName);
    const collection = db.collection(coll);
    console.log('当前操作集合:', collection.collectionName);
    // 打印集合文档总数
    const docCount = await collection.countDocuments({});
    console.log('集合文档总数:', docCount);
    return collection;
}

如果docCount返回0，说明当前集合确实无数据，需检查数据存储目标；如果docCount大于0但find({}).toArray()返回空，需进一步排查连接状态或查询逻辑。

四、环境变量与权限排查 #

1. 确认MONGODB_URI正确性：检查环境变量MONGODB_URI是否指向存储数据的MongoDB实例（比如是否误切换到测试环境数据库）。
2. 权限验证：确认连接数据库的用户拥有Countries集合的读取权限，若URI中的用户信息有变更，可能导致权限问题。

修改后的完整代码示例 #

// $lib/mongodb/db.ts
const url = MONGODB_URI;
const client = new MongoClient(url);
const dbName = 'Destinations';
let isConnected = false;

export async function connectToDatabase(coll: string) {
    if (!isConnected) {
        await client.connect();
        console.log('Successfully connected to the server');
        isConnected = true;
    }
    const db = client.db(dbName);
    const collection = db.collection(coll);
    return collection;
}

export async function getCountries() {
    const collection = await connectToDatabase('Countries');
    const query = await collection.find({}).toArray();
    console.log('查询结果:', query);
    return query;
}

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