move array functions to a separate file

[migration-tools.git] / sql / base / 21-fixed-fields.sql

diff --git a/sql/base/21-fixed-fields.sql b/sql/base/21-fixed-fields.sql
index 6b42ce1..fe9c3d0 100644 (file)
--- a/sql/base/21-fixed-fields.sql
+++ b/sql/base/21-fixed-fields.sql
@@ -249,7 +249,7 @@ DECLARE
     icon    TEXT[];
     vlist   INTEGER[];
 BEGIN
-    SELECT reingest_staged_record_attributes(rid) INTO vlist;
+    SELECT migration_tools.reingest_staged_record_attributes(rid) INTO vlist;
 
     RETURN QUERY SELECT ctype, code, value FROM config.coded_value_map WHERE id IN (SELECT UNNEST(vlist));
 END;
@@ -260,7 +260,7 @@ DECLARE
        search  TEXT[];
        vlist   INTEGER[];
 BEGIN
-       SELECT reingest_staged_record_attributes(rid) INTO vlist;
+       SELECT migration_tools.reingest_staged_record_attributes(rid) INTO vlist;
 
        SELECT ARRAY_AGG(code) FROM config.coded_value_map WHERE id IN (SELECT UNNEST(vlist)) 
                AND ctype = 'search_format' INTO search;
@@ -274,7 +274,7 @@ DECLARE
     search  TEXT[];
     vlist   INTEGER[];
 BEGIN
-    SELECT reingest_staged_record_attributes(rid) INTO vlist;
+    SELECT migration_tools.reingest_staged_record_attributes(rid) INTO vlist;
 
     SELECT ARRAY_AGG(code) FROM config.coded_value_map WHERE id IN (SELECT UNNEST(vlist))
         AND ctype = 'search_format' INTO search;
@@ -289,7 +289,7 @@ DECLARE
     search  TEXT[];
     vlist   INTEGER[];
 BEGIN
-    SELECT reingest_staged_record_attributes(rid) INTO vlist;
+    SELECT migration_tools.reingest_staged_record_attributes(rid) INTO vlist;
 
     SELECT ARRAY_AGG(code) FROM config.coded_value_map WHERE id IN (SELECT UNNEST(vlist))
         AND ctype = 'search_format' INTO search;
@@ -317,77 +317,6 @@ BEGIN
 END;
 $func$ LANGUAGE PLPGSQL;
 
-DROP AGGREGATE IF EXISTS anyarray_agg(anyarray);
-CREATE AGGREGATE anyarray_agg(anyarray) (
-        SFUNC = anyarray_agg_statefunc,
-        STYPE = anyarray
-);
-COMMENT ON AGGREGATE anyarray_agg(anyarray) IS
-'Concatenates arrays into a single array when aggregating.';
-
-DROP FUNCTION IF EXISTS migration_tools.anyarray_agg_statefunc(anyarray, anyarray);
-CREATE FUNCTION anyarray_agg_statefunc(state anyarray, value anyarray)
-        RETURNS anyarray AS
-$BODY$
-        SELECT array_cat($1, $2)
-$BODY$
-        LANGUAGE sql IMMUTABLE;
-COMMENT ON FUNCTION anyarray_agg_statefunc(anyarray, anyarray) IS
-'Used internally by aggregate anyarray_agg(anyarray).';
-
-DROP FUNCTION IF EXISTS migration_tools.anyarray_sort(anyarray);
-CREATE OR REPLACE FUNCTION migration_tools.anyarray_sort(with_array anyarray)
-    RETURNS anyarray AS
-$BODY$
-    DECLARE
-        return_array with_array%TYPE := '{}';
-    BEGIN
-        SELECT ARRAY_AGG(sorted_vals.val) AS array_value
-        FROM
-            (   SELECT UNNEST(with_array) AS val
-                ORDER BY val
-            ) AS sorted_vals INTO return_array;
-        RETURN return_array;
-    END;
-$BODY$ LANGUAGE plpgsql;
-
-DROP FUNCTION IF EXISTS migration_tools.anyarray_uniq(anyarray);
-CREATE OR REPLACE FUNCTION migration_tools.anyarray_uniq(with_array anyarray)
-    RETURNS anyarray AS
-$BODY$
-    DECLARE
-        -- The variable used to track iteration over "with_array".
-        loop_offset integer;
-
-        -- The array to be returned by this function.
-        return_array with_array%TYPE := '{}';
-    BEGIN
-        IF with_array IS NULL THEN
-            return NULL;
-        END IF;
-
-        IF with_array = '{}' THEN
-            return return_array;
-        END IF;
-
-        -- Iterate over each element in "concat_array".
-        FOR loop_offset IN ARRAY_LOWER(with_array, 1)..ARRAY_UPPER(with_array, 1) LOOP
-            IF with_array[loop_offset] IS NULL THEN
-                IF NOT EXISTS
-                    ( SELECT 1 FROM UNNEST(return_array) AS s(a)
-                    WHERE a IS NULL )
-                THEN return_array = ARRAY_APPEND(return_array, with_array[loop_offset]);
-                END IF;
-            -- When an array contains a NULL value, ANY() returns NULL instead of FALSE...
-            ELSEIF NOT(with_array[loop_offset] = ANY(return_array)) OR NOT(NULL IS DISTINCT FROM (with_array[loop_offset] = ANY(return_array))) THEN
-                return_array = ARRAY_APPEND(return_array, with_array[loop_offset]);
-            END IF;
-        END LOOP;
-
-    RETURN return_array;
- END;
-$BODY$ LANGUAGE plpgsql;
-
 DROP FUNCTION IF EXISTS migration_tools.modify_staged_fixed_fields (BIGINT,TEXT);
 CREATE OR REPLACE FUNCTION migration_tools.modify_staged_fixed_fields (bib_id BIGINT, xcode TEXT)
  RETURNS BOOLEAN
@@ -418,7 +347,7 @@ BEGIN
        ELSE
                ysrform_exclude := '';
        END IF;
-    SELECT modify_fixed_fields(marc,xcode,xitype,xiform,xphy,xphyv,xphyp,xbiblevel,yiform_exclude,ysrform_exclude) FROM biblio_record_entry_legacy WHERE id = bib_id INTO r;
+    SELECT migration_tools.modify_fixed_fields(marc,xcode,xitype,xiform,xphy,xphyv,xphyp,xbiblevel,yiform_exclude,ysrform_exclude) FROM biblio_record_entry_legacy WHERE id = bib_id INTO r;
     UPDATE biblio_record_entry_legacy SET marc = r WHERE id = bib_id;
     RETURN TRUE;
 END;