273 patch partitioningspartidparents

.github/CODEOWNERS

@@ -1 +1 @@
-* @benedeki @lsulak @TebaleloS @Zejnilovic @dk1844 @salamonpavel
+* @benedeki @lsulak @TebaleloS @Zejnilovic @dk1844 @salamonpavel @ABLL526

database/README.md

@@ -32,3 +32,10 @@ to remove them or
 sbt flywayBaseline 
 ```
 to set the current state as the baseline.
+
+```zsh
+docker kill atum_db
+docker rm atum_db
+docker run --name=atum_db -e POSTGRES_PASSWORD=postgres -e POSTGRES_DB=atum_db -p 5432:5432 -d postgres:16
+sbt flywayMigrate
+```

database/src/main/postgres/runs/V0.3.0.1__get_ancestors.sql

@@ -0,0 +1,141 @@
+/*
+ * Copyright 2021 ABSA Group Limited
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+CREATE OR REPLACE FUNCTION runs.get_ancestors(
+    IN i_partitioning_id    BIGINT,
+    IN i_limit              INT DEFAULT 5,
+    IN i_offset             BIGINT DEFAULT 0,
+    OUT status              INTEGER,
+    OUT status_text         TEXT,
+    OUT ancestor_id         BIGINT,
+    OUT partitioning        JSONB,
+    OUT author              TEXT,
+    OUT has_more            BOOLEAN
+)  RETURNS SETOF record AS
+$$
+    -------------------------------------------------------------------------------
+--
+-- Function: runs.get_ancestors(1)
+--      Returns Ancestors' partition ID for the given id
+--
+-- Parameters:
+--      i_partitioning_id   - id that we asking the Ancestors for
+--      i_limit             - (optional) maximum number of partitionings to return, default is 5
+--      i_offset            - (optional) offset to use for pagination, default is 0
+--
+-- Returns:
+--      status              - Status code
+--      status_text         - Status message
+--      ancestor_id         - ID of Ancestor partition
+--      partitioning        - partitioning data of ancestor
+--      author              - author of the Ancestor partitioning
+--      has_more            - Flag indicating if there are more partitionings available
+
+-- Status codes:
+--      11 - OK
+--      41 - Partitioning not found
+--
+-------------------------------------------------------------------------------
+DECLARE
+    flow_id BIGINT[];
+    var BIGINT;
+    partitionCreateAt TIMESTAMP;
+    _has_more BOOLEAN;
+
+BEGIN
+
+    PERFORM 1 FROM runs.partitionings WHERE id_partitioning = i_partitioning_id;
+    IF NOT FOUND THEN
+        status := 41;
+        status_text := 'Child Partitioning not found';
+        has_more := FALSE;
+        RETURN NEXT;
+        RETURN;
+    END IF;
+
+    SELECT created_at FROM runs.partitionings WHERE id_partitioning = i_partitioning_id INTO partitionCreateAt;
+
+    flow_id := array(
+            SELECT fk_flow AS flow_id
+            FROM flows.partitioning_to_flow
+            WHERE fk_partitioning = i_partitioning_id
+    );
+
+    IF cardinality(flow_id) = 0
+    THEN
+        status := 41;
+        status_text := 'Flow not found';
+        has_more := FALSE;
+        RETURN NEXT;
+        RETURN;
+    END IF;
+
+    FOREACH var IN ARRAY flow_id LOOP
+        IF i_limit IS NOT NULL THEN
+            SELECT count(*) > i_limit
+            FROM flows.partitioning_to_flow PTF
+            WHERE PTF.fk_flow = var
+            LIMIT i_limit + 1 OFFSET i_offset
+            INTO _has_more;
+        ELSE
+            _has_more := false;
+        END IF;
+    END LOOP;
+
+    RETURN QUERY
+        SELECT
+            11 AS status,
+            'OK' AS status_text,
+            P.id_partitioning AS ancestor_id,
+            P.partitioning AS partitioning,
+            P.created_by AS author,
+            _has_more AS has_more
+        FROM
+            runs.partitionings P
+            INNER JOIN
+            flows.partitioning_to_flow PF
+                ON  PF.fk_partitioning = P.id_partitioning
+            INNER JOIN
+            (SELECT * FROM flows.partitioning_to_flow OLD_PF WHERE OLD_PF.fk_partitioning = i_partitioning_id) PF2
+                ON Pf2.fk_flow = PF.fk_flow
+        WHERE
+            P.id_partitioning < i_partitioning_id
+        AND
+            P.created_at <= partitionCreateAt
+        GROUP BY P.id_partitioning
+        ORDER BY
+            P.id_partitioning,
+            P.created_at DESC
+        LIMIT i_limit
+        OFFSET i_offset;
+
+    IF FOUND THEN
+        status := 11;
+        status_text := 'OK';
+    ELSE
+        status := 41;
+        status_text := 'Ancestor Partitioning not found';
+        has_more := FALSE;
+    END IF;
+    RETURN NEXT;
+    RETURN;
+
+END;
+$$
+    LANGUAGE plpgsql VOLATILE SECURITY DEFINER;
+
+ALTER FUNCTION runs.get_ancestors(BIGINT, INT, BIGINT) OWNER TO atum_owner;
+GRANT EXECUTE ON FUNCTION runs.get_ancestors(BIGINT, INT, BIGINT) TO atum_user;