fix: Add ON DELETE CASCADE to redshift snapshots. (#880)

cloudquery · May 11, 2022 · 0009d0a · 0009d0a
1 parent 00197b5
commit 0009d0a
Show file tree

Hide file tree

Showing 4 changed files with 26 additions and 0 deletions.
diff --git a/resources/provider/migrations/postgres/32_v0.11.6.down.sql b/resources/provider/migrations/postgres/32_v0.11.6.down.sql
@@ -0,0 +1,6 @@
+-- aws_redshift_snapshots
+ALTER TABLE IF EXISTS aws_redshift_snapshots DROP CONSTRAINT aws_redshift_snapshots_cluster_cq_id_fkey;
+ALTER TABLE IF EXISTS aws_redshift_snapshots
+    ADD CONSTRAINT aws_redshift_snapshots_cluster_cq_id_fkey
+    FOREIGN KEY (cluster_cq_id)
+    REFERENCES aws_redshift_clusters(cq_id);
diff --git a/resources/provider/migrations/postgres/32_v0.11.6.up.sql b/resources/provider/migrations/postgres/32_v0.11.6.up.sql
@@ -0,0 +1,7 @@
+-- aws_redshift_snapshots
+ALTER TABLE IF EXISTS aws_redshift_snapshots DROP CONSTRAINT aws_redshift_snapshots_cluster_cq_id_fkey;
+ALTER TABLE IF EXISTS aws_redshift_snapshots
+    ADD CONSTRAINT aws_redshift_snapshots_cluster_cq_id_fkey
+    FOREIGN KEY (cluster_cq_id)
+    REFERENCES aws_redshift_clusters(cq_id)
+    ON DELETE CASCADE;
diff --git a/resources/provider/migrations/timescale/32_v0.11.6.down.sql b/resources/provider/migrations/timescale/32_v0.11.6.down.sql
@@ -0,0 +1,6 @@
+-- aws_redshift_snapshots
+ALTER TABLE IF EXISTS aws_redshift_snapshots DROP CONSTRAINT aws_redshift_snapshots_cluster_cq_id_fkey;
+ALTER TABLE IF EXISTS aws_redshift_snapshots
+    ADD CONSTRAINT aws_redshift_snapshots_cluster_cq_id_fkey
+    FOREIGN KEY (cq_fetch_date, cluster_cq_id)
+    REFERENCES aws_redshift_clusters(cq_fetch_date, cq_id);
diff --git a/resources/provider/migrations/timescale/32_v0.11.6.up.sql b/resources/provider/migrations/timescale/32_v0.11.6.up.sql
@@ -0,0 +1,7 @@
+-- aws_redshift_snapshots
+ALTER TABLE IF EXISTS aws_redshift_snapshots DROP CONSTRAINT aws_redshift_snapshots_cluster_cq_id_fkey;
+ALTER TABLE IF EXISTS aws_redshift_snapshots
+    ADD CONSTRAINT aws_redshift_snapshots_cluster_cq_id_fkey
+    FOREIGN KEY (cq_fetch_date, cluster_cq_id)
+    REFERENCES aws_redshift_clusters(cq_fetch_date, cq_id)
+    ON DELETE CASCADE;