Mongoose 多数据库连接与模型管理深度指南

const mongoose = require('mongoose');

// 定义通用的连接选项，确保连接的稳定性和兼容性
const connectionOptions = {
    useCreateIndex: true,         // 确保创建索引时兼容性
    useNewUrlParser: true,        // 使用新的URL解析器
    useUnifiedTopology: true,     // 使用新的统一拓扑引擎
    useFindAndModify: false       // 禁用 findAndModify()，使用 findOneAndUpdate() 或 findOneAndRemove()
};

// 建立第一个数据库连接（例如，主数据库）
const dbMain = mongoose.createConnection("mongodb://localhost/db_main", connectionOptions);

// 监听连接事件，以便了解连接状态
dbMain.on('connected', () => {
    console.log('成功连接到主数据库: db_main');
});
dbMain.on('error', (err) => {
    console.error('主数据库连接错误:', err);
});
dbMain.on('disconnected', () => {
    console.log('主数据库连接已断开: db_main');
});

// 建立第二个数据库连接（例如，db_en 数据库）
const dbEn = mongoose.createConnection("mongodb://localhost/db_en", connectionOptions);

dbEn.on('connected', () => {
    console.log('成功连接到第二数据库: db_en');
});
dbEn.on('error', (err) => {
    console.error('第二数据库连接错误:', err);
});
dbEn.on('disconnected', () => {
    console.log('第二数据库连接已断开: db_en');
});

// 您可以根据需要建立更多连接

// 定义一个 Schema
const priceSchema = new mongoose.Schema({
    fixed: {
        1: { type: Number, default: 199 },
        3: { type: Number, default: 499 },
        6: { type: Number, default: 729 },
        12: { type: Number, default: 999 }
    }
});

// 在 dbEn 连接上定义 Price 模型
// 正确的做法：将 dbEn.model() 的返回值赋给一个变量
const PriceModelEn = dbEn.model('Price', priceSchema);

// 错误示范：直接尝试从连接对象访问模型，会导致 TypeError
// dbEn.model('Price', priceSchema); // 此时模型已在 dbEn 上定义，但没有赋值给变量
// const ggg = new dbEn.Price(); // 错误！dbEn.Price 不存在，dbEn 实例上没有名为 Price 的属性
// 错误信息：TypeError: conn.Price is not a constructor

// ... (承接上面的连接建立和 Schema 定义) ...

// 异步函数用于演示数据操作
async function savePriceData() {
    try {
        // 使用 PriceModelEn 构造函数来创建文档实例
        const newPrice = new PriceModelEn({
            fixed: {
                1: 299,
                3: 599
            }
        });

        // 保存文档到 db_en 数据库
        const savedPrice = await newPrice.save();
        console.log('价格数据成功保存到 db_en 数据库:', savedPrice);

        // 您也可以通过模型直接查询数据
        const foundPrice = await PriceModelEn.findOne({ 'fixed.1': 299 });
        console.log('从 db_en 数据库查询到的价格数据:', foundPrice);

    } catch (error) {
        console.error('保存或查询价格数据时发生错误:', error);
    } finally {
        // 在操作完成后，可以选择关闭连接
        // dbEn.close();
        // dbMain.close(); // 如果不再需要，也关闭主连接
    }
}

// 调用函数执行数据操作
savePriceData();

// 示例：如果在 dbMain 上也有一个 User 模型
// const userSchema = new mongoose.Schema({ name: String });
// const UserModelMain = dbMain.model('User', userSchema);
// async function saveUserData() {
//     try {
//         const newUser = new UserModelMain({ name: 'Alice' });
//         await newUser.save();
//         console.log('用户数据成功保存到 db_main 数据库:', newUser);
//     } catch (error) {
//         console.error('保存用户数据时发生错误:', error);
//     }
// }
// saveUserData();