使用TypeORM Query Builder左连接删除时报列不存在错误的问题

我希望从控制器接收id和用户信息作为参数，通过Query Builder执行删除操作，但出现了QueryFailedError: Unknown column 'certificate.id' in 'where clause'错误。我对Query Builder不太熟悉，请问该错误的原因是什么？

实体定义代码 #

CertificateEntity #

@Entity()
@Unique(['url'])
export class CertificateEntity {
  @PrimaryGeneratedColumn()
  id: number;

  @Column()
  @IsUrl()
  url: string;

  @Column()
  valid_from: string;

  @Column()
  valid_to: string;

  @ManyToOne((type) => AuthEntity, (user) => user.certificates, {
    eager: false,
  })
  user: AuthEntity;
}

AuthEntity #

@Unique(['username'])
@Entity()
export class AuthEntity extends BaseEntity {
  @PrimaryGeneratedColumn()
  id: number;

  @Column()
  email: string;

  @Column()
  username: string;

  @Column()
  password: string;

  @Column()
  signupVerifyToken: string;

  @OneToMany((type) => CertificateEntity, (certificates) => certificates.user, {
    eager: true,
  })
  certificates: CertificateEntity[];
}

服务层代码 #

// service
async remove(id: number, user: AuthEntity): Promise<boolean> {
  console.log(id, user.id);

  // error this point !
  await this.certificateRepo
    .createQueryBuilder('certificate')
    .leftJoin('certificate.user', 'user')
    .where('certificate.id=:id', { id: id })
    .andWhere('user.id=:id', { id: user.id })
    .delete()
    .execute();
  return true;
}

核心错误原因 #

1. Delete Query Builder不支持JOIN别名引用：TypeORM的Delete操作Query Builder不会保留JOIN的表别名上下文，执行时数据库无法识别certificate.id、user.id这类别名引用的字段——因为DELETE语句默认仅操作主表，JOIN在这里不生效。
2. 参数名冲突：两个条件都使用:id作为参数名，会导致后传入的user.id覆盖前一个id的值，逻辑上也存在错误。

修正方案 #

方案一：直接通过外键字段删除 #

利用TypeORM自动生成的外键列（默认是userId）直接过滤，无需JOIN：

async remove(id: number, user: AuthEntity): Promise<boolean> {
  const result = await this.certificateRepo
    .createQueryBuilder()
    .delete()
    .from(CertificateEntity)
    .where("id = :certId", { certId: id })
    .andWhere("userId = :userId", { userId: user.id })
    .execute();

  return result.affected > 0;
}

注：如果你的外键列名不是userId（比如手动指定了@JoinColumn({ name: 'user_id' })），需要替换为对应的列名。

方案二：先查询验证再删除 #

先确认证书属于当前用户，再执行删除，逻辑更清晰：

async remove(id: number, user: AuthEntity): Promise<boolean> {
  const certificate = await this.certificateRepo.findOne({
    where: { id, user: { id: user.id } }
  });

  if (!certificate) {
    return false;
  }

  await this.certificateRepo.remove(certificate);
  return true;
}

方案三：数据库兼容的JOIN删除（可选） #

如果依赖特定数据库特性（比如MySQL），可以用USING子句实现JOIN删除，但兼容性较差：

async remove(id: number, user: AuthEntity): Promise<boolean> {
  const result = await this.certificateRepo
    .createQueryBuilder()
    .delete()
    .from(CertificateEntity)
    .using(AuthEntity, "user")
    .where("certificate.id = :certId", { certId: id })
    .andWhere("certificate.userId = user.id")
    .andWhere("user.id = :userId", { userId: user.id })
    .execute();

  return result.affected > 0;
}

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