如何使用Mongoose将模型函数拆分到多个独立文件

要把不同业务域的Mongoose操作函数拆分到独立文件管理，核心是做好依赖引入和模块导出两个环节，同时修正原有代码的隐含bug，具体实现如下：

推荐目录结构 #

先按业务职责拆分文件，避免所有逻辑堆在单文件中：

项目根目录
├── db.js              # 全局数据库连接逻辑（仅执行一次连接）
├── Schemas.js         # Mongoose模型定义文件
├── services/
│   ├── userService.js # 用户相关操作函数
│   └── productService.js # 拆分出来的商品相关操作函数
└── app.js             # 项目入口文件

各文件实现代码 #

1. 修正模型定义文件 Schemas.js #

原文件缺失mongoose引入，同时建议给模型用语义化命名，不要用无意义的Schemas作为模型名：

// 补全缺失的mongoose引入
const mongoose = require('mongoose');
const { Schema } = mongoose;

const productSchema = new Schema({
      name: String,
      price: Number
});

const userSchema = new Schema({
      name: String,
      email: String,
      products: [productSchema]
});

// 导出语义化的User模型
module.exports = mongoose.model('User', userSchema);

2. 抽离全局数据库连接 db.js #

数据库连接全局只需要初始化一次，不要在每个业务文件重复写连接逻辑：

const mongoose = require('mongoose');

const connectDB = async () => {
  try {
    await mongoose.connect('mongodb://localhost/test');
    console.log('Connected to MongoDB');
  } catch (err) {
    console.log('MongoDB connection error:', err);
    process.exit(1);
  }
}

module.exports = connectDB;

3. 用户操作文件 services/userService.js #

存放所有和用户相关的操作函数，最后导出需要被外部调用的方法：

const User = require('../Schemas');

async function createUser(name, email) {
    try {
        const user = new User({
            name,
            email,
            products: []
        });
        await user.save();
        console.log('User created');
        return user;
    } catch (e) {
        console.log("### ERROR: ",e.message);
        throw e;
    }
}

// 导出对外暴露的方法
module.exports = {
  createUser
}

4. 拆分出的商品操作文件 services/productService.js #

独立存放商品相关逻辑，引入需要的依赖后导出方法即可：

const User = require('../Schemas');

async function createProduct(name, price, userName) {
    try {
        const user = await User.findOne({name: userName});
        if (!user) throw new Error('绑定的用户不存在');
        // 商品是User模型下的嵌套子文档，不需要单独new模型实例，直接推入数组即可
        user.products.push({name, price});
        await user.save();
        console.log('Product created');
        return user.products.at(-1);
    } catch (e) {
        console.log("### ERROR: ",e.message);
        throw e;
    }
}

module.exports = {
  createProduct
}

5. 入口文件 app.js #

统一引入依赖、初始化数据库连接后执行业务逻辑：

const connectDB = require('./db');
const { createUser } = require('./services/userService');
const { createProduct } = require('./services/productService');

const init = async () => {
  // 等待数据库连接完成后再执行操作，避免时序错误
  await connectDB();
  await createUser('John', 'john@doe.com');
  await createProduct('Product_name', 100, 'John');
}

init();

关键注意事项 #

• 所有文件中用到的第三方包、自定义模块，必须在文件顶部通过require()显式引入，不能直接使用未声明的变量
• 模块引入时的路径要和实际目录结构匹配，上级目录用../、同级目录用./开头
• 原代码存在逻辑漏洞：原createProduct方法中new Schemas({name, price})会生成缺失email、products字段的无效User文档，并非合法商品数据，上述代码已经修正该问题
• 如果后续需要独立管理商品数据，可以单独定义Product模型、导出后在对应service文件中引入使用即可，拆分逻辑和上述流程一致

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