Mongoose多数据库连接下的模型管理与实例化指南

const mongoose = require('mongoose');
const connectionOptions = { useNewUrlParser: true, useUnifiedTopology: true };
const conn = mongoose.createConnection("mongodb://localhost/db_en", connectionOptions);

const Schema = mongoose.Schema;

const priceSchema = new Schema({
    fixed: {
        1: { type: Number, default: 199 },
        3: { type: Number, default: 499 },
        6: { type: Number, default: 729 },
        12: { type: Number, default: 999 }
    }
});

// 在 conn 连接上注册模型，但没有捕获返回的模型构造函数
conn.model('Price', priceSchema);

// 错误：尝试将 conn.Price 作为构造函数使用
// const ggg = new conn.Price(); // 会抛出 TypeError

const mongoose = require('mongoose');

// 1. 建立独立连接
const connectionOptions = {
    useCreateIndex: true, // 现代Mongoose版本可能不再需要此选项，或已弃用
    useNewUrlParser: true,
    useUnifiedTopology: true,
    useFindAndModify: false // 现代Mongoose版本可能不再需要此选项，或已弃用
};

const conn = mongoose.createConnection("mongodb://localhost/db_en", connectionOptions);

// 监听连接事件，确保连接成功
conn.on('connected', () => {
    console.log('MongoDB db_en connected successfully!');
});
conn.on('error', (err) => {
    console.error('MongoDB db_en connection error:', err);
});
conn.on('disconnected', () => {
    console.log('MongoDB db_en disconnected.');
});

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

// 3. 在 conn 连接上注册模型，并捕获返回的模型构造函数
// PriceModel 现在是 Price 模型的构造函数，它与 conn 连接关联
const PriceModel = conn.model('Price', priceSchema);

// 4. 实例化和保存文档
async function createAndSavePrice() {
    try {
        // 使用 PriceModel 构造函数创建新文档实例
        const newPrice = new PriceModel();
        await newPrice.save();
        console.log('Price document saved successfully:', newPrice);
    } catch (error) {
        console.error('Error saving price document:', error);
    } finally {
        // 在实际应用中，你可能不会立即关闭连接
        // conn.close();
    }
}

// 确保连接建立后再执行操作
conn.once('open', () => {
    createAndSavePrice();
});

// 示例：从同一个连接中获取已定义的模型（如果已定义过）
async function findPrice() {
    try {
        // 如果 PriceModel 已经定义并赋值，可以直接使用
        // 否则，可以通过 conn.model('Price') 获取已定义的模型
        const retrievedPriceModel = conn.model('Price');
        const prices = await retrievedPriceModel.find({});
        console.log('Retrieved prices:', prices);
    } catch (error) {
        console.error('Error retrieving prices:', error);
    }
}

conn.once('open', () => {
    findPrice();
});