diff --git a/services/user-feeds/migrations/Migration20250214201450.ts b/services/user-feeds/migrations/Migration20250214201450.ts index 58131fcbd..397b06f7d 100644 --- a/services/user-feeds/migrations/Migration20250214201450.ts +++ b/services/user-feeds/migrations/Migration20250214201450.ts @@ -1,15 +1,17 @@ -import { Migration } from '@mikro-orm/migrations'; +import { Migration } from "@mikro-orm/migrations"; export class Migration20250214201450 extends Migration { - async up(): Promise { this.addSql(`DROP INDEX delivery_record_partitioned_feed_timeframe_count;`); - this.addSql(`CREATE INDEX delivery_record_partitioned_feed_timeframe_count ON delivery_record_partitioned (created_at DESC, feed_id, status);`); + this.addSql( + `CREATE INDEX delivery_record_partitioned_feed_timeframe_count ON delivery_record_partitioned (created_at DESC, feed_id, status);` + ); } async down(): Promise { this.addSql(`DROP INDEX delivery_record_partitioned_feed_timeframe_count;`); - this.addSql(`CREATE INDEX delivery_record_partitioned_feed_timeframe_count ON delivery_record_partitioned (created_at, status, feed_id);`); + this.addSql( + `CREATE INDEX delivery_record_partitioned_feed_timeframe_count ON delivery_record_partitioned (created_at, status, feed_id);` + ); } - } diff --git a/services/user-feeds/migrations/Migration20250225140642.ts b/services/user-feeds/migrations/Migration20250225140642.ts new file mode 100644 index 000000000..fdc3f73fb --- /dev/null +++ b/services/user-feeds/migrations/Migration20250225140642.ts @@ -0,0 +1,21 @@ +import { Migration } from "@mikro-orm/migrations"; + +export class Migration20250225140642 extends Migration { + override async up(): Promise { + this.addSql( + `DROP INDEX delivery_record_partitioned_feed_parent_created_at_desc;` + ); + this.addSql( + `CREATE INDEX delivery_record_partitioned_feed_parent_created_at_desc ON delivery_record_partitioned (feed_id, created_at DESC, parent_id);` + ); + } + + override async down(): Promise { + this.addSql( + `DROP INDEX delivery_record_partitioned_feed_parent_created_at_desc;` + ); + this.addSql( + `CREATE INDEX delivery_record_partitioned_feed_parent_created_at_desc ON delivery_record_partitioned (feed_id, parent_id, created_at DESC);` + ); + } +}