1 -- Enable automated ingest of authority records; just insert the row into
2 -- authority.record_entry and authority.full_rec will automatically be populated
5 INSERT INTO config.upgrade_log (version) VALUES ('0342'); -- dbs
7 CREATE OR REPLACE FUNCTION authority.propagate_changes (aid BIGINT, bid BIGINT) RETURNS BIGINT AS $func$
8 UPDATE biblio.record_entry
9 SET marc = vandelay.merge_record_xml( marc, authority.generate_overlay_template( $1 ) )
14 CREATE OR REPLACE FUNCTION authority.propagate_changes (aid BIGINT) RETURNS SETOF BIGINT AS $func$
15 SELECT authority.propagate_changes( authority, bib ) FROM authority.bib_linking WHERE authority = $1;
18 CREATE OR REPLACE FUNCTION authority.flatten_marc ( TEXT ) RETURNS SETOF authority.full_rec AS $func$
21 use MARC::File::XML (BinaryEncoding => 'UTF-8');
24 my $r = MARC::Record->new_from_xml( $xml );
26 return_next( { tag => 'LDR', value => $r->leader } );
28 for my $f ( $r->fields ) {
29 if ($f->is_control_field) {
30 return_next({ tag => $f->tag, value => $f->data });
32 for my $s ($f->subfields) {
35 ind1 => $f->indicator(1),
36 ind2 => $f->indicator(2),
47 $func$ LANGUAGE PLPERLU;
49 CREATE OR REPLACE FUNCTION authority.flatten_marc ( rid BIGINT ) RETURNS SETOF authority.full_rec AS $func$
51 auth authority.record_entry%ROWTYPE;
52 output authority.full_rec%ROWTYPE;
55 SELECT INTO auth * FROM authority.record_entry WHERE id = rid;
57 FOR field IN SELECT * FROM authority.flatten_marc( auth.marc ) LOOP
59 output.ind1 := field.ind1;
60 output.ind2 := field.ind2;
61 output.tag := field.tag;
62 output.subfield := field.subfield;
63 IF field.subfield IS NOT NULL THEN
64 output.value := naco_normalize(field.value, field.subfield);
66 output.value := field.value;
69 CONTINUE WHEN output.value IS NULL;
74 $func$ LANGUAGE PLPGSQL;
76 -- authority.rec_descriptor appears to be unused currently
77 CREATE OR REPLACE FUNCTION authority.reingest_authority_rec_descriptor( auth_id BIGINT ) RETURNS VOID AS $func$
79 DELETE FROM authority.rec_descriptor WHERE record = auth_id;
80 -- INSERT INTO authority.rec_descriptor (record, record_status, char_encoding)
85 $func$ LANGUAGE PLPGSQL;
87 CREATE OR REPLACE FUNCTION authority.reingest_authority_full_rec( auth_id BIGINT ) RETURNS VOID AS $func$
89 DELETE FROM authority.full_rec WHERE record = auth_id;
90 INSERT INTO authority.full_rec (record, tag, ind1, ind2, subfield, value)
91 SELECT record, tag, ind1, ind2, subfield, value FROM authority.flatten_marc( auth_id );
95 $func$ LANGUAGE PLPGSQL;
97 -- AFTER UPDATE OR INSERT trigger for authority.record_entry
98 CREATE OR REPLACE FUNCTION authority.indexing_ingest_or_delete () RETURNS TRIGGER AS $func$
101 IF NEW.deleted IS TRUE THEN -- If this authority is deleted
102 DELETE FROM authority.bib_linking WHERE authority = NEW.id; -- Avoid updating fields in bibs that are no longer visible
103 -- Should remove matching $0 from controlled fields at the same time?
104 RETURN NEW; -- and we're done
107 IF TG_OP = 'UPDATE' THEN -- re-ingest?
108 PERFORM * FROM config.internal_flag WHERE name = 'ingest.reingest.force_on_same_marc' AND enabled;
110 IF NOT FOUND AND OLD.marc = NEW.marc THEN -- don't do anything if the MARC didn't change
115 -- Flatten and insert the afr data
116 PERFORM * FROM config.internal_flag WHERE name = 'ingest.disable_authority_full_rec' AND enabled;
118 PERFORM authority.reingest_authority_full_rec(NEW.id);
119 -- authority.rec_descriptor is not currently used
120 -- PERFORM * FROM config.internal_flag WHERE name = 'ingest.disable_authority_rec_descriptor' AND enabled;
122 -- PERFORM authority.reingest_authority_rec_descriptor(NEW.id);
128 $func$ LANGUAGE PLPGSQL;