/* NAGPRA Report Filed Data Migration to Version 7.0
-- NAGPRA Report Filed field group changed to repeating group.
-- Migrates existing data to the new nagpraReportFiledGroup repeating group table.
- 1) "NAGPRA report filed": collectionobjects_nagpra.nagprareportfiled
+ 1) "NAGPRA report filed": collectionobjects_nagpra.nagprareportfiled
Copy to nagprareportfiledgroup.nagprareportfiled as a new record.
Create new hierarchy record for primarytype = 'nagpraReportFiledGroup'
2) "NAGPRA report filed by": collectionobjects_nagpra.nagprareportfiledby
BEGIN
- -- If public.collectionobjects_nagpra does not exist or contains 0 records, there is nothing to migrate.
- IF (select to_regclass('collectionobjects_nagpra')::text = 'collectionobjects_nagpra') AND (SELECT count(*) from collectionobjects_nagpra) > 0 THEN
-
- DROP TABLE IF EXISTS temp_cn;
-
- CREATE TEMP TABLE temp_cn AS
- SELECT
- uuid_generate_v4()::varchar AS new_nrfgid,
- cn.id as cnid,
- cn.nagprareportfiled,
- cn.nagprareportfiledby,
- uuid_generate_v4()::varchar AS new_sdgid,
- sdg.*
- FROM collectionobjects_nagpra cn
- LEFT OUTER JOIN hierarchy hsdg ON (cn.id = hsdg.parentid and hsdg.name = 'collectionobjects_nagpra:nagpraReportFiledDate')
- LEFT OUTER JOIN structureddategroup sdg ON (hsdg.id = sdg.id)
- ORDER BY cnid;
-
- DROP TABLE IF EXISTS temp_nrfg;
-
- CREATE TEMP TABLE temp_nrfg AS
- SELECT
- hnrfg.parentid as nrfg_parentid,
- nrfg.nagprareportfiled,
- nrfg.nagprareportfiledby,
- sdg.datedisplaydate
- FROM nagprareportfiledgroup nrfg
- LEFT OUTER JOIN hierarchy hnrfg ON (nrfg.id = hnrfg.id)
- LEFT OUTER JOIN hierarchy hsdg ON (nrfg.id = hsdg.parentid AND hsdg.name = 'nagpraReportFiledDate')
- LEFT OUTER JOIN structureddategroup sdg ON (hsdg.id = sdg.id);
-
- -- Check for existing nagpraReportFiledGroup records that match collectionobjects_nagpra records.
- PERFORM cn.cnid
- FROM temp_cn cn
- LEFT OUTER JOIN temp_nrfg nrfg ON (cn.cnid = nrfg.nrfg_parentid)
- WHERE
- coalesce(cn.nagprareportfiled::text, '') || '|' || coalesce(cn.nagprareportfiledby, '')
- || '|' || coalesce(cn.datedisplaydate, '') !=
- coalesce(nrfg.nagprareportfiled::text, '') || '|' || coalesce(nrfg.nagprareportfiledby, '')
- || '|' || coalesce(nrfg.datedisplaydate, '')
- AND cn.new_nrfgid NOT IN (
- SELECT c.new_nrfgid FROM temp_cn c JOIN temp_nrfg n ON (c.cnid = n.nrfg_parentid)
+ -- If public.collectionobjects_nagpra does not exist, there is nothing to migrate.
+ IF (select to_regclass('collectionobjects_nagpra')::text = 'collectionobjects_nagpra') THEN
+
+ -- If public.collectionobjects_nagpra contains 0 records, there is nothing to migrate.
+ IF (SELECT count(*) from collectionobjects_nagpra) > 0 THEN
+
+ DROP TABLE IF EXISTS temp_cn;
+
+ CREATE TEMP TABLE temp_cn AS
+ SELECT
+ uuid_generate_v4()::varchar AS new_nrfgid,
+ cn.id as cnid,
+ cn.nagprareportfiled,
+ cn.nagprareportfiledby,
+ uuid_generate_v4()::varchar AS new_sdgid,
+ sdg.*
+ FROM collectionobjects_nagpra cn
+ LEFT OUTER JOIN hierarchy hsdg ON (cn.id = hsdg.parentid and hsdg.name = 'collectionobjects_nagpra:nagpraReportFiledDate')
+ LEFT OUTER JOIN structureddategroup sdg ON (hsdg.id = sdg.id)
+ ORDER BY cnid;
+
+ DROP TABLE IF EXISTS temp_nrfg;
+
+ CREATE TEMP TABLE temp_nrfg AS
+ SELECT
+ hnrfg.parentid as nrfg_parentid,
+ nrfg.nagprareportfiled,
+ nrfg.nagprareportfiledby,
+ sdg.datedisplaydate
+ FROM nagprareportfiledgroup nrfg
+ LEFT OUTER JOIN hierarchy hnrfg ON (nrfg.id = hnrfg.id)
+ LEFT OUTER JOIN hierarchy hsdg ON (nrfg.id = hsdg.parentid AND hsdg.name = 'nagpraReportFiledDate')
+ LEFT OUTER JOIN structureddategroup sdg ON (hsdg.id = sdg.id);
+
+ -- Check for existing nagpraReportFiledGroup records that match collectionobjects_nagpra records.
+ PERFORM DISTINCT cn.cnid
+ FROM temp_cn cn
+ LEFT OUTER JOIN temp_nrfg nrfg ON (cn.cnid = nrfg.nrfg_parentid)
WHERE
- coalesce(c.nagprareportfiled::text, '') || '|' || coalesce(c.nagprareportfiledby, '')
- || '|' || coalesce(c.datedisplaydate, '') =
- coalesce(n.nagprareportfiled::text, '') || '|' || coalesce(n.nagprareportfiledby, '')
- || '|' || coalesce(n.datedisplaydate, ''));
+ coalesce(cn.nagprareportfiled::text, '') || '|' || coalesce(cn.nagprareportfiledby, '')
+ || '|' || coalesce(cn.datedisplaydate, '') !=
+ coalesce(nrfg.nagprareportfiled::text, '') || '|' || coalesce(nrfg.nagprareportfiledby, '')
+ || '|' || coalesce(nrfg.datedisplaydate, '')
+ AND cn.new_nrfgid NOT IN (
+ SELECT c.new_nrfgid FROM temp_cn c JOIN temp_nrfg n ON (c.cnid = n.nrfg_parentid)
+ WHERE
+ coalesce(c.nagprareportfiled::text, '') || '|' || coalesce(c.nagprareportfiledby, '')
+ || '|' || coalesce(c.datedisplaydate, '') =
+ coalesce(n.nagprareportfiled::text, '') || '|' || coalesce(n.nagprareportfiledby, '')
+ || '|' || coalesce(n.datedisplaydate, ''));
- GET DIAGNOSTICS rc = ROW_COUNT;
+ GET DIAGNOSTICS rc = ROW_COUNT;
- IF rc = 0 THEN
+ IF rc = 0 THEN
- RAISE NOTICE 'INFO: Nothing to migrate.';
+ RAISE NOTICE 'INFO: Nothing to migrate.';
- ELSE
+ ELSE
- RAISE NOTICE 'INFO: % NAGPRA Report Filed records to migrate.', rc;
+ RAISE NOTICE 'INFO: % NAGPRA Report Filed records to migrate.', rc;
- FOR trow IN
- SELECT cn.*
- FROM temp_cn cn
- LEFT OUTER JOIN temp_nrfg nrfg ON (cn.cnid = nrfg.nrfg_parentid)
- WHERE
- coalesce(cn.nagprareportfiled::text, '') || '|' || coalesce(cn.nagprareportfiledby, '')
- || '|' || coalesce(cn.datedisplaydate, '') !=
- coalesce(nrfg.nagprareportfiled::text, '') || '|' || coalesce(nrfg.nagprareportfiledby, '')
- || '|' || coalesce(nrfg.datedisplaydate, '')
- AND cn.new_nrfgid NOT IN (
- SELECT c.new_nrfgid FROM temp_cn c JOIN temp_nrfg n ON (c.cnid = n.nrfg_parentid)
+ FOR trow IN
+ SELECT DISTINCT cn.*
+ FROM temp_cn cn
+ LEFT OUTER JOIN temp_nrfg nrfg ON (cn.cnid = nrfg.nrfg_parentid)
WHERE
- coalesce(c.nagprareportfiled::text, '') || '|' || coalesce(c.nagprareportfiledby, '')
- || '|' || coalesce(c.datedisplaydate, '') =
- coalesce(n.nagprareportfiled::text, '') || '|' || coalesce(n.nagprareportfiledby, '')
- || '|' || coalesce(n.datedisplaydate, ''))
-
- LOOP
-
- -- Check for duplicates in collectionobjects_nagpra
- IF (SELECT count(*) FROM temp_cn where cnid = trow.cnid) > 1 THEN
-
- RAISE NOTICE 'ERROR: More than 1 collectionobjects_nagpra record found for id = "%".', trow.cnid;
-
- ELSE -- Migrate NAGPRA Report Filed data:
-
- RAISE NOTICE 'INFO: MIGRATING NAGPRA Report Filed data for CollObjID = "%"', trow.cnid;
-
- -- Get max pos value for nagpraReportFiledGroup records:
- SELECT coalesce(max(pos), -1) + 1 INTO newpos
- FROM hierarchy
- WHERE parentid = trow.cnid
- AND primarytype = 'nagpraReportFiledGroup';
-
- -- Create new nagpraReportFiledGroup hierarchy record for collectionobjects_nagpra record
- INSERT INTO hierarchy (
- id,
- parentid,
- pos,
- name,
- isproperty,
- primarytype)
- VALUES (
- trow.new_nrfgid,
- trow.cnid,
- newpos,
- 'collectionobjects_nagpra:nagpraReportFiledGroupList',
- True,
- 'nagpraReportFiledGroup');
-
- GET DIAGNOSTICS rc = ROW_COUNT;
- RAISE NOTICE ' : INSERTED % into hierarchy, id = "%", pos %, nagpraReportFiledGroup.', rc, trow.new_nrfgid, newpos;
-
- -- Create new nagpraReportFiledGroup record from collectionobjects_nagpra record
- INSERT INTO nagprareportfiledgroup (
- id,
- nagprareportfiled,
- nagprareportfiledby)
- VALUES (
- trow.new_nrfgid,
- trow.nagprareportfiled,
- trow.nagprareportfiledby);
-
- -- Create new nagpraReportFiledDate hierarchy record for collectionobjects_nagpra record
- INSERT INTO hierarchy (
- id,
- parentid,
- name,
- isproperty,
- primarytype)
- VALUES (
- trow.new_sdgid,
- trow.new_nrfgid,
- 'nagpraReportFiledDate',
- True,
- 'structuredDateGroup');
-
- GET DIAGNOSTICS rc = ROW_COUNT;
- RAISE NOTICE ' : INSERTED % into hierarchy, id = "%", nagpraReportFiledDate.', rc, trow.new_sdgid;
-
- -- Migrate/Create new structuredDateGroup record from collectionobjects_nagpra record
- IF trow.id IS NOT NULL THEN
- INSERT INTO structureddategroup (
+ coalesce(cn.nagprareportfiled::text, '') || '|' || coalesce(cn.nagprareportfiledby, '')
+ || '|' || coalesce(cn.datedisplaydate, '') !=
+ coalesce(nrfg.nagprareportfiled::text, '') || '|' || coalesce(nrfg.nagprareportfiledby, '')
+ || '|' || coalesce(nrfg.datedisplaydate, '')
+ AND cn.new_nrfgid NOT IN (
+ SELECT c.new_nrfgid FROM temp_cn c JOIN temp_nrfg n ON (c.cnid = n.nrfg_parentid)
+ WHERE
+ coalesce(c.nagprareportfiled::text, '') || '|' || coalesce(c.nagprareportfiledby, '')
+ || '|' || coalesce(c.datedisplaydate, '') =
+ coalesce(n.nagprareportfiled::text, '') || '|' || coalesce(n.nagprareportfiledby, '')
+ || '|' || coalesce(n.datedisplaydate, ''))
+
+ LOOP
+
+ -- Check for duplicates in collectionobjects_nagpra
+ IF (SELECT count(*) FROM temp_cn where cnid = trow.cnid) > 1 THEN
+
+ RAISE NOTICE 'ERROR: More than 1 collectionobjects_nagpra record found for id = "%".', trow.cnid;
+
+ ELSE -- Migrate NAGPRA Report Filed data:
+
+ RAISE NOTICE 'INFO: MIGRATING NAGPRA Report Filed data for CollObjID = "%"', trow.cnid;
+
+ -- Get max pos value for nagpraReportFiledGroup records:
+ SELECT coalesce(max(pos), -1) + 1 INTO newpos
+ FROM hierarchy
+ WHERE parentid = trow.cnid
+ AND primarytype = 'nagpraReportFiledGroup';
+
+ -- Create new nagpraReportFiledGroup hierarchy record for collectionobjects_nagpra record
+ INSERT INTO hierarchy (
+ id,
+ parentid,
+ pos,
+ name,
+ isproperty,
+ primarytype)
+ VALUES (
+ trow.new_nrfgid,
+ trow.cnid,
+ newpos,
+ 'collectionobjects_nagpra:nagpraReportFiledGroupList',
+ True,
+ 'nagpraReportFiledGroup');
+
+ GET DIAGNOSTICS rc = ROW_COUNT;
+ RAISE NOTICE ' : INSERTED % into hierarchy, id = "%", pos %, nagpraReportFiledGroup.', rc, trow.new_nrfgid, newpos;
+
+ -- Create new nagpraReportFiledGroup record from collectionobjects_nagpra record
+ INSERT INTO nagprareportfiledgroup (
id,
- dateearliestsinglequalifier,
- scalarvaluescomputed,
- datelatestyear,
- datelatestday,
- dateassociation,
- dateearliestsingleera,
- datedisplaydate,
- dateearliestsinglecertainty,
- datelatestera,
- dateearliestsinglequalifiervalue,
- datelatestcertainty,
- dateearliestsingleyear,
- datelatestqualifier,
- datelatestqualifiervalue,
- dateearliestsinglequalifierunit,
- dateperiod,
- dateearliestscalarvalue,
- datelatestmonth,
- datenote,
- datelatestscalarvalue,
- datelatestqualifierunit,
- dateearliestsingleday,
- dateearliestsinglemonth)
+ nagprareportfiled,
+ nagprareportfiledby)
+ VALUES (
+ trow.new_nrfgid,
+ trow.nagprareportfiled,
+ trow.nagprareportfiledby);
+
+ -- Create new nagpraReportFiledDate hierarchy record for collectionobjects_nagpra record
+ INSERT INTO hierarchy (
+ id,
+ parentid,
+ name,
+ isproperty,
+ primarytype)
VALUES (
trow.new_sdgid,
- trow.dateearliestsinglequalifier,
- trow.scalarvaluescomputed,
- trow.datelatestyear,
- trow.datelatestday,
- trow.dateassociation,
- trow.dateearliestsingleera,
- trow.datedisplaydate,
- trow.dateearliestsinglecertainty,
- trow.datelatestera,
- trow.dateearliestsinglequalifiervalue,
- trow.datelatestcertainty,
- trow.dateearliestsingleyear,
- trow.datelatestqualifier,
- trow.datelatestqualifiervalue,
- trow.dateearliestsinglequalifierunit,
- trow.dateperiod,
- trow.dateearliestscalarvalue,
- trow.datelatestmonth,
- trow.datenote,
- trow.datelatestscalarvalue,
- trow.datelatestqualifierunit,
- trow.dateearliestsingleday,
- trow.dateearliestsinglemonth);
-
+ trow.new_nrfgid,
+ 'nagpraReportFiledDate',
+ True,
+ 'structuredDateGroup');
+
GET DIAGNOSTICS rc = ROW_COUNT;
- RAISE NOTICE ' : INSERTED % into structuredDatetGroup, id = "%".', rc, trow.new_sdgid;
-
+ RAISE NOTICE ' : INSERTED % into hierarchy, id = "%", nagpraReportFiledDate.', rc, trow.new_sdgid;
+
+ -- Migrate/Create new structuredDateGroup record from collectionobjects_nagpra record
+ IF trow.id IS NOT NULL THEN
+ INSERT INTO structureddategroup (
+ id,
+ dateearliestsinglequalifier,
+ scalarvaluescomputed,
+ datelatestyear,
+ datelatestday,
+ dateassociation,
+ dateearliestsingleera,
+ datedisplaydate,
+ dateearliestsinglecertainty,
+ datelatestera,
+ dateearliestsinglequalifiervalue,
+ datelatestcertainty,
+ dateearliestsingleyear,
+ datelatestqualifier,
+ datelatestqualifiervalue,
+ dateearliestsinglequalifierunit,
+ dateperiod,
+ dateearliestscalarvalue,
+ datelatestmonth,
+ datenote,
+ datelatestscalarvalue,
+ datelatestqualifierunit,
+ dateearliestsingleday,
+ dateearliestsinglemonth)
+ VALUES (
+ trow.new_sdgid,
+ trow.dateearliestsinglequalifier,
+ trow.scalarvaluescomputed,
+ trow.datelatestyear,
+ trow.datelatestday,
+ trow.dateassociation,
+ trow.dateearliestsingleera,
+ trow.datedisplaydate,
+ trow.dateearliestsinglecertainty,
+ trow.datelatestera,
+ trow.dateearliestsinglequalifiervalue,
+ trow.datelatestcertainty,
+ trow.dateearliestsingleyear,
+ trow.datelatestqualifier,
+ trow.datelatestqualifiervalue,
+ trow.dateearliestsinglequalifierunit,
+ trow.dateperiod,
+ trow.dateearliestscalarvalue,
+ trow.datelatestmonth,
+ trow.datenote,
+ trow.datelatestscalarvalue,
+ trow.datelatestqualifierunit,
+ trow.dateearliestsingleday,
+ trow.dateearliestsinglemonth);
+
+ GET DIAGNOSTICS rc = ROW_COUNT;
+ RAISE NOTICE ' : INSERTED % into structuredDatetGroup, id = "%".', rc, trow.new_sdgid;
+
+ END IF;
+
END IF;
-
- END IF;
-
- END LOOP;
- END IF;
+ END LOOP;
+
+ END IF;
+
+ ELSE
+
+ RAISE NOTICE 'collectionobjects_nagpra has 0 records';
+ END IF;
ELSE
- RAISE NOTICE 'collectionobjects_nagpra does not exist or has 0 records';
+ RAISE NOTICE 'collectionobjects_nagpra does not exist';
END IF;
projects / tmp / jakarta-migration.git / commitdiff