summary refs log tree commit diff
path: root/src/util/migration/postgres/1776178642013-Int8PrimaryKeysWebhooks.ts
diff options
context:
space:
mode:
Diffstat (limited to 'src/util/migration/postgres/1776178642013-Int8PrimaryKeysWebhooks.ts')
-rw-r--r--src/util/migration/postgres/1776178642013-Int8PrimaryKeysWebhooks.ts23
1 files changed, 23 insertions, 0 deletions
diff --git a/src/util/migration/postgres/1776178642013-Int8PrimaryKeysWebhooks.ts b/src/util/migration/postgres/1776178642013-Int8PrimaryKeysWebhooks.ts
new file mode 100644

index 00000000..a5fdfbdf --- /dev/null +++ b/src/util/migration/postgres/1776178642013-Int8PrimaryKeysWebhooks.ts
@@ -0,0 +1,23 @@ +import { MigrationInterface, QueryRunner } from "typeorm"; + +export class Int8PrimaryKeysWebhooks1776178642013 implements MigrationInterface { + name = "Int8PrimaryKeysWebhooks1776178642013"; + + public async up(queryRunner: QueryRunner): Promise<void> { + await this.convertPks(queryRunner, "int8"); + } + + public async down(queryRunner: QueryRunner): Promise<void> { + await this.convertPks(queryRunner, "varchar"); + } + + private async convertPks(queryRunner: QueryRunner, to: string) { + // webhooks + // -> messages + await queryRunner.query(`ALTER TABLE messages DROP CONSTRAINT "FK_f83c04bcf1df4e5c0e7a52ed348";`); //webhook_id + await queryRunner.query(`ALTER TABLE messages ALTER COLUMN webhook_id TYPE ${to} USING webhook_id::${to}`); + // and finally, cleanup + await queryRunner.query(`ALTER TABLE webhooks ALTER COLUMN id TYPE ${to} USING id::${to};`); + await queryRunner.query(`ALTER TABLE public.messages ADD CONSTRAINT "FK_f83c04bcf1df4e5c0e7a52ed348" FOREIGN KEY (webhook_id) REFERENCES webhooks(id);`); + } +}