typeorm高效批量更新

Question

我有一个在< code>postgresql数据库上使用< code>typeorm的更新查询，如下所示，该查询频繁地在20个项目的列表上执行(每30秒一次)。大约需要。更新12秒，对我的极限来说已经很多了。

for (item of items) {
    await getConnection().createQueryBuilder().update(ItemEntity)
        .set({status: item.status, data: item.data})
        .whereInIds(item.id).execute();
}

是否有可能在单个查询中执行这样的批量更新，而不是迭代其他项？如果是的话-怎么做？

项。状态和项。数据对于每个项目都是唯一的。

Answer 1

使用纯psql，可以按照答案中的描述完成：使用PostgreSQL更新同一查询中的多行

但是，来自 Typeorm 的更新查询生成器不支持 from 子句。就目前而言，我认为原始查询是唯一的方法，即获取管理器（..query（“原始sql...”）。

Answer 2

有一种方法可以通过升级来解决这个问题

使用数据库上已有的数据数组并使用ON CONFLICT对其进行更新。

const queryInsert = manager
    .createQueryBuilder()
    .insert()
    .into(Entity)
    .values(updatedEntities)
    .orUpdate(["column1", "column2", "otherEntityId"], "PK_table_entity")
    .execute();

将运行以下内容：

INSERT INTO entity (
    "id", "column1", "column2", "otherEntityId"
) VALUES 
    ($1, $2, $3, $4), 
    ($5, $6, $7, $8), 
ON CONFLICT 
    ON CONSTRAINT "PK_table_entity" 
    DO UPDATE SET 
        "column1" = EXCLUDED."column1", 
        "column2" = EXCLUDED."column2", 
        "otherEntityId" = EXCLUDED."otherEntityId"

但您需要注意，orUpdate不支持使用Entity关系，您需要传递关系实体的id列。它也不会对命名策略进行任何操作。另一个问题是，它只有在您的pk没有使用@PrimaryGeneratedColumn时才有效（您可以改用@Primary Column）