如何在TypeORM中无需加载全部关联数据添加多对多关联

针对你遇到的两个痛点——并发投票可能丢数据、加载全量关联用户效率低，直接上实用解决方案：

1. 直接操作中间表（最优解） #

TypeORM的多对多关联会自动生成中间表（默认命名类似poll_voted_users_user，也可以通过@JoinTable自定义），直接操作这个中间表是最高效的方式，不需要加载任何实体或关联集合。

代码示例： #

async function addVote(pollId: number, userId: number) {
  const queryRunner = getConnection().createQueryRunner();
  await queryRunner.connect();
  await queryRunner.startTransaction();

  try {
    // 先检查是否已投票，避免重复插入
    const hasVoted = await queryRunner.manager
      .createQueryBuilder()
      .select("1")
      .from("poll_voted_users_user", "pvuu") // 替换成你的中间表实际名称
      .where("pvuu.pollId = :pollId", { pollId })
      .andWhere("pvuu.userId = :userId", { userId })
      .getRawOne();

    if (!hasVoted) {
      await queryRunner.manager
        .createQueryBuilder()
        .insert()
        .into("poll_voted_users_user")
        .values({ pollId, userId })
        .execute();
    }

    await queryRunner.commitTransaction();
  } catch (err) {
    await queryRunner.rollbackTransaction();
    throw err;
  } finally {
    await queryRunner.release();
  }
}

核心优势： #

• 完全不依赖关联集合加载，性能不受投票人数增长影响
• 事务+存在性检查保证原子性，并发场景下数据库行锁会自动处理冲突，不会丢失投票记录

2. 用QueryBuilder关联操作（更简洁） #

TypeORM支持直接通过ID操作关联关系，无需加载完整实体或关联集合：

async function addVote(pollId: number, userId: number) {
  await getConnection()
    .createQueryBuilder()
    .relation(Poll, "votedUsers")
    .of(pollId) // 直接传入Poll的ID，无需查询实体
    .add(userId); // 直接传入User的ID，无需查询实体
}

关键注意事项： #

• 必须给中间表的pollId和userId添加联合唯一约束，否则并发场景下可能出现重复插入
• 并发插入时数据库会抛出唯一约束冲突，需在代码中捕获并处理：

  try {
    // 执行上述addVote逻辑
  } catch (err) {
    // 不同数据库错误码不同，例如PostgreSQL为23505
    if (err.code === "23505") {
      throw new Error("你已经投过票了");
    }
    throw err;
  }
  

3. 给中间表添加唯一约束（必做基础配置） #

不管用哪种方案，这一步是保证并发安全和避免重复投票的基础，在@JoinTable中配置：

@Entity('poll')
class Poll {
    ...
    @ManyToMany(() => User, user => user.votedPolls)
    @JoinTable({
      name: "poll_voted_users", // 自定义中间表名，可选
      joinColumn: { name: "poll_id", referencedColumnName: "id" },
      inverseJoinColumn: { name: "user_id", referencedColumnName: "id" },
      uniqueConstraints: [
        { name: "unique_poll_user", columns: ["poll_id", "user_id"] }
      ]
    })
    votedUsers!: User[] 
}

为什么不推荐加载全量关联集合？ #

你原本的方式存在两个致命问题：

• 效率极低：投票人数越多，需要加载的数据量越大，内存和数据库IO开销会急剧上升
• 原子性缺失：并发场景下，两个请求同时加载同一个Poll的用户列表，各自添加用户后保存，后保存的请求会覆盖前者的修改，直接导致投票记录丢失

而直接操作中间表或使用QueryBuilder关联操作，都是直接向数据库发送单条/少量SQL，数据库会自动处理锁和约束，既保证了效率又确保了操作的原子性。

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