Mongoose多数据库连接与模型使用指南

const mongoose = require('mongoose');

// 数据库连接选项
// 注意：useCreateIndex, useFindAndModify 在 Mongoose 6.0+ 中已弃用，
// useNewUrlParser, useUnifiedTopology 也是默认行为，通常不再需要显式设置。
const connectionOptions = {
    useNewUrlParser: true, // 保持兼容性，尽管在新版本中已是默认
    useUnifiedTopology: true // 保持兼容性，尽管在新版本中已是默认
};

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

// 监听连接事件，确保连接成功或处理错误
dbEnConn.on('connected', () => {
    console.log('成功连接到数据库：db_en');
});
dbEnConn.on('error', (err) => {
    console.error('db_en 数据库连接错误:', err);
});
dbEnConn.on('disconnected', () => {
    console.log('db_en 数据库连接已断开');
});

// 定义 Price 模型的 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 }
    }
}, { timestamps: true }); // 添加时间戳，便于追踪

// 将 Price 模型注册到 dbEnConn 连接实例上，并获取其构造函数
const PriceModel = dbEnConn.model('Price', priceSchema);

// 实例化 Price 模型并保存数据
async function savePriceData() {
    try {
        const newPriceEntry = new PriceModel({
            fixed: {
                1: 200,
                3: 500
            }
        });
        const savedPrice = await newPriceEntry.save();
        console.log('价格数据已成功保存到 db_en:', savedPrice);
    } catch (error) {
        console.error('保存价格数据时发生错误:', error);
    }
}

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

// 监听连接事件
dbAnotherConn.on('connected', () => {
    console.log('成功连接到数据库：db_another');
});
dbAnotherConn.on('error', (err) => {
    console.error('db_another 数据库连接错误:', err);
});
dbAnotherConn.on('disconnected', () => {
    console.log('db_another 数据库连接已断开');
});

// 定义 User 模型的 Schema
const userSchema = new mongoose.Schema({
    name: { type: String, required: true },
    email: { type: String, required: true, unique: true }
}, { timestamps: true });

// 将 User 模型注册到 dbAnotherConn 连接实例上，并获取其构造函数
const UserModel = dbAnotherConn.model('User', userSchema);

// 实例化 User 模型并保存数据
async function saveUserData() {
    try {
        const newUserEntry = new UserModel({
            name: 'Alice',
            email: 'alice@example.com'
        });
        const savedUser = await newUserEntry.save();
        console.log('用户数据已成功保存到 db_another:', savedUser);

        // 尝试保存第二个用户，演示错误处理（如 email unique 约束）
        const anotherUser = new UserModel({
            name: 'Bob',
            email: 'alice@example.com' // 会导致唯一性约束错误
        });
        await anotherUser.save();
    } catch (error) {
        // Mongoose 错误通常有 name 和 code 属性
        if (error.code === 11000) {
            console.error('保存用户数据时发生错误: 邮箱已存在。', error.message);
        } else {
            console.error('保存用户数据时发生错误:', error);
        }
    }
}

// 运行示例
async function runExamples() {
    await savePriceData();
    await saveUserData();

    // 在实际应用中，你可能需要等待所有操作完成后再关闭连接
    // setTimeout(() => {
    //     dbEnConn.close(() => console.log('db_en 连接已关闭'));
    //     dbAnotherConn.close(() => console.log('db_another 连接已关闭'));
    // }, 5000); // 示例：5秒后关闭
}

runExamples();