NestJS中Mongoose多对一关联失效问题求助

问题 #

使用NestJS + Mongoose开发时，Report与User的一对多关联（Report关联User）可正常工作，但User与Report的反向关联（User的reports数组）始终为空。相关代码及现象如下：

User Schema #

import { Prop, Schema, SchemaFactory } from "@nestjs/mongoose";
import mongoose, { Document } from "mongoose";
import { Report } from "./report.schema";

export type UserDocument = User & Document;

@Schema()
export class User {

    @Prop()
    id: string;

    @Prop({ required: true })
    email: string;

    @Prop({ required: true })
    password: string;

    @Prop({ type: [mongoose.Schema.Types.ObjectId], ref: 'Report' })
    reports: Report[];
}

export const UserSchema = SchemaFactory.createForClass(User);

User Repository #

import { CreateUser } from "@mypleaks/ms-models";
import { Injectable } from "@nestjs/common";
import { InjectModel } from "@nestjs/mongoose";
import { Model } from "mongoose";
import { User, UserDocument } from "../schema/user.schema";

@Injectable()
export class UsersRepository {

    constructor(@InjectModel(User.name) private userModel: Model<UserDocument>) { }

    async create(createUser: CreateUser): Promise<User> {
        let user = new this.userModel(createUser);
        return await user.save();
    }

    async findAll() {
        return await this.userModel.find().populate('reports');
    }
}

Report Schema #

import { Prop, Schema, SchemaFactory } from "@nestjs/mongoose";
import mongoose, { Types } from "mongoose";
import { User } from "./user.schema";

export type ReportDocument = Report & mongoose.Document;

@Schema()
export class Report {

    @Prop()
    id: string;

    @Prop({ required: true })
    make: string;

    @Prop({ required: true })
    year: string;

    @Prop()
    mileage: string;

    @Prop({ type: Types.ObjectId, ref: 'User' })
    user: User;
}

export const ReportSchema = SchemaFactory.createForClass(Report);

Report Repository #

import { CreateReport } from '../schema/create-report';
import { Injectable } from '@nestjs/common';
import { InjectModel } from '@nestjs/mongoose';
import { Model } from 'mongoose';
import { Report, ReportDocument } from '../schema/report.schema';

@Injectable()
export class ReportRepository {

    constructor(@InjectModel(Report.name) private reportModel: Model<ReportDocument>) { }

    async create(createReport: CreateReport): Promise<Report> {
        const report = new this.reportModel(createReport);
        return await report.save();
    }

    async findAll() {
        return await this.reportModel.find().populate('user');
    }
}

异常现象 #

• 创建Report时已传入正确的User关联ID，但MongoDB中User文档的reports数组始终为空
• 查询Report时，通过populate('user')可正常获取关联的用户信息
• 查询User时，populate('reports')返回空数组，示例结果：

[
    {
        "reports": [],
        "_id": "62ed613c943954aeb1738f14",
        "email": "d@x.com",
        "password": "cc5f719b6a70c5371129429aa12b7715fef99f41372f8d676e610dc880702b36.2f9e002f0f1eadaa",
        "__v": 0
    }
]

解决思路与方案 #

1. 手动维护反向关联（直接生效） #

Mongoose不会自动维护双向关联的两端数据，创建Report时需要同时更新对应User的reports数组：

修改ReportRepository的create方法：

// 注意需要先注入UserModel
constructor(
    @InjectModel(Report.name) private reportModel: Model<ReportDocument>,
    @InjectModel(User.name) private userModel: Model<UserDocument>
) { }

async create(createReport: CreateReport): Promise<Report> {
    const report = new this.reportModel(createReport);
    // 先保存报告
    await report.save();
    // 更新关联用户的reports数组，添加当前报告ID
    await this.userModel.findByIdAndUpdate(
        createReport.user, // 确保createReport.user是有效的用户ObjectId
        { $push: { reports: report._id } }
    );
    return report;
}

2. 使用Mongoose中间件（自动维护） #

在Report Schema中添加post保存中间件，报告保存后自动更新用户的关联数组：

export const ReportSchema = SchemaFactory.createForClass(Report);

// 报告保存后自动同步用户的reports数组
ReportSchema.post('save', async function(doc) {
    await mongoose.model('User').findByIdAndUpdate(
        doc.user,
        { $push: { reports: doc._id } }
    );
});

3. 验证数据一致性 #

• 确认MongoDB中Report文档的user字段是对应User的_id（类型必须为ObjectId，而非字符串，除非Schema中显式定义为字符串类型）
• 检查创建Report时传入的user参数是否为有效的用户ObjectId

4. 可选：用虚拟字段替代存储数组（避免数据冗余） #

如果不想在User文档中存储reports数组，可以定义虚拟字段，通过查询动态获取关联报告：

修改User Schema：

@Schema()
export class User {
    // 保留原有字段...
}

// 定义虚拟字段，不存储在数据库中
UserSchema.virtual('reports', {
    ref: 'Report',
    localField: '_id',
    foreignField: 'user',
    justOne: false // 一对多关联，返回数组
});

// 开启虚拟字段的JSON/Object转换
UserSchema.set('toJSON', { virtuals: true });
UserSchema.set('toObject', { virtuals: true });

此时查询User时无需调用populate('reports')，虚拟字段会在文档转换为JSON/Object时自动查询返回关联的报告列表。

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