Next.js中使用Mongoose查询MongoDB任务时重复创建集合问题

问题说明 #

在Next.js应用中使用Mongoose从MongoDB获取数据时，每次运行程序都会尝试创建集合，但实际仅需查询已存在的任务数据。

相关代码 #

任务模型文件 #

export class TaskModel extends Mixin(AuditableModel, Mongoose.Schema) {
    constructor(
        public taskId?: number,
        public title?: string,
        public description?: string,
        public isActive?: boolean,
        public creator?: UserModel
    ) {
        super();
    }
}

任务Schema定义 #

export const TaskSchema = mongoose.model('task', new TaskModel())

任务服务文件 #

public async GetAll() {
        await mongoose.connect(dbUrl).then(()=>{console.log("Connected")}).catch(()=>{console.log("Not Connected")});
        var response = new Envelop(true, 1000001, TaskSchema.find());
        console.log('Get All!');
        return response;
    }

问题根源 #

1. Mongoose默认行为：调用mongoose.model()时，若指定的集合不存在，Mongoose会自动创建该集合。
2. 模型定义错误：你的TaskModel直接继承Mongoose.Schema，但没有正确定义Schema的字段结构，实例化后作为模型参数传入，导致Mongoose识别为新Schema，触发集合创建逻辑。
3. 重复数据库连接：每次调用GetAll都重新连接数据库，重复初始化模型，加剧了集合创建的触发。

解决办法 #

1. 修正Schema与Model的定义逻辑 #

Mongoose要求Schema和Model分离，先定义字段结构，再创建Model：

// 定义Task的Schema结构
const taskSchema = new mongoose.Schema({
    taskId: Number,
    title: String,
    description: String,
    isActive: Boolean,
    creator: { type: mongoose.Schema.Types.ObjectId, ref: 'User' } // 关联User模型，根据实际调整
});

// 集成AuditableModel的逻辑（比如审计字段）
// 如果AuditableModel包含创建时间、更新时间，可直接用Mongoose的timestamps选项：
// taskSchema.set('timestamps', true);
// 或者通过自定义插件实现你的AuditableModel逻辑
// taskSchema.plugin(yourAuditablePlugin);

// 创建Task模型
export const TaskModel = mongoose.model('task', taskSchema);

2. 统一数据库连接逻辑，避免重复连接 #

在Next.js中把数据库连接抽成单独文件，确保只连接一次：

// lib/mongodb.ts
import mongoose from 'mongoose';

const dbUrl = process.env.MONGODB_URI;

if (!dbUrl) {
    throw new Error('请配置MONGODB_URI环境变量');
}

// 缓存连接，避免重复初始化
let cached = global.mongoose;
if (!cached) {
    cached = global.mongoose = { conn: null, promise: null };
}

async function connectToDatabase() {
    if (cached.conn) return cached.conn;

    if (!cached.promise) {
        cached.promise = mongoose.connect(dbUrl)
            .then(mongoose => {
                console.log('数据库连接成功');
                return mongoose;
            })
            .catch(err => {
                console.log('数据库连接失败', err);
                throw err;
            });
    }

    cached.conn = await cached.promise;
    return cached.conn;
}

export default connectToDatabase;

然后在服务中使用：

import connectToDatabase from '../lib/mongodb';
import { TaskModel } from './task-model';

public async GetAll() {
        await connectToDatabase();
        // 注意要await查询，否则返回的是Query对象，不是实际数据
        const tasks = await TaskModel.find();
        const response = new Envelop(true, 1000001, tasks);
        console.log('Get All!');
        return response;
    }

3. 可选：禁用自动创建集合 #

如果确认集合已经存在，创建Model时可以添加autoCreate: false选项阻止自动创建：

export const TaskModel = mongoose.model('task', taskSchema, 'task', { autoCreate: false });

内容的提问来源于stack exchange，提问作者Assay Khan