perf(Impact View): Concurrent Refresh on impact view

Makes the Impact Materialized View able to be refreshed concurrently by adding an unique index
Vizzuality · Nov 8, 2022 · 309d795 · 309d795
1 parent a31a77d
commit 309d795
Show file tree

Hide file tree

Showing 2 changed files with 19 additions and 1 deletion.
diff --git a/api/src/migrations/1667497567675-ImpactMaterializedViewUniqueIndex.ts b/api/src/migrations/1667497567675-ImpactMaterializedViewUniqueIndex.ts
@@ -0,0 +1,18 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class ImpactMaterializedViewUniqueIndex1667497567675
+  implements MigrationInterface
+{
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(`
+        DROP INDEX IF EXISTS idx_georegion_h3data_indexed;
+        CREATE UNIQUE INDEX idx_georegion_h3data_indexed ON impact_materialized_view ("geoRegionId", "h3DataId", "h3index") INCLUDE ("value");
+      `);
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(`
+        DROP INDEX IF EXISTS idx_georegion_h3data_indexed;
+      `);
+  }
+}
diff --git a/api/src/modules/indicator-records/indicator-record.entity.ts b/api/src/modules/indicator-records/indicator-record.entity.ts
@@ -108,7 +108,7 @@ export class IndicatorRecord extends TimestampedBaseEntity {
 
   static updateImpactView(): Promise<void> {
     return getManager().query(
-      `REFRESH MATERIALIZED VIEW ${IMPACT_VIEW_NAME} WITH DATA`,
+      `REFRESH MATERIALIZED VIEW CONCURRENTLY ${IMPACT_VIEW_NAME} WITH DATA`,
     );
   }
 }