Open-ILS/src/sql/Pg/upgrade/0762.schema.partitioned-ingest.sql

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