ci: attempt to fix Deployment
This commit is contained in:
@@ -1,11 +1,20 @@
|
||||
-- CreateEnum
|
||||
CREATE TYPE "SyncJobType" AS ENUM ('FULL_SYNC', 'INCREMENTAL_SYNC');
|
||||
-- CreateEnum (idempotent)
|
||||
DO $$
|
||||
BEGIN
|
||||
IF NOT EXISTS (SELECT 1 FROM pg_type WHERE typname = 'SyncJobType') THEN
|
||||
CREATE TYPE "SyncJobType" AS ENUM ('FULL_SYNC', 'INCREMENTAL_SYNC');
|
||||
END IF;
|
||||
END $$;
|
||||
|
||||
-- CreateEnum
|
||||
CREATE TYPE "SyncJobStatus" AS ENUM ('QUEUED', 'RUNNING', 'COMPLETED', 'FAILED', 'TIMED_OUT');
|
||||
DO $$
|
||||
BEGIN
|
||||
IF NOT EXISTS (SELECT 1 FROM pg_type WHERE typname = 'SyncJobStatus') THEN
|
||||
CREATE TYPE "SyncJobStatus" AS ENUM ('QUEUED', 'RUNNING', 'COMPLETED', 'FAILED', 'TIMED_OUT');
|
||||
END IF;
|
||||
END $$;
|
||||
|
||||
-- CreateTable
|
||||
CREATE TABLE "SyncJobRun" (
|
||||
-- CreateTable (idempotent)
|
||||
CREATE TABLE IF NOT EXISTS "SyncJobRun" (
|
||||
"id" TEXT NOT NULL,
|
||||
"jobType" "SyncJobType" NOT NULL,
|
||||
"status" "SyncJobStatus" NOT NULL DEFAULT 'QUEUED',
|
||||
@@ -19,8 +28,7 @@ CREATE TABLE "SyncJobRun" (
|
||||
CONSTRAINT "SyncJobRun_pkey" PRIMARY KEY ("id")
|
||||
);
|
||||
|
||||
-- CreateTable
|
||||
CREATE TABLE "SyncStepLog" (
|
||||
CREATE TABLE IF NOT EXISTS "SyncStepLog" (
|
||||
"id" TEXT NOT NULL,
|
||||
"syncJobRunId" TEXT NOT NULL,
|
||||
"tableName" TEXT NOT NULL,
|
||||
@@ -37,5 +45,14 @@ CREATE TABLE "SyncStepLog" (
|
||||
CONSTRAINT "SyncStepLog_pkey" PRIMARY KEY ("id")
|
||||
);
|
||||
|
||||
-- AddForeignKey
|
||||
ALTER TABLE "SyncStepLog" ADD CONSTRAINT "SyncStepLog_syncJobRunId_fkey" FOREIGN KEY ("syncJobRunId") REFERENCES "SyncJobRun"("id") ON DELETE CASCADE ON UPDATE CASCADE;
|
||||
-- AddForeignKey (idempotent)
|
||||
DO $$
|
||||
BEGIN
|
||||
IF NOT EXISTS (
|
||||
SELECT 1 FROM information_schema.table_constraints
|
||||
WHERE constraint_name = 'SyncStepLog_syncJobRunId_fkey'
|
||||
) THEN
|
||||
ALTER TABLE "SyncStepLog" ADD CONSTRAINT "SyncStepLog_syncJobRunId_fkey"
|
||||
FOREIGN KEY ("syncJobRunId") REFERENCES "SyncJobRun"("id") ON DELETE CASCADE ON UPDATE CASCADE;
|
||||
END IF;
|
||||
END $$;
|
||||
|
||||
Reference in New Issue
Block a user