解决MongoDB连接错误：正确使用MongoClient进行数据库连接

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

const url = 'mongodb+srv://your_username:your_password@your_cluster_url/your_database_name?retryWrites=true&w=majority'; // 替换为你的MongoDB连接字符串
const dbName = 'your_database_name'; // 替换为你的数据库名称

let db; // 用于存储数据库实例

async function connectToMongoDB() {
    const client = new MongoClient(url);
    try {
        await client.connect();
        console.log("MongoDB 连接成功！");
        db = client.db(dbName); // 获取数据库实例
    } catch (error) {
        console.error("MongoDB 连接失败:", error);
        process.exit(1); // 连接失败时退出应用
    }
}

// 调用连接函数
connectToMongoDB();

// 在需要时，你可以通过 db 变量进行数据库操作
// 例如：
// async function fetchData() {
//     if (!db) {
//         console.error("数据库未连接！");
//         return;
//     }
//     const collection = db.collection('your_collection_name');
//     const data = await collection.find({}).toArray();
//     console.log(data);
// }
// fetchData();

const { MongoClient, ObjectId } = require('mongodb'); // 引入ObjectId用于处理_id
const express = require('express');
const cors = require('cors'); // 引入cors中间件处理跨域请求

const app = express(); // 初始化Express应用

// 配置Express中间件
app.use(express.json()); // 启用JSON请求体解析
app.use(cors()); // 启用CORS，允许跨域请求

let db; // 全局变量，用于存储MongoDB数据库实例

// MongoDB连接配置
const url = 'mongodb+srv://your_username:your_password@your_cluster_url/your_database_name?retryWrites=true&w=majority'; // 替换为你的连接字符串
const dbName = 'your_database_name'; // 替换为你的数据库名称
const client = new MongoClient(url);

// 异步IIFE (Immediately Invoked Function Expression) 用于在应用启动时连接MongoDB
(async () => {
    try {
        await client.connect();
        db = client.db(dbName); // 获取数据库实例
        console.log("MongoDB 连接成功！数据库实例已准备就绪。");
    } catch (error) {
        console.error("MongoDB 连接失败:", error);
        process.exit(1); // 连接失败时，终止应用启动
    }
})();

// 定义一个示例路由
app.get("/someroute/:id", async (req, res) => {
    if (!db) {
        return res.status(500).json({ message: "数据库未连接。" });
    }
    try {
        // 使用ObjectId将字符串ID转换为MongoDB的ObjectId类型
        const result = await db.collection("your_collection_name").findOne({ _id: new ObjectId(req.params.id) });
        if (result) {
            res.json(result);
        } else {
            res.status(404).json({ message: "未找到对应记录。" });
        }
    } catch (error) {
        console.error("查询数据时发生错误:", error);
        res.status(500).json({ message: "服务器内部错误，查询失败。" });
    }
});

// 启动Express服务器
const PORT = 3000;
app.listen(PORT, () => {
    console.log(`服务器已启动，监听端口 ${PORT}`);
});