AfterUpdate 中的查询在 TypeORM 中未按预期工作

Question

我在 TypeORM 中有一个实体，其中包含一组其他子实体：

MyEntity
  children (OneToMany)

当我删除一个子实体（例如 ID = 2）并保存该实体时，子实体表中的框架将按预期触发更新：

MyEntity
  children (OneToMany)

我还有一个订阅者正在监听更新后事件，该事件也按预期触发。但是，更新不会删除该条目。该条目现在是孤立的，关系 ID 为空。在下面的示例中，我使用订阅者来清理孤立的实体：

UPDATE "my_children_table" SET "myEntityId" = null WHERE "id" = 2 

但是，当上面的查询运行时，更新尚未运行，因此不会从数据库中删除任何内容。我期望删除能够删除孤立的行。

根据TypeORM日志，查询按以下顺序执行：

@EventSubscriber()
export class MyChildSubscriber implements EntitySubscriberInterface<MyChildEntity> {
  public listenTo(): string | Function {
    return MyChildEntity;
  }

  public async afterUpdate(event: LoadEvent<MyChildEntity>) {
    console.log('It works! The event is triggered as expected!');

    const builder = event.connection
      .createQueryBuilder()
      .delete()
      .from(MyChildEntity)
      .where('"myEntityId" IS NULL');

    return builder.execute();
  }
}

如果我直接在数据库中运行相同的事务（我使用的是 PostgreSQL），一切都会按预期工作，但 TypeORM 的行为就像 DELETE 在 UPDATE 之前运行一样。

你能帮助我理解我做错了什么吗？

Answer 1

我通过提交当前事务（因此数据被保存到数据库）并启动一个新事务来解决这个问题，因此 TypeORM 稍后会提交这个新事务。我返回了我的查询执行（一个 Promise）以确保 TypeORM 会等待它：

public async afterUpdate(event: LoadEvent<MyChildEntity>) {
  await event.queryRunner.commitTransaction();
  await event.queryRunner.startTransaction();
  return event.manager
    .createQueryBuilder()
    .delete()
    .from(MyChildEntity)
    .where('"myEntityId" IS NULL')
    .execute();
}