时间戳

首页 > 解决方案 > AfterUpdate 中的查询在 TypeORM 中没有按预期工作

postgresql - AfterUpdate 中的查询在 TypeORM 中没有按预期工作

问题描述

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

MyEntity
  children (OneToMany)

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

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

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

@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();
  }
}

但是，当上面的查询运行时，更新还没有运行，所以没有从数据库中删除。我期待删除删除孤立的行。

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

START TRANSACTION
UPDATE "my_children_table" SET "myEntityId" = $2 WHERE "id" = $1 -- PARAMETERS: [2,null]
DELETE FROM "my_children_table" WHERE "myEntityId" IS NULL
COMMIT

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

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

标签： postgresqltypeormtypeorm-datamapper

解决方案

我通过提交当前事务（因此数据保存到数据库中）并启动一个新事务来解决它，因此 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();
}

推荐阅读