使用TypeORM在PostgreSQL中保存产品多对多categories关联字段失败

具体错误点 #

• 产品实体的关联字段类型定义错误
  在productsEntity中，多对多关联的categories字段被标注为string类型，完全不符合多对多关系的要求。TypeORM会根据字段类型推断关联映射逻辑，写成字符串类型会直接让TypeORM跳过该字段的关联处理，完全不会往关联中间表写入数据，这是最核心的问题。
• 多对多关系缺少必须的关联表配置
  TypeORM的多对多关系必须在关系拥有方（即本项目的产品实体端）添加@JoinTable装饰器，明确中间表的结构和外键映射规则。目前仅在两端分别声明了@ManyToMany装饰器，没有配置拥有方的关联表规则，哪怕框架默认能创建中间表，也会因为关系映射不完整导致保存时关联数据无法写入。
• 保存逻辑中的关联赋值无效
  保存产品时，直接把从入参解构出的belongsTo变量赋值给newProduct.categories。这个值本质是前端传过来的原始参数（大概率是分类ID数组或分类标题字符串数组），而TypeORM在保存多对多关联时，要求该字段必须传入从数据库查询得到的Categories实体实例数组，直接传入原始值会被TypeORM判定为无效关联对象，直接忽略不做持久化处理。
• DTO字段类型定义和实际传参逻辑不匹配
  在addProductDto中将categories字段的类型声明为Categories[]，但实际客户端提交请求时，根本不会传递完整的Categories实体对象过来，最多传入分类ID数组或分类名称数组。这个错误的类型声明会导致入参校验逻辑无法正确识别参数，进一步加重类型不匹配的问题。

修正步骤与参考代码 #

1. 调整产品实体的关联定义

@Entity('products')
export class productsEntity extends BaseEntity{
    @PrimaryGeneratedColumn()
    id: number;
    // ...其他原有业务列

    @ManyToMany(() => Categories, category => category.products)
    @JoinTable({
        name: 'product_category_rel', // 可自定义中间表名称，不配则使用框架默认命名
        joinColumn: { name: 'product_id', referencedColumnName: 'id' },
        inverseJoinColumn: { name: 'category_id', referencedColumnName: 'id' }
    })
    // 修正字段类型为Categories数组，替换原来错误的string类型
    categories: Categories[];
}

2. 调整DTO的字段类型，匹配实际前端传参

export class addProductDto{
    // ...其他原有校验字段
    @IsNotEmpty({ message: "category needs to be set."})
    // 修正为前端实际传递的分类ID数组类型
    categories: number[];
}

3. 调整仓储层的保存逻辑，补充关联实体查询步骤

@EntityRepository(productsEntity)
export class productsRepository extends Repository<productsEntity> {
    private logger = new Logger();

    async addProduct(productDetails: addProductDto, username: string){
        // 直接按DTO字段名解构，避免字段名混淆
        const { title, description, categories, price, units }  = productDetails;
        try{
            // 根据前端传入的分类ID，从数据库查出对应的Categories实体
            const categoryList = await this.manager.findBy(Categories, {
                id: In(categories)
            })
            // 校验分类是否存在，避免无效关联
            if (!categoryList.length) {
                throw new HttpException('指定的分类不存在', HttpStatus.BAD_REQUEST)
            }

            const newProduct = new productsEntity();
            newProduct.title = title;
            newProduct.description = description;
            // 给categories赋已经查出来的实体数组
            newProduct.categories = categoryList;
            newProduct.price = price;
            newProduct.units = units;
            newProduct.soldBy = username;
            await this.manager.save(newProduct);
        }
        catch(err){
            this.logger.error(err.message);
            throw new HttpException('Failed adding Product.', HttpStatus.INTERNAL_SERVER_ERROR)
        }
    }
}

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