3 INSERT INTO config.upgrade_log (version) VALUES ('0512'); -- miker
5 CREATE TABLE biblio.peer_type (
7 name TEXT NOT NULL UNIQUE -- i18n
10 CREATE TABLE biblio.peer_bib_copy_map (
11 id SERIAL PRIMARY KEY,
12 peer_type INT NOT NULL REFERENCES biblio.peer_type (id),
13 peer_record BIGINT NOT NULL REFERENCES biblio.record_entry (id),
14 target_copy BIGINT NOT NULL -- can't use fkey because of acp subtables
16 CREATE INDEX peer_bib_copy_map_record_idx ON biblio.peer_bib_copy_map (peer_record);
17 CREATE INDEX peer_bib_copy_map_copy_idx ON biblio.peer_bib_copy_map (target_copy);
19 DROP TABLE asset.opac_visible_copies;
20 CREATE TABLE asset.opac_visible_copies (
21 id BIGSERIAL primary key,
27 INSERT INTO biblio.peer_type (id,name) VALUES
28 (1,oils_i18n_gettext(1,'Bound Volume','bpt','name')),
29 (2,oils_i18n_gettext(2,'Bilingual','bpt','name')),
30 (3,oils_i18n_gettext(3,'Back-to-back','bpt','name')),
31 (4,oils_i18n_gettext(4,'Set','bpt','name')),
32 (5,oils_i18n_gettext(5,'e-Reader Preload','bpt','name'));
34 SELECT SETVAL('biblio.peer_type_id_seq'::TEXT, 100);
36 CREATE OR REPLACE FUNCTION search.query_parser_fts (
42 param_locations INT[],
49 ) RETURNS SETOF search.search_result AS $func$
52 current_res search.search_result%ROWTYPE;
53 search_org_list INT[];
61 core_cursor REFCURSOR;
66 deleted_count INT := 0;
67 visible_count INT := 0;
68 excluded_count INT := 0;
72 check_limit := COALESCE( param_check, 1000 );
73 core_limit := COALESCE( param_limit, 25000 );
74 core_offset := COALESCE( param_offset, 0 );
76 -- core_skip_chk := COALESCE( param_skip_chk, 1 );
78 IF param_search_ou > 0 THEN
79 IF param_depth IS NOT NULL THEN
80 SELECT array_accum(distinct id) INTO search_org_list FROM actor.org_unit_descendants( param_search_ou, param_depth );
82 SELECT array_accum(distinct id) INTO search_org_list FROM actor.org_unit_descendants( param_search_ou );
84 ELSIF param_search_ou < 0 THEN
85 SELECT array_accum(distinct org_unit) INTO search_org_list FROM actor.org_lasso_map WHERE lasso = -param_search_ou;
86 ELSIF param_search_ou = 0 THEN
87 -- reserved for user lassos (ou_buckets/type='lasso') with ID passed in depth ... hack? sure.
90 OPEN core_cursor FOR EXECUTE param_query;
94 FETCH core_cursor INTO core_result;
96 EXIT WHEN total_count >= core_limit;
98 total_count := total_count + 1;
100 CONTINUE WHEN total_count NOT BETWEEN core_offset + 1 AND check_limit + core_offset;
102 check_count := check_count + 1;
104 PERFORM 1 FROM biblio.record_entry b WHERE NOT b.deleted AND b.id IN ( SELECT * FROM search.explode_array( core_result.records ) );
106 -- RAISE NOTICE ' % were all deleted ... ', core_result.records;
107 deleted_count := deleted_count + 1;
112 FROM biblio.record_entry b
113 JOIN config.bib_source s ON (b.source = s.id)
115 AND b.id IN ( SELECT * FROM search.explode_array( core_result.records ) );
118 -- RAISE NOTICE ' % were all transcendant ... ', core_result.records;
119 visible_count := visible_count + 1;
121 current_res.id = core_result.id;
122 current_res.rel = core_result.rel;
126 SELECT COUNT(DISTINCT s.source) INTO tmp_int FROM metabib.metarecord_source_map s WHERE s.metarecord = core_result.id;
130 current_res.record = core_result.records[1];
132 current_res.record = NULL;
135 RETURN NEXT current_res;
141 FROM asset.call_number cn
142 JOIN asset.uri_call_number_map map ON (map.call_number = cn.id)
143 JOIN asset.uri uri ON (map.uri = uri.id)
145 AND cn.label = '##URI##'
147 AND ( param_locations IS NULL OR array_upper(param_locations, 1) IS NULL )
148 AND cn.record IN ( SELECT * FROM search.explode_array( core_result.records ) )
149 AND cn.owning_lib IN ( SELECT * FROM search.explode_array( search_org_list ) )
153 -- RAISE NOTICE ' % have at least one URI ... ', core_result.records;
154 visible_count := visible_count + 1;
156 current_res.id = core_result.id;
157 current_res.rel = core_result.rel;
161 SELECT COUNT(DISTINCT s.source) INTO tmp_int FROM metabib.metarecord_source_map s WHERE s.metarecord = core_result.id;
165 current_res.record = core_result.records[1];
167 current_res.record = NULL;
170 RETURN NEXT current_res;
175 IF param_statuses IS NOT NULL AND array_upper(param_statuses, 1) > 0 THEN
178 FROM asset.call_number cn
179 JOIN asset.copy cp ON (cp.call_number = cn.id)
182 AND cp.status IN ( SELECT * FROM search.explode_array( param_statuses ) )
183 AND cn.record IN ( SELECT * FROM search.explode_array( core_result.records ) )
184 AND cp.circ_lib IN ( SELECT * FROM search.explode_array( search_org_list ) )
189 FROM biblio.peer_bib_copy_map pr
190 JOIN asset.copy cp ON (cp.id = pr.target_copy)
192 AND cp.status IN ( SELECT * FROM search.explode_array( param_statuses ) )
193 AND pr.peer_record IN ( SELECT * FROM search.explode_array( core_result.records ) )
194 AND cp.circ_lib IN ( SELECT * FROM search.explode_array( search_org_list ) )
198 -- RAISE NOTICE ' % and multi-home linked records were all status-excluded ... ', core_result.records;
199 excluded_count := excluded_count + 1;
206 IF param_locations IS NOT NULL AND array_upper(param_locations, 1) > 0 THEN
209 FROM asset.call_number cn
210 JOIN asset.copy cp ON (cp.call_number = cn.id)
213 AND cp.location IN ( SELECT * FROM search.explode_array( param_locations ) )
214 AND cn.record IN ( SELECT * FROM search.explode_array( core_result.records ) )
215 AND cp.circ_lib IN ( SELECT * FROM search.explode_array( search_org_list ) )
220 FROM biblio.peer_bib_copy_map pr
221 JOIN asset.copy cp ON (cp.id = pr.target_copy)
223 AND cp.location IN ( SELECT * FROM search.explode_array( param_locations ) )
224 AND pr.peer_record IN ( SELECT * FROM search.explode_array( core_result.records ) )
225 AND cp.circ_lib IN ( SELECT * FROM search.explode_array( search_org_list ) )
229 -- RAISE NOTICE ' % and multi-home linked records were all copy_location-excluded ... ', core_result.records;
230 excluded_count := excluded_count + 1;
237 IF staff IS NULL OR NOT staff THEN
240 FROM asset.opac_visible_copies
241 WHERE circ_lib IN ( SELECT * FROM search.explode_array( search_org_list ) )
242 AND record IN ( SELECT * FROM search.explode_array( core_result.records ) )
247 FROM biblio.peer_bib_copy_map pr
248 JOIN asset.opac_visible_copies cp ON (cp.copy_id = pr.target_copy)
249 WHERE cp.circ_lib IN ( SELECT * FROM search.explode_array( search_org_list ) )
250 AND pr.peer_record IN ( SELECT * FROM search.explode_array( core_result.records ) )
255 -- RAISE NOTICE ' % and multi-home linked records were all visibility-excluded ... ', core_result.records;
256 excluded_count := excluded_count + 1;
264 FROM asset.call_number cn
265 JOIN asset.copy cp ON (cp.call_number = cn.id)
268 AND cp.circ_lib IN ( SELECT * FROM search.explode_array( search_org_list ) )
269 AND cn.record IN ( SELECT * FROM search.explode_array( core_result.records ) )
275 FROM biblio.peer_bib_copy_map pr
276 JOIN asset.copy cp ON (cp.id = pr.target_copy)
278 AND cp.circ_lib IN ( SELECT * FROM search.explode_array( search_org_list ) )
279 AND pr.peer_record IN ( SELECT * FROM search.explode_array( core_result.records ) )
285 FROM asset.call_number cn
286 WHERE cn.record IN ( SELECT * FROM search.explode_array( core_result.records ) )
290 -- RAISE NOTICE ' % and multi-home linked records were all visibility-excluded ... ', core_result.records;
291 excluded_count := excluded_count + 1;
300 visible_count := visible_count + 1;
302 current_res.id = core_result.id;
303 current_res.rel = core_result.rel;
307 SELECT COUNT(DISTINCT s.source) INTO tmp_int FROM metabib.metarecord_source_map s WHERE s.metarecord = core_result.id;
311 current_res.record = core_result.records[1];
313 current_res.record = NULL;
316 RETURN NEXT current_res;
318 IF visible_count % 1000 = 0 THEN
319 -- RAISE NOTICE ' % visible so far ... ', visible_count;
324 current_res.id = NULL;
325 current_res.rel = NULL;
326 current_res.record = NULL;
327 current_res.total = total_count;
328 current_res.checked = check_count;
329 current_res.deleted = deleted_count;
330 current_res.visible = visible_count;
331 current_res.excluded = excluded_count;
335 RETURN NEXT current_res;
338 $func$ LANGUAGE PLPGSQL;
340 CREATE OR REPLACE FUNCTION unapi.holdings_xml (bid BIGINT, ouid INT, org TEXT, depth INT DEFAULT NULL, includes TEXT[] DEFAULT NULL::TEXT[], slimit INT DEFAULT NULL, soffset INT DEFAULT NULL, include_xmlns BOOL DEFAULT TRUE) RETURNS XML AS $F$
344 CASE WHEN $8 THEN 'http://open-ils.org/spec/holdings/v1' ELSE NULL END AS xmlns,
345 CASE WHEN ('bre' = ANY ('{acn,auri}'::TEXT[] || $5)) THEN 'tag:open-ils.org:U2@bre/' || $1 || '/' || $3 ELSE NULL END AS id
349 (SELECT XMLAGG(XMLELEMENT::XML) FROM (
352 XMLATTRIBUTES('public' as type, depth, org_unit, coalesce(transcendant,0) as transcendant, available, visible as count, unshadow)
354 FROM asset.opac_ou_record_copy_count($2, $1)
358 XMLATTRIBUTES('staff' as type, depth, org_unit, coalesce(transcendant,0) as transcendant, available, visible as count, unshadow)
360 FROM asset.staff_ou_record_copy_count($2, $1)
365 WHEN ('bmp' = ANY ($5)) THEN
366 XMLELEMENT( name monograph_parts,
367 XMLAGG((SELECT unapi.bmp( id, 'xml', 'monograph_part', evergreen.array_remove_item_by_value( evergreen.array_remove_item_by_value($5,'bre'), 'holdings_xml'), $3, $4, $6, $7, FALSE) FROM biblio.monograph_part WHERE record = $1))
371 CASE WHEN ('acn' = ANY ('{acn,auri}'::TEXT[] || $5)) THEN
374 (SELECT XMLAGG(acn) FROM (
375 SELECT unapi.acn(acn.id,'xml','volume',evergreen.array_remove_item_by_value(evergreen.array_remove_item_by_value('{acn,auri}'::TEXT[] || $5,'holdings_xml'),'bre'), $3, $4, $6, $7, FALSE)
376 FROM asset.call_number acn
377 WHERE acn.record = $1
381 JOIN actor.org_unit_descendants(
386 FROM actor.org_unit_type aout
387 JOIN actor.org_unit aou ON (aou.ou_type = aout.id AND aou.id = $2)
390 ) aoud ON (acp.circ_lib = aoud.id)
393 ORDER BY label_sortkey
399 CASE WHEN ('ssub' = ANY ('{acn,auri}'::TEXT[] || $5)) THEN
402 (SELECT XMLAGG(ssub) FROM (
403 SELECT unapi.ssub(id,'xml','subscription','{}'::TEXT[], $3, $4, $6, $7, FALSE)
404 FROM serial.subscription
405 WHERE record_entry = $1
409 CASE WHEN ('acp' = ANY ($5)) THEN
412 (SELECT XMLAGG(acp) FROM (
413 SELECT unapi.acp(p.target_copy,'xml','copy','{}'::TEXT[], $3, $4, $6, $7, FALSE)
414 FROM biblio.peer_bib_copy_map p
415 JOIN asset.copy c ON (p.target_copy = c.id)
416 WHERE NOT c.deleted AND peer_record = $1
423 CREATE OR REPLACE FUNCTION unapi.acp ( obj_id BIGINT, format TEXT, ename TEXT, includes TEXT[], org TEXT, depth INT DEFAULT NULL, slimit INT DEFAULT NULL, soffset INT DEFAULT NULL, include_xmlns BOOL DEFAULT TRUE ) RETURNS XML AS $F$
427 CASE WHEN $9 THEN 'http://open-ils.org/spec/holdings/v1' ELSE NULL END AS xmlns,
428 'tag:open-ils.org:U2@acp/' || id AS id,
429 create_date, edit_date, copy_number, circulate, deposit,
430 ref, holdable, deleted, deposit_amount, price, barcode,
431 circ_modifier, circ_as_type, opac_visible
433 unapi.ccs( status, $2, 'status', evergreen.array_remove_item_by_value($4,'acp'), $5, $6, $7, $8, FALSE),
434 unapi.acl( location, $2, 'location', evergreen.array_remove_item_by_value($4,'acp'), $5, $6, $7, $8, FALSE),
435 unapi.aou( circ_lib, $2, 'circ_lib', evergreen.array_remove_item_by_value($4,'acp'), $5, $6, $7, $8),
436 unapi.aou( circ_lib, $2, 'circlib', evergreen.array_remove_item_by_value($4,'acp'), $5, $6, $7, $8),
437 CASE WHEN ('acn' = ANY ($4)) THEN unapi.acn( call_number, $2, 'call_number', evergreen.array_remove_item_by_value($4,'acp'), $5, $6, $7, $8, FALSE) ELSE NULL END,
438 XMLELEMENT( name copy_notes,
440 WHEN ('acpn' = ANY ($4)) THEN
441 XMLAGG((SELECT unapi.acpn( id, 'xml', 'copy_note', evergreen.array_remove_item_by_value($4,'acp'), $5, $6, $7, $8, FALSE) FROM asset.copy_note WHERE owning_copy = cp.id AND pub))
445 XMLELEMENT( name statcats,
447 WHEN ('ascecm' = ANY ($4)) THEN
448 XMLAGG((SELECT unapi.ascecm( stat_cat_entry, 'xml', 'statcat', evergreen.array_remove_item_by_value($4,'acp'), $5, $6, $7, $8, FALSE) FROM asset.stat_cat_entry_copy_map WHERE owning_copy = cp.id))
452 XMLELEMENT( name foreign_records,
454 WHEN ('bre' = ANY ($4)) THEN
455 XMLAGG((SELECT unapi.bre(peer_record,'marcxml','record','{}'::TEXT[], $5, $6, $7, $8, FALSE) FROM biblio.peer_bib_copy_map WHERE target_copy = cp.id))
461 WHEN ('bmp' = ANY ($4)) THEN
462 XMLELEMENT( name monograph_parts,
463 XMLAGG((SELECT unapi.bmp( part, 'xml', 'monograph_part', evergreen.array_remove_item_by_value($4,'acp'), $5, $6, $7, $8, FALSE) FROM asset.copy_part_map WHERE target_copy = cp.id))
470 GROUP BY id, status, location, circ_lib, call_number, create_date, edit_date, copy_number, circulate, deposit, ref, holdable, deleted, deposit_amount, price, barcode, circ_modifier, circ_as_type, opac_visible;
473 CREATE OR REPLACE FUNCTION asset.refresh_opac_visible_copies_mat_view () RETURNS VOID AS $$
475 TRUNCATE TABLE asset.opac_visible_copies;
477 INSERT INTO asset.opac_visible_copies (copy_id, circ_lib, record)
478 SELECT cp.id, cp.circ_lib, cn.record
480 JOIN asset.call_number cn ON (cn.id = cp.call_number)
481 JOIN actor.org_unit a ON (cp.circ_lib = a.id)
482 JOIN asset.copy_location cl ON (cp.location = cl.id)
483 JOIN config.copy_status cs ON (cp.status = cs.id)
484 JOIN biblio.record_entry b ON (cn.record = b.id)
493 SELECT cp.id, cp.circ_lib, pbcm.peer_record AS record
495 JOIN biblio.peer_bib_copy_map pbcm ON (pbcm.target_copy = cp.id)
496 JOIN actor.org_unit a ON (cp.circ_lib = a.id)
497 JOIN asset.copy_location cl ON (cp.location = cl.id)
498 JOIN config.copy_status cs ON (cp.status = cs.id)
506 COMMENT ON FUNCTION asset.refresh_opac_visible_copies_mat_view() IS $$
507 Rebuild the copy OPAC visibility cache. Useful during migrations.
510 SELECT asset.refresh_opac_visible_copies_mat_view();
511 CREATE INDEX opac_visible_copies_idx1 on asset.opac_visible_copies (record, circ_lib);
512 CREATE INDEX opac_visible_copies_copy_id_idx on asset.opac_visible_copies (copy_id);
513 CREATE UNIQUE INDEX opac_visible_copies_once_per_record_idx on asset.opac_visible_copies (copy_id, record);
515 CREATE OR REPLACE FUNCTION asset.cache_copy_visibility () RETURNS TRIGGER as $func$
519 do_add BOOLEAN := false;
520 do_remove BOOLEAN := false;
523 INSERT INTO asset.opac_visible_copies (copy_id, circ_lib, record)
524 SELECT id, circ_lib, record FROM (
525 SELECT cp.id, cp.circ_lib, cn.record, cn.id AS call_number
527 JOIN asset.call_number cn ON (cn.id = cp.call_number)
528 JOIN actor.org_unit a ON (cp.circ_lib = a.id)
529 JOIN asset.copy_location cl ON (cp.location = cl.id)
530 JOIN config.copy_status cs ON (cp.status = cs.id)
531 JOIN biblio.record_entry b ON (cn.record = b.id)
540 SELECT cp.id, cp.circ_lib, pbcm.peer_record AS record, NULL AS call_number
542 JOIN biblio.peer_bib_copy_map pbcm ON (pbcm.target_copy = cp.id)
543 JOIN actor.org_unit a ON (cp.circ_lib = a.id)
544 JOIN asset.copy_location cl ON (cp.location = cl.id)
545 JOIN config.copy_status cs ON (cp.status = cs.id)
555 remove_query := $$ DELETE FROM asset.opac_visible_copies WHERE copy_id IN ( SELECT id FROM asset.copy WHERE $$;
557 IF TG_TABLE_NAME = 'peer_bib_copy_map' THEN
558 IF TG_OP = 'INSERT' THEN
559 add_query := add_query || 'WHERE x.id = ' || NEW.target_copy || ' AND x.record = ' || NEW.peer_record || ';';
563 remove_query := 'DELETE FROM asset.opac_visible_copies WHERE copy_id = ' || OLD.target_copy || ' AND record = ' || OLD.peer_record || ';';
564 EXECUTE remove_query;
569 IF TG_OP = 'INSERT' THEN
571 IF TG_TABLE_NAME IN ('copy', 'unit') THEN
572 add_query := add_query || 'WHERE x.id = ' || NEW.id || ';';
580 -- handle items first, since with circulation activity
581 -- their statuses change frequently
582 IF TG_TABLE_NAME IN ('copy', 'unit') THEN
584 IF OLD.location <> NEW.location OR
585 OLD.call_number <> NEW.call_number OR
586 OLD.status <> NEW.status OR
587 OLD.circ_lib <> NEW.circ_lib THEN
588 -- any of these could change visibility, but
589 -- we'll save some queries and not try to calculate
590 -- the change directly
595 IF OLD.deleted <> NEW.deleted THEN
603 IF OLD.opac_visible <> NEW.opac_visible THEN
604 IF OLD.opac_visible THEN
606 ELSIF NOT do_remove THEN -- handle edge case where deleted item
607 -- is also marked opac_visible
615 DELETE FROM asset.opac_visible_copies WHERE id = NEW.id;
618 add_query := add_query || 'WHERE x.id = ' || NEW.id || ';';
626 IF TG_TABLE_NAME IN ('call_number', 'record_entry') THEN -- these have a 'deleted' column
628 IF OLD.deleted AND NEW.deleted THEN -- do nothing
632 ELSIF NEW.deleted THEN -- remove rows
634 IF TG_TABLE_NAME = 'call_number' THEN
635 DELETE FROM asset.opac_visible_copies WHERE id IN (SELECT id FROM asset.copy WHERE call_number = NEW.id);
636 ELSIF TG_TABLE_NAME = 'record_entry' THEN
637 DELETE FROM asset.opac_visible_copies WHERE record = NEW.id;
642 ELSIF OLD.deleted THEN -- add rows
644 IF TG_TABLE_NAME IN ('copy','unit') THEN
645 add_query := add_query || 'WHERE x.id = ' || NEW.id || ';';
646 ELSIF TG_TABLE_NAME = 'call_number' THEN
647 add_query := add_query || 'WHERE x.call_number = ' || NEW.id || ';';
648 ELSIF TG_TABLE_NAME = 'record_entry' THEN
649 add_query := add_query || 'WHERE x.record = ' || NEW.id || ';';
659 IF TG_TABLE_NAME = 'call_number' THEN
661 IF OLD.record <> NEW.record THEN
662 -- call number is linked to different bib
663 remove_query := remove_query || 'call_number = ' || NEW.id || ');';
664 EXECUTE remove_query;
665 add_query := add_query || 'WHERE x.call_number = ' || NEW.id || ';';
673 IF TG_TABLE_NAME IN ('record_entry') THEN
674 RETURN NEW; -- don't have 'opac_visible'
677 -- actor.org_unit, asset.copy_location, asset.copy_status
678 IF NEW.opac_visible = OLD.opac_visible THEN -- do nothing
682 ELSIF NEW.opac_visible THEN -- add rows
684 IF TG_TABLE_NAME = 'org_unit' THEN
685 add_query := add_query || 'AND cp.circ_lib = ' || NEW.id || ';';
686 ELSIF TG_TABLE_NAME = 'copy_location' THEN
687 add_query := add_query || 'AND cp.location = ' || NEW.id || ';';
688 ELSIF TG_TABLE_NAME = 'copy_status' THEN
689 add_query := add_query || 'AND cp.status = ' || NEW.id || ';';
696 IF TG_TABLE_NAME = 'org_unit' THEN
697 remove_query := 'DELETE FROM asset.opac_visible_copies WHERE circ_lib = ' || NEW.id || ';';
698 ELSIF TG_TABLE_NAME = 'copy_location' THEN
699 remove_query := remove_query || 'location = ' || NEW.id || ');';
700 ELSIF TG_TABLE_NAME = 'copy_status' THEN
701 remove_query := remove_query || 'status = ' || NEW.id || ');';
704 EXECUTE remove_query;
710 $func$ LANGUAGE PLPGSQL;
711 COMMENT ON FUNCTION asset.cache_copy_visibility() IS $$
712 Trigger function to update the copy OPAC visiblity cache.
715 CREATE TRIGGER a_opac_vis_mat_view_tgr AFTER INSERT OR DELETE ON biblio.peer_bib_copy_map FOR EACH ROW EXECUTE PROCEDURE asset.cache_copy_visibility();
717 CREATE OR REPLACE FUNCTION biblio.indexing_ingest_or_delete () RETURNS TRIGGER AS $func$
719 transformed_xml TEXT;
722 xfrm config.xml_transform%ROWTYPE;
724 new_attrs HSTORE := ''::HSTORE;
725 attr_def config.record_attr_definition%ROWTYPE;
728 IF NEW.deleted IS TRUE THEN -- If this bib is deleted
729 DELETE FROM metabib.metarecord_source_map WHERE source = NEW.id; -- Rid ourselves of the search-estimate-killing linkage
730 DELETE FROM metabib.record_attr WHERE id = NEW.id; -- Kill the attrs hash, useless on deleted records
731 DELETE FROM authority.bib_linking WHERE bib = NEW.id; -- Avoid updating fields in bibs that are no longer visible
732 DELETE FROM biblio.peer_bib_copy_map WHERE peer_record = NEW.id; -- Separate any multi-homed items
733 RETURN NEW; -- and we're done
736 IF TG_OP = 'UPDATE' THEN -- re-ingest?
737 PERFORM * FROM config.internal_flag WHERE name = 'ingest.reingest.force_on_same_marc' AND enabled;
739 IF NOT FOUND AND OLD.marc = NEW.marc THEN -- don't do anything if the MARC didn't change
744 -- Record authority linking
745 PERFORM * FROM config.internal_flag WHERE name = 'ingest.disable_authority_linking' AND enabled;
747 PERFORM biblio.map_authority_linking( NEW.id, NEW.marc );
750 -- Flatten and insert the mfr data
751 PERFORM * FROM config.internal_flag WHERE name = 'ingest.disable_metabib_full_rec' AND enabled;
753 PERFORM metabib.reingest_metabib_full_rec(NEW.id);
755 -- Now we pull out attribute data, which is dependent on the mfr for all but XPath-based fields
756 PERFORM * FROM config.internal_flag WHERE name = 'ingest.disable_metabib_rec_descriptor' AND enabled;
758 FOR attr_def IN SELECT * FROM config.record_attr_definition ORDER BY format LOOP
760 IF attr_def.tag IS NOT NULL THEN -- tag (and optional subfield list) selection
761 SELECT ARRAY_TO_STRING(ARRAY_ACCUM(value), COALESCE(attr_def.joiner,' ')) INTO attr_value
762 FROM (SELECT * FROM metabib.full_rec ORDER BY tag, subfield) AS x
763 WHERE record = NEW.id
764 AND tag LIKE attr_def.tag
766 WHEN attr_def.sf_list IS NOT NULL
767 THEN POSITION(subfield IN attr_def.sf_list) > 0
774 ELSIF attr_def.fixed_field IS NOT NULL THEN -- a named fixed field, see config.marc21_ff_pos_map.fixed_field
775 attr_value := biblio.marc21_extract_fixed_field(NEW.id, attr_def.fixed_field);
777 ELSIF attr_def.xpath IS NOT NULL THEN -- and xpath expression
779 SELECT INTO xfrm * FROM config.xml_transform WHERE name = attr_def.format;
781 -- See if we can skip the XSLT ... it's expensive
782 IF prev_xfrm IS NULL OR prev_xfrm <> xfrm.name THEN
783 -- Can't skip the transform
784 IF xfrm.xslt <> '---' THEN
785 transformed_xml := oils_xslt_process(NEW.marc,xfrm.xslt);
787 transformed_xml := NEW.marc;
790 prev_xfrm := xfrm.name;
793 IF xfrm.name IS NULL THEN
794 -- just grab the marcxml (empty) transform
795 SELECT INTO xfrm * FROM config.xml_transform WHERE xslt = '---' LIMIT 1;
796 prev_xfrm := xfrm.name;
799 attr_value := oils_xpath_string(attr_def.xpath, transformed_xml, COALESCE(attr_def.joiner,' '), ARRAY[ARRAY[xfrm.prefix, xfrm.namespace_uri]]);
801 ELSIF attr_def.phys_char_sf IS NOT NULL THEN -- a named Physical Characteristic, see config.marc21_physical_characteristic_*_map
802 SELECT value::TEXT INTO attr_value
803 FROM biblio.marc21_physical_characteristics(NEW.id)
804 WHERE subfield = attr_def.phys_char_sf
805 LIMIT 1; -- Just in case ...
809 -- apply index normalizers to attr_value
811 SELECT n.func AS func,
812 n.param_count AS param_count,
814 FROM config.index_normalizer n
815 JOIN config.record_attr_index_norm_map m ON (m.norm = n.id)
816 WHERE attr = attr_def.name
818 EXECUTE 'SELECT ' || normalizer.func || '(' ||
819 quote_literal( attr_value ) ||
821 WHEN normalizer.param_count > 0
822 THEN ',' || REPLACE(REPLACE(BTRIM(normalizer.params,'[]'),E'\'',E'\\\''),E'"',E'\'')
829 -- Add the new value to the hstore
830 new_attrs := new_attrs || hstore( attr_def.name, attr_value );
834 IF TG_OP = 'INSERT' OR OLD.deleted THEN -- initial insert OR revivication
835 INSERT INTO metabib.record_attr (id, attrs) VALUES (NEW.id, new_attrs);
837 UPDATE metabib.record_attr SET attrs = attrs || new_attrs WHERE id = NEW.id;
843 -- Gather and insert the field entry data
844 PERFORM metabib.reingest_metabib_field_entries(NEW.id);
847 IF TG_OP = 'INSERT' THEN
848 PERFORM * FROM config.internal_flag WHERE name = 'ingest.disable_located_uri' AND enabled;
850 PERFORM biblio.extract_located_uris( NEW.id, NEW.marc, NEW.editor );
853 PERFORM * FROM config.internal_flag WHERE name = 'ingest.disable_located_uri' AND enabled;
855 PERFORM biblio.extract_located_uris( NEW.id, NEW.marc, NEW.editor );
859 -- (re)map metarecord-bib linking
860 IF TG_OP = 'INSERT' THEN -- if not deleted and performing an insert, check for the flag
861 PERFORM * FROM config.internal_flag WHERE name = 'ingest.metarecord_mapping.skip_on_insert' AND enabled;
863 PERFORM metabib.remap_metarecord_for_bib( NEW.id, NEW.fingerprint );
865 ELSE -- we're doing an update, and we're not deleted, remap
866 PERFORM * FROM config.internal_flag WHERE name = 'ingest.metarecord_mapping.skip_on_update' AND enabled;
868 PERFORM metabib.remap_metarecord_for_bib( NEW.id, NEW.fingerprint );
874 $func$ LANGUAGE PLPGSQL;