Open-ILS/src/sql/Pg/upgrade/0488.function.maintain_901_tcn.sql

   1 BEGIN;
   2
   3 INSERT INTO config.upgrade_log (version) VALUES ('0488'); -- dbs
   4
   5 CREATE OR REPLACE FUNCTION maintain_901 () RETURNS TRIGGER AS $func$
   6 DECLARE
   7     use_id_for_tcn BOOLEAN;
   8 BEGIN
   9     -- Remove any existing 901 fields before we insert the authoritative one
  10     NEW.marc := REGEXP_REPLACE(NEW.marc, E'<datafield\s*[^<>]*?\s*tag="901".+?</datafield>', '', 'g');
  11
  12     IF TG_TABLE_SCHEMA = 'biblio' THEN
  13         -- Set TCN value to record ID?
  14         SELECT enabled FROM config.global_flag INTO use_id_for_tcn
  15             WHERE name = 'cat.bib.use_id_for_tcn';
  16
  17         IF use_id_for_tcn = 't' THEN
  18             NEW.tcn_value := NEW.id;
  19         END IF;
  20
  21         NEW.marc := REGEXP_REPLACE(
  22             NEW.marc,
  23             E'(</(?:[^:]*?:)?record>)',
  24             E'<datafield tag="901" ind1=" " ind2=" ">' ||
  25                 '<subfield code="a">' || NEW.tcn_value || E'</subfield>' ||
  26                 '<subfield code="b">' || NEW.tcn_source || E'</subfield>' ||
  27                 '<subfield code="c">' || NEW.id || E'</subfield>' ||
  28                 '<subfield code="t">' || TG_TABLE_SCHEMA || E'</subfield>' ||
  29                 CASE WHEN NEW.owner IS NOT NULL THEN '<subfield code="o">' || NEW.owner || E'</subfield>' ELSE '' END ||
  30                 CASE WHEN NEW.share_depth IS NOT NULL THEN '<subfield code="d">' || NEW.share_depth || E'</subfield>' ELSE '' END ||
  31              E'</datafield>\\1'
  32         );
  33     ELSIF TG_TABLE_SCHEMA = 'authority' THEN
  34         NEW.marc := REGEXP_REPLACE(
  35             NEW.marc,
  36             E'(</(?:[^:]*?:)?record>)',
  37             E'<datafield tag="901" ind1=" " ind2=" ">' ||
  38                 '<subfield code="c">' || NEW.id || E'</subfield>' ||
  39                 '<subfield code="t">' || TG_TABLE_SCHEMA || E'</subfield>' ||
  40              E'</datafield>\\1'
  41         );
  42     ELSIF TG_TABLE_SCHEMA = 'serial' THEN
  43         NEW.marc := REGEXP_REPLACE(
  44             NEW.marc,
  45             E'(</(?:[^:]*?:)?record>)',
  46             E'<datafield tag="901" ind1=" " ind2=" ">' ||
  47                 '<subfield code="c">' || NEW.id || E'</subfield>' ||
  48                 '<subfield code="t">' || TG_TABLE_SCHEMA || E'</subfield>' ||
  49                 '<subfield code="o">' || NEW.owning_lib || E'</subfield>' ||
  50                 CASE WHEN NEW.record IS NOT NULL THEN '<subfield code="r">' || NEW.record || E'</subfield>' ELSE '' END ||
  51              E'</datafield>\\1'
  52         );
  53     ELSE
  54         NEW.marc := REGEXP_REPLACE(
  55             NEW.marc,
  56             E'(</(?:[^:]*?:)?record>)',
  57             E'<datafield tag="901" ind1=" " ind2=" ">' ||
  58                 '<subfield code="c">' || NEW.id || E'</subfield>' ||
  59                 '<subfield code="t">' || TG_TABLE_SCHEMA || E'</subfield>' ||
  60              E'</datafield>\\1'
  61         );
  62     END IF;
  63
  64     RETURN NEW;
  65 END;
  66 $func$ LANGUAGE PLPGSQL;
  67
  68 COMMIT;