Open-ILS/src/sql/Pg/upgrade/0197.schema.metabib.allow-multiple-insert-streams.sql

   1
   2 BEGIN;
   3
   4 INSERT INTO config.upgrade_log (version) VALUES ('0197');
   5
   6 CREATE TABLE config.internal_flag (
   7     name    TEXT    PRIMARY KEY,
   8     value   TEXT,
   9     enabled BOOL    NOT NULL DEFAULT FALSE
  10 );
  11 INSERT INTO config.internal_flag (name) VALUES ('ingest.metarecord_mapping.skip_on_insert');
  12
  13 -- AFTER UPDATE OR INSERT trigger for biblio.record_entry
  14 CREATE OR REPLACE FUNCTION biblio.indexing_ingest_or_delete () RETURNS TRIGGER AS $func$
  15 DECLARE
  16     ind_data        metabib.field_entry_template%ROWTYPE;
  17     old_mr          INT;
  18     tmp_mr          metabib.metarecord%ROWTYPE;
  19     source_count    INT;
  20     deleted_mrs     INT[];
  21     uris            TEXT[];
  22     uri_xml         TEXT;
  23     uri_label       TEXT;
  24     uri_href        TEXT;
  25     uri_use         TEXT;
  26     uri_owner       TEXT;
  27     uri_owner_id    INT;
  28     uri_id          INT;
  29     uri_cn_id       INT;
  30     uri_map_id      INT;
  31 BEGIN
  32
  33     IF TG_OP = 'UPDATE' THEN -- Clean out the cruft
  34         DELETE FROM metabib.metarecord_source_map WHERE source = NEW.id; -- Rid ourselves of the search-estimate-killing linkage
  35     END IF;
  36
  37     IF NEW.deleted IS TRUE THEN
  38         RETURN NEW; -- and we're done
  39     END IF;
  40
  41     IF TG_OP = 'UPDATE' THEN -- Clean out the cruft
  42         DELETE FROM metabib.title_field_entry WHERE source = NEW.id;
  43         DELETE FROM metabib.author_field_entry WHERE source = NEW.id;
  44         DELETE FROM metabib.subject_field_entry WHERE source = NEW.id;
  45         DELETE FROM metabib.keyword_field_entry WHERE source = NEW.id;
  46         DELETE FROM metabib.series_field_entry WHERE source = NEW.id;
  47         DELETE FROM metabib.full_rec WHERE record = NEW.id;
  48         DELETE FROM metabib.rec_descriptor WHERE record = NEW.id;
  49
  50     END IF;
  51
  52     -- Shove the flattened MARC in
  53     INSERT INTO metabib.full_rec (record, tag, ind1, ind2, subfield, value)
  54         SELECT record, tag, ind1, ind2, subfield, value FROM biblio.flatten_marc( NEW.id );
  55
  56     -- And now the indexing data
  57     FOR ind_data IN SELECT * FROM biblio.extract_metabib_field_entry( NEW.id ) LOOP
  58         IF ind_data.field_class = 'title' THEN
  59             INSERT INTO metabib.title_field_entry (field, source, value)
  60                 VALUES (ind_data.field, ind_data.source, ind_data.value);
  61         ELSIF ind_data.field_class = 'author' THEN
  62             INSERT INTO metabib.author_field_entry (field, source, value)
  63                 VALUES (ind_data.field, ind_data.source, ind_data.value);
  64         ELSIF ind_data.field_class = 'subject' THEN
  65             INSERT INTO metabib.subject_field_entry (field, source, value)
  66                 VALUES (ind_data.field, ind_data.source, ind_data.value);
  67         ELSIF ind_data.field_class = 'keyword' THEN
  68             INSERT INTO metabib.keyword_field_entry (field, source, value)
  69                 VALUES (ind_data.field, ind_data.source, ind_data.value);
  70         ELSIF ind_data.field_class = 'series' THEN
  71             INSERT INTO metabib.series_field_entry (field, source, value)
  72                 VALUES (ind_data.field, ind_data.source, ind_data.value);
  73         END IF;
  74     END LOOP;
  75
  76     -- Then, the rec_descriptor
  77     INSERT INTO metabib.rec_descriptor (record, item_type, item_form, bib_level, control_type, enc_level, audience, lit_form, type_mat, cat_form, pub_status, item_lang, vr_format, date1, date2)
  78         SELECT  NEW.id,
  79                 biblio.marc21_extract_fixed_field( NEW.id, 'Type' ),
  80                 biblio.marc21_extract_fixed_field( NEW.id, 'Form' ),
  81                 biblio.marc21_extract_fixed_field( NEW.id, 'BLvl' ),
  82                 biblio.marc21_extract_fixed_field( NEW.id, 'Ctrl' ),
  83                 biblio.marc21_extract_fixed_field( NEW.id, 'ELvl' ),
  84                 biblio.marc21_extract_fixed_field( NEW.id, 'Audn' ),
  85                 biblio.marc21_extract_fixed_field( NEW.id, 'LitF' ),
  86                 biblio.marc21_extract_fixed_field( NEW.id, 'TMat' ),
  87                 biblio.marc21_extract_fixed_field( NEW.id, 'Desc' ),
  88                 biblio.marc21_extract_fixed_field( NEW.id, 'DtSt' ),
  89                 biblio.marc21_extract_fixed_field( NEW.id, 'Lang' ),
  90                 (   SELECT  v.value
  91                       FROM  biblio.marc21_physical_characteristics( NEW.id) p
  92                             JOIN config.marc21_physical_characteristic_subfield_map s ON (s.id = p.subfield)
  93                             JOIN config.marc21_physical_characteristic_value_map v ON (v.id = p.value)
  94                       WHERE p.ptype = 'v' AND s.subfield = 'e'    ),
  95                 biblio.marc21_extract_fixed_field( NEW.id, 'Date1'),
  96                 biblio.marc21_extract_fixed_field( NEW.id, 'Date2');
  97
  98     -- On to URIs ...
  99     uris := oils_xpath('//*[@tag="856" and (@ind1="4" or @ind1="1") and (@ind2="0" or @ind2="1")]',NEW.marc);
 100     IF ARRAY_UPPER(uris,1) > 0 THEN
 101         FOR i IN 1 .. ARRAY_UPPER(uris, 1) LOOP
 102             -- First we pull infot out of the 856
 103             uri_xml     := uris[i];
 104
 105             uri_href    := (oils_xpath('//*[@code="u"]/text()',uri_xml))[1];
 106             CONTINUE WHEN uri_href IS NULL;
 107
 108             uri_label   := (oils_xpath('//*[@code="y"]/text()|//*[@code="3"]/text()|//*[@code="u"]/text()',uri_xml))[1];
 109             CONTINUE WHEN uri_label IS NULL;
 110
 111             uri_owner   := (oils_xpath('//*[@code="9"]/text()|//*[@code="w"]/text()|//*[@code="n"]/text()',uri_xml))[1];
 112             CONTINUE WHEN uri_owner IS NULL;
 113
 114             uri_use     := (oils_xpath('//*[@code="z"]/text()|//*[@code="2"]/text()|//*[@code="n"]/text()',uri_xml))[1];
 115
 116             uri_owner := REGEXP_REPLACE(uri_owner, $re$^.*?\((\w+)\).*$$re$, E'\\1');
 117
 118             SELECT id INTO uri_owner_id FROM actor.org_unit WHERE shortname = uri_owner;
 119             CONTINUE WHEN NOT FOUND;
 120
 121             -- now we look for a matching uri
 122             SELECT id INTO uri_id FROM asset.uri WHERE label = uri_label AND href = uri_href AND use_restriction = uri_use AND active;
 123             IF NOT FOUND THEN -- create one
 124                 INSERT INTO asset.uri (label, href, use_restriction) VALUES (uri_label, uri_href, uri_use);
 125                 SELECT id INTO uri_id FROM asset.uri WHERE label = uri_label AND href = uri_href AND use_restriction = uri_use AND active;
 126             END IF;
 127
 128             -- we need a call number to link through
 129             SELECT id INTO uri_cn_id FROM asset.call_number WHERE owning_lib = uri_owner_id AND record = NEW.id AND label = '##URI##' AND NOT deleted;
 130             IF NOT FOUND THEN
 131                 INSERT INTO asset.call_number (owning_lib, record, create_date, edit_date, creator, editor, label)
 132                     VALUES (uri_owner_id, NEW.id, 'now', 'now', NEW.editor, NEW.editor, '##URI##');
 133                 SELECT id INTO uri_cn_id FROM asset.call_number WHERE owning_lib = uri_owner_id AND record = NEW.id AND label = '##URI##' AND NOT deleted;
 134             END IF;
 135
 136             -- now, link them if they're not already
 137             SELECT id INTO uri_map_id FROM asset.uri_call_number_map WHERE call_number = uri_cn_id AND uri = uri_id;
 138             IF NOT FOUND THEN
 139                 INSERT INTO asset.uri_call_number_map (call_number, uri) VALUES (uri_cn_id, uri_id);
 140             END IF;
 141
 142         END LOOP;
 143     END IF;
 144
 145     -- And, finally, metarecord mapping!
 146
 147     PERFORM * FROM config.internal_flag WHERE name = 'ingest.metarecord_mapping.skip_on_insert' AND enabled;
 148
 149     IF NOT FOUND OR TG_OP = 'UPDATE' THEN
 150         FOR tmp_mr IN SELECT  m.* FROM  metabib.metarecord m JOIN metabib.metarecord_source_map s ON (s.metarecord = m.id) WHERE s.source = NEW.id LOOP
 151
 152             IF old_mr IS NULL AND NEW.fingerprint = tmp_mr.fingerprint THEN -- Find the first fingerprint-matching
 153                 old_mr := tmp_mr.id;
 154             ELSE
 155                 SELECT COUNT(*) INTO source_count FROM metabib.metarecord_source_map WHERE metarecord = tmp_mr.id;
 156                 IF source_count = 0 THEN -- No other records
 157                     deleted_mrs := ARRAY_APPEND(deleted_mrs, tmp_mr.id);
 158                     DELETE FROM metabib.metarecord WHERE id = tmp_mr.id;
 159                 END IF;
 160             END IF;
 161
 162         END LOOP;
 163
 164         IF old_mr IS NULL THEN -- we found no suitable, preexisting MR based on old source maps
 165             SELECT id INTO old_mr FROM metabib.metarecord WHERE fingerprint = NEW.fingerprint; -- is there one for our current fingerprint?
 166             IF old_mr IS NULL THEN -- nope, create one and grab its id
 167                 INSERT INTO metabib.metarecord ( fingerprint, master_record ) VALUES ( NEW.fingerprint, NEW.id );
 168                 SELECT id INTO old_mr FROM metabib.metarecord WHERE fingerprint = NEW.fingerprint;
 169             ELSE -- indeed there is. update it with a null cache and recalcualated master record
 170                 UPDATE  metabib.metarecord
 171                   SET   mods = NULL,
 172                         master_record = ( SELECT id FROM biblio.record_entry WHERE fingerprint = NEW.fingerprint ORDER BY quality DESC LIMIT 1)
 173                   WHERE id = old_mr;
 174             END IF;
 175         ELSE -- there was one we already attached to, update its mods cache and master_record
 176             UPDATE  metabib.metarecord
 177               SET   mods = NULL,
 178                     master_record = ( SELECT id FROM biblio.record_entry WHERE fingerprint = NEW.fingerprint ORDER BY quality DESC LIMIT 1)
 179               WHERE id = old_mr;
 180         END IF;
 181
 182         INSERT INTO metabib.metarecord_source_map (metarecord, source) VALUES (old_mr, NEW.id); -- new source mapping
 183
 184         UPDATE action.hold_request SET target = old_mr WHERE target IN ( SELECT explode_array(deleted_mrs) ) AND hold_type = 'M'; -- if we had to delete any MRs above, make sure their holds are moved
 185     END IF;
 186
 187     RETURN NEW;
 188
 189 END;
 190 $func$ LANGUAGE PLPGSQL;
 191
 192 COMMIT;
 193