Database script for migration tables

components/infra-proxy-service/storage/postgres/migration/sql/07_migration.down.sql

@@ -0,0 +1,8 @@
+-- drop table migration
+DROP TABLE IF EXISTS migration;
+
+-- drop table migration_type
+DROP TABLE IF EXISTS migration_type;
+
+-- drop table migration_status
+DROP TABLE IF EXISTS migration_status;

components/infra-proxy-service/storage/postgres/migration/sql/07_migration.up.sql

@@ -0,0 +1,34 @@
+--create table migration_type
+CREATE TABLE IF NOT EXISTS migration_type (
+  id                        TEXT PRIMARY KEY,
+  type                      TEXT NOT NULL DEFAULT ''
+);
+
+--create table migration_status
+CREATE TABLE IF NOT EXISTS migration_status (
+  id                        TEXT PRIMARY KEY,
+  status_message            TEXT NOT NULL DEFAULT 'In Progress'
+);
+
+--create table migration
+CREATE TABLE IF NOT EXISTS migration (
+  id                        TEXT PRIMARY KEY,
+  type_id                   TEXT NOT NULL references migration_type(id) ON DELETE RESTRICT,
+  status_id                 TEXT NOT NULL references migration_status(id) ON DELETE RESTRICT,
+  total_succeeded           int,
+  total_skipped             int,
+  total_failed              int,
+  created_at                TIMESTAMPTZ NOT NULL,
+  updated_at                TIMESTAMPTZ NOT NULL
+);
+
+-- Insert rows into migration_type
+INSERT INTO migration_type (id,type)
+VALUES (md5(RANDOM()::TEXT),'user'),
+       (md5(RANDOM()::TEXT),'org');
+
+-- Insert rows into migration_status
+INSERT INTO migration_status(id,status_message)
+VALUES (md5(RANDOM()::TEXT),'In Progress'),
+       (md5(RANDOM()::TEXT),'Completed'),
+       (md5(RANDOM()::TEXT),'Failed');

components/infra-proxy-service/storage/postgres/migration/sql/README.md

@@ -7,3 +7,4 @@
 - [`04_convert_table_to_human_readable_ids.up.sql`](04_convert_table_to_human_readable_ids.up.sql)
 - [`05_remove_orgs_pkey.up.sql`](05_remove_orgs_pkey.up.sql)
 - [`06_user_management.up.sql`](06_user_management.up.sql)
+- [`07_migration.up.sql`](07_migration.up.sql)