Mongoose多数据库连接与模型管理深度解析

// 使用db_enConnection上的Price模型
async function createPriceDocument() {
    // 正确的实例化方式：使用获取到的模型构造函数
    const priceDoc = new PriceModelEn();

    try {
        await priceDoc.save(); // 使用await确保异步操作完成
        console.log('价格文档已保存到 db_en:', priceDoc);
    } catch (error) {
        console.error('保存价格文档到 db_en 失败:', error);
    }
}

// 使用db_frConnection上的Product模型
async function createProductDocument() {
    // 正确的实例化方式：使用获取到的模型构造函数
    const productDoc = new ProductModelFr({ name: 'French Baguette', price: 2.50 });

    try {
        await productDoc.save();
        console.log('产品文档已保存到 db_fr:', productDoc);
    } catch (error) {
        console.error('保存产品文档到 db_fr 失败:', error);
    }
}

const mongoose = require('mongoose');

// 统一的连接选项
const connectionOptions = {
    useCreateIndex: true,
    useNewUrlParser: true,
    useUnifiedTopology: true,
    useFindAndModify: false
};

// --- 第一数据库连接：db_en ---
const dbEnConnection = mongoose.createConnection("mongodb://localhost/db_en", connectionOptions);

dbEnConnection.on('connected', () => console.log('Successfully connected to db_en'));
dbEnConnection.on('error', (err) => console.error('db_en connection error:', err));
dbEnConnection.on('disconnected', () => console.log('Disconnected from 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 }
    }
});

// 在db_enConnection上注册Price模型并获取构造函数
const PriceModelEn = dbEnConnection.model('Price', priceSchema);

// --- 第二数据库连接：db_fr ---
const dbFrConnection = mongoose.createConnection("mongodb://localhost/db_fr", connectionOptions);

dbFrConnection.on('connected', () => console.log('Successfully connected to db_fr'));
dbFrConnection.on('error', (err) => console.error('db_fr connection error:', err));
dbFrConnection.on('disconnected', () => console.log('Disconnected from db_fr'));

// 定义产品Schema
const productSchema = new mongoose.Schema({
    name: { type: String, required: true },
    price: { type: Number, required: true },
    currency: { type: String, default: 'EUR' }
});

// 在db_frConnection上注册Product模型并获取构造函数
const ProductModelFr = dbFrConnection.model('Product', productSchema);

// --- 示例操作函数 ---

async function createPriceDocument() {
    console.log('\n--- 尝试在 db_en 中创建价格文档 ---');
    const priceDoc = new PriceModelEn(); // 使用正确的模型构造函数
    try {
        await priceDoc.save();
        console.log('价格文档已成功保存到 db_en:', priceDoc);
    } catch (error) {
        console.error('保存价格文档到 db_en 失败:', error.message);
    }
}

async function createProductDocument() {
    console.log('\n--- 尝试在 db_fr 中创建产品文档 ---');
    const productDoc = new ProductModelFr({ name: 'Laptop', price: 1200.00 });
    try {
        await productDoc.save();
        console.log('产品文档已成功保存到 db_fr:', productDoc);
    } catch (error) {
        console.error('保存产品文档到 db_fr 失败:', error.message);
    }
}

async function runAllExamples() {
    await createPriceDocument();
    await createProductDocument();

    // 示例查询
    console.log('\n--- 尝试从 db_en 查询价格文档 ---');
    try {
        const prices = await PriceModelEn.find({});
        console.log('db_en 中的价格文档:', prices);
    } catch (error) {
        console.error('从 db_en 查询失败:', error.message);
    }

    console.log('\n--- 尝试从 db_fr 查询产品文档 ---');
    try {
        const products = await ProductModelFr.find({});
        console.log('db_fr 中的产品文档:', products);
    } catch (error) {
        console.error('从 db_fr 查询失败:', error.message);
    }

    // 关闭所有连接
    console.log('\n--- 关闭数据库连接 ---');
    await dbEnConnection.close();
    await dbFrConnection.close();
    console.log('所有数据库连接已关闭。');
}

// 运行所有示例
runAllExamples().catch(console.error);