Open-ILS/src/sql/Pg/upgrade/0687.schema.enhance_reingest.sql

   1 -- Evergreen DB patch 0687.schema.enhance_reingest.sql
   2 --
   3 -- FIXME: insert description of change, if needed
   4 --
   5 BEGIN;
   6
   7
   8 -- check whether patch can be applied
   9 SELECT evergreen.upgrade_deps_block_check('0687', :eg_version);
  10
  11 -- FIXME: add/check SQL statements to perform the upgrade
  12 -- New function def
  13 CREATE OR REPLACE FUNCTION metabib.reingest_metabib_field_entries( bib_id BIGINT, skip_facet BOOL DEFAULT FALSE, skip_browse BOOL DEFAULT FALSE, skip_search BOOL DEFAULT FALSE ) RETURNS VOID AS $func$
  14 DECLARE
  15     fclass          RECORD;
  16     ind_data        metabib.field_entry_template%ROWTYPE;
  17     mbe_row         metabib.browse_entry%ROWTYPE;
  18     mbe_id          BIGINT;
  19 BEGIN
  20     PERFORM * FROM config.internal_flag WHERE name = 'ingest.assume_inserts_only' AND enabled;
  21     IF NOT FOUND THEN
  22         IF NOT skip_search THEN
  23             FOR fclass IN SELECT * FROM config.metabib_class LOOP
  24                 -- RAISE NOTICE 'Emptying out %', fclass.name;
  25                 EXECUTE $$DELETE FROM metabib.$$ || fclass.name || $$_field_entry WHERE source = $$ || bib_id;
  26             END LOOP;
  27         END IF;
  28         IF NOT skip_facet THEN
  29             DELETE FROM metabib.facet_entry WHERE source = bib_id;
  30         END IF;
  31         IF NOT skip_browse THEN
  32             DELETE FROM metabib.browse_entry_def_map WHERE source = bib_id;
  33         END IF;
  34     END IF;
  35
  36     FOR ind_data IN SELECT * FROM biblio.extract_metabib_field_entry( bib_id ) LOOP
  37         IF ind_data.field < 0 THEN
  38             ind_data.field = -1 * ind_data.field;
  39         END IF;
  40
  41         IF ind_data.facet_field AND NOT skip_facet THEN
  42             INSERT INTO metabib.facet_entry (field, source, value)
  43                 VALUES (ind_data.field, ind_data.source, ind_data.value);
  44         END IF;
  45
  46         IF ind_data.browse_field AND NOT skip_browse THEN
  47             -- A caveat about this SELECT: this should take care of replacing
  48             -- old mbe rows when data changes, but not if normalization (by
  49             -- which I mean specifically the output of
  50             -- evergreen.oils_tsearch2()) changes.  It may or may not be
  51             -- expensive to add a comparison of index_vector to index_vector
  52             -- to the WHERE clause below.
  53             SELECT INTO mbe_row * FROM metabib.browse_entry WHERE value = ind_data.value;
  54             IF FOUND THEN
  55                 mbe_id := mbe_row.id;
  56             ELSE
  57                 INSERT INTO metabib.browse_entry (value) VALUES
  58                     (metabib.browse_normalize(ind_data.value, ind_data.field));
  59                 mbe_id := CURRVAL('metabib.browse_entry_id_seq'::REGCLASS);
  60             END IF;
  61
  62             INSERT INTO metabib.browse_entry_def_map (entry, def, source)
  63                 VALUES (mbe_id, ind_data.field, ind_data.source);
  64         END IF;
  65
  66         IF ind_data.search_field AND NOT skip_search THEN
  67             EXECUTE $$
  68                 INSERT INTO metabib.$$ || ind_data.field_class || $$_field_entry (field, source, value)
  69                     VALUES ($$ ||
  70                         quote_literal(ind_data.field) || $$, $$ ||
  71                         quote_literal(ind_data.source) || $$, $$ ||
  72                         quote_literal(ind_data.value) ||
  73                     $$);$$;
  74         END IF;
  75
  76     END LOOP;
  77
  78     RETURN;
  79 END;
  80 $func$ LANGUAGE PLPGSQL;
  81
  82 -- Delete old one
  83 DROP FUNCTION IF EXISTS metabib.reingest_metabib_field_entries(BIGINT);
  84
  85
  86 COMMIT;