Forward-port 3.0.2 upgrade script
[working/Evergreen.git] / Open-ILS / src / sql / Pg / version-upgrade / 3.0.1-3.0.2-upgrade-db.sql
1 --Upgrade Script for 3.0.1 to 3.0.2
2 \set eg_version '''3.0.2'''
3 BEGIN;
4 INSERT INTO config.upgrade_log (version, applied_to) VALUES ('3.0.2', :eg_version);
5
6 SELECT evergreen.upgrade_deps_block_check('1079', :eg_version); -- rhamby/cesardv/gmcharlt
7
8 CREATE OR REPLACE FUNCTION asset.merge_record_assets( target_record BIGINT, source_record BIGINT ) RETURNS INT AS $func$
9 DECLARE
10     moved_objects INT := 0;
11     source_cn     asset.call_number%ROWTYPE;
12     target_cn     asset.call_number%ROWTYPE;
13     metarec       metabib.metarecord%ROWTYPE;
14     hold          action.hold_request%ROWTYPE;
15     ser_rec       serial.record_entry%ROWTYPE;
16     ser_sub       serial.subscription%ROWTYPE;
17     acq_lineitem  acq.lineitem%ROWTYPE;
18     acq_request   acq.user_request%ROWTYPE;
19     booking       booking.resource_type%ROWTYPE;
20     source_part   biblio.monograph_part%ROWTYPE;
21     target_part   biblio.monograph_part%ROWTYPE;
22     multi_home    biblio.peer_bib_copy_map%ROWTYPE;
23     uri_count     INT := 0;
24     counter       INT := 0;
25     uri_datafield TEXT;
26     uri_text      TEXT := '';
27 BEGIN
28
29     -- move any 856 entries on records that have at least one MARC-mapped URI entry
30     SELECT  INTO uri_count COUNT(*)
31       FROM  asset.uri_call_number_map m
32             JOIN asset.call_number cn ON (m.call_number = cn.id)
33       WHERE cn.record = source_record;
34
35     IF uri_count > 0 THEN
36         
37         -- This returns more nodes than you might expect:
38         -- 7 instead of 1 for an 856 with $u $y $9
39         SELECT  COUNT(*) INTO counter
40           FROM  oils_xpath_table(
41                     'id',
42                     'marc',
43                     'biblio.record_entry',
44                     '//*[@tag="856"]',
45                     'id=' || source_record
46                 ) as t(i int,c text);
47     
48         FOR i IN 1 .. counter LOOP
49             SELECT  '<datafield xmlns="http://www.loc.gov/MARC21/slim"' || 
50                         ' tag="856"' ||
51                         ' ind1="' || FIRST(ind1) || '"'  ||
52                         ' ind2="' || FIRST(ind2) || '">' ||
53                         STRING_AGG(
54                             '<subfield code="' || subfield || '">' ||
55                             regexp_replace(
56                                 regexp_replace(
57                                     regexp_replace(data,'&','&amp;','g'),
58                                     '>', '&gt;', 'g'
59                                 ),
60                                 '<', '&lt;', 'g'
61                             ) || '</subfield>', ''
62                         ) || '</datafield>' INTO uri_datafield
63               FROM  oils_xpath_table(
64                         'id',
65                         'marc',
66                         'biblio.record_entry',
67                         '//*[@tag="856"][position()=' || i || ']/@ind1|' ||
68                         '//*[@tag="856"][position()=' || i || ']/@ind2|' ||
69                         '//*[@tag="856"][position()=' || i || ']/*/@code|' ||
70                         '//*[@tag="856"][position()=' || i || ']/*[@code]',
71                         'id=' || source_record
72                     ) as t(id int,ind1 text, ind2 text,subfield text,data text);
73
74             -- As most of the results will be NULL, protect against NULLifying
75             -- the valid content that we do generate
76             uri_text := uri_text || COALESCE(uri_datafield, '');
77         END LOOP;
78
79         IF uri_text <> '' THEN
80             UPDATE  biblio.record_entry
81               SET   marc = regexp_replace(marc,'(</[^>]*record>)', uri_text || E'\\1')
82               WHERE id = target_record;
83         END IF;
84
85     END IF;
86
87         -- Find and move metarecords to the target record
88         SELECT  INTO metarec *
89           FROM  metabib.metarecord
90           WHERE master_record = source_record;
91
92         IF FOUND THEN
93                 UPDATE  metabib.metarecord
94                   SET   master_record = target_record,
95                         mods = NULL
96                   WHERE id = metarec.id;
97
98                 moved_objects := moved_objects + 1;
99         END IF;
100
101         -- Find call numbers attached to the source ...
102         FOR source_cn IN SELECT * FROM asset.call_number WHERE record = source_record LOOP
103
104                 SELECT  INTO target_cn *
105                   FROM  asset.call_number
106                   WHERE label = source_cn.label
107             AND prefix = source_cn.prefix
108             AND suffix = source_cn.suffix
109                         AND owning_lib = source_cn.owning_lib
110                         AND record = target_record
111                         AND NOT deleted;
112
113                 -- ... and if there's a conflicting one on the target ...
114                 IF FOUND THEN
115
116                         -- ... move the copies to that, and ...
117                         UPDATE  asset.copy
118                           SET   call_number = target_cn.id
119                           WHERE call_number = source_cn.id;
120
121                         -- ... move V holds to the move-target call number
122                         FOR hold IN SELECT * FROM action.hold_request WHERE target = source_cn.id AND hold_type = 'V' LOOP
123                 
124                                 UPDATE  action.hold_request
125                                   SET   target = target_cn.id
126                                   WHERE id = hold.id;
127                 
128                                 moved_objects := moved_objects + 1;
129                         END LOOP;
130         
131             UPDATE asset.call_number SET deleted = TRUE WHERE id = source_cn.id;
132
133                 -- ... if not ...
134                 ELSE
135                         -- ... just move the call number to the target record
136                         UPDATE  asset.call_number
137                           SET   record = target_record
138                           WHERE id = source_cn.id;
139                 END IF;
140
141                 moved_objects := moved_objects + 1;
142         END LOOP;
143
144         -- Find T holds targeting the source record ...
145         FOR hold IN SELECT * FROM action.hold_request WHERE target = source_record AND hold_type = 'T' LOOP
146
147                 -- ... and move them to the target record
148                 UPDATE  action.hold_request
149                   SET   target = target_record
150                   WHERE id = hold.id;
151
152                 moved_objects := moved_objects + 1;
153         END LOOP;
154
155         -- Find serial records targeting the source record ...
156         FOR ser_rec IN SELECT * FROM serial.record_entry WHERE record = source_record LOOP
157                 -- ... and move them to the target record
158                 UPDATE  serial.record_entry
159                   SET   record = target_record
160                   WHERE id = ser_rec.id;
161
162                 moved_objects := moved_objects + 1;
163         END LOOP;
164
165         -- Find serial subscriptions targeting the source record ...
166         FOR ser_sub IN SELECT * FROM serial.subscription WHERE record_entry = source_record LOOP
167                 -- ... and move them to the target record
168                 UPDATE  serial.subscription
169                   SET   record_entry = target_record
170                   WHERE id = ser_sub.id;
171
172                 moved_objects := moved_objects + 1;
173         END LOOP;
174
175         -- Find booking resource types targeting the source record ...
176         FOR booking IN SELECT * FROM booking.resource_type WHERE record = source_record LOOP
177                 -- ... and move them to the target record
178                 UPDATE  booking.resource_type
179                   SET   record = target_record
180                   WHERE id = booking.id;
181
182                 moved_objects := moved_objects + 1;
183         END LOOP;
184
185         -- Find acq lineitems targeting the source record ...
186         FOR acq_lineitem IN SELECT * FROM acq.lineitem WHERE eg_bib_id = source_record LOOP
187                 -- ... and move them to the target record
188                 UPDATE  acq.lineitem
189                   SET   eg_bib_id = target_record
190                   WHERE id = acq_lineitem.id;
191
192                 moved_objects := moved_objects + 1;
193         END LOOP;
194
195         -- Find acq user purchase requests targeting the source record ...
196         FOR acq_request IN SELECT * FROM acq.user_request WHERE eg_bib = source_record LOOP
197                 -- ... and move them to the target record
198                 UPDATE  acq.user_request
199                   SET   eg_bib = target_record
200                   WHERE id = acq_request.id;
201
202                 moved_objects := moved_objects + 1;
203         END LOOP;
204
205         -- Find parts attached to the source ...
206         FOR source_part IN SELECT * FROM biblio.monograph_part WHERE record = source_record LOOP
207
208                 SELECT  INTO target_part *
209                   FROM  biblio.monograph_part
210                   WHERE label = source_part.label
211                         AND record = target_record;
212
213                 -- ... and if there's a conflicting one on the target ...
214                 IF FOUND THEN
215
216                         -- ... move the copy-part maps to that, and ...
217                         UPDATE  asset.copy_part_map
218                           SET   part = target_part.id
219                           WHERE part = source_part.id;
220
221                         -- ... move P holds to the move-target part
222                         FOR hold IN SELECT * FROM action.hold_request WHERE target = source_part.id AND hold_type = 'P' LOOP
223                 
224                                 UPDATE  action.hold_request
225                                   SET   target = target_part.id
226                                   WHERE id = hold.id;
227                 
228                                 moved_objects := moved_objects + 1;
229                         END LOOP;
230
231                 -- ... if not ...
232                 ELSE
233                         -- ... just move the part to the target record
234                         UPDATE  biblio.monograph_part
235                           SET   record = target_record
236                           WHERE id = source_part.id;
237                 END IF;
238
239                 moved_objects := moved_objects + 1;
240         END LOOP;
241
242         -- Find multi_home items attached to the source ...
243         FOR multi_home IN SELECT * FROM biblio.peer_bib_copy_map WHERE peer_record = source_record LOOP
244                 -- ... and move them to the target record
245                 UPDATE  biblio.peer_bib_copy_map
246                   SET   peer_record = target_record
247                   WHERE id = multi_home.id;
248
249                 moved_objects := moved_objects + 1;
250         END LOOP;
251
252         -- And delete mappings where the item's home bib was merged with the peer bib
253         DELETE FROM biblio.peer_bib_copy_map WHERE peer_record = (
254                 SELECT (SELECT record FROM asset.call_number WHERE id = call_number)
255                 FROM asset.copy WHERE id = target_copy
256         );
257
258     -- Finally, "delete" the source record
259     DELETE FROM biblio.record_entry WHERE id = source_record;
260
261         -- That's all, folks!
262         RETURN moved_objects;
263 END;
264 $func$ LANGUAGE plpgsql;
265
266
267 SELECT evergreen.upgrade_deps_block_check('1080', :eg_version); -- miker/jboyer/gmcharlt
268
269 CREATE OR REPLACE FUNCTION asset.cache_copy_visibility () RETURNS TRIGGER as $func$
270 DECLARE
271     ocn     asset.call_number%ROWTYPE;
272     ncn     asset.call_number%ROWTYPE;
273     cid     BIGINT;
274 BEGIN
275
276     IF TG_TABLE_NAME = 'peer_bib_copy_map' THEN -- Only needs ON INSERT OR DELETE, so handle separately
277         IF TG_OP = 'INSERT' THEN
278             INSERT INTO asset.copy_vis_attr_cache (record, target_copy, vis_attr_vector) VALUES (
279                 NEW.peer_record,
280                 NEW.target_copy,
281                 asset.calculate_copy_visibility_attribute_set(NEW.target_copy)
282             );
283
284             RETURN NEW;
285         ELSIF TG_OP = 'DELETE' THEN
286             DELETE FROM asset.copy_vis_attr_cache
287               WHERE record = OLD.peer_record AND target_copy = OLD.target_copy;
288
289             RETURN OLD;
290         END IF;
291     END IF;
292
293     IF TG_OP = 'INSERT' THEN -- Handles ON INSERT. ON UPDATE is below.
294         IF TG_TABLE_NAME IN ('copy', 'unit') THEN
295             SELECT * INTO ncn FROM asset.call_number cn WHERE id = NEW.call_number;
296             INSERT INTO asset.copy_vis_attr_cache (record, target_copy, vis_attr_vector) VALUES (
297                 ncn.record,
298                 NEW.id,
299                 asset.calculate_copy_visibility_attribute_set(NEW.id)
300             );
301         ELSIF TG_TABLE_NAME = 'record_entry' THEN
302             NEW.vis_attr_vector := biblio.calculate_bib_visibility_attribute_set(NEW.id);
303         END IF;
304
305         RETURN NEW;
306     END IF;
307
308     -- handle items first, since with circulation activity
309     -- their statuses change frequently
310     IF TG_TABLE_NAME IN ('copy', 'unit') THEN -- This handles ON UPDATE OR DELETE. ON INSERT above
311
312         IF TG_OP = 'DELETE' THEN -- Shouldn't get here, normally
313             DELETE FROM asset.copy_vis_attr_cache WHERE target_copy = OLD.id;
314             RETURN OLD;
315         END IF;
316
317         SELECT * INTO ncn FROM asset.call_number cn WHERE id = NEW.call_number;
318
319         IF OLD.deleted <> NEW.deleted THEN
320             IF NEW.deleted THEN
321                 DELETE FROM asset.copy_vis_attr_cache WHERE target_copy = OLD.id;
322             ELSE
323                 INSERT INTO asset.copy_vis_attr_cache (record, target_copy, vis_attr_vector) VALUES (
324                     ncn.record,
325                     NEW.id,
326                     asset.calculate_copy_visibility_attribute_set(NEW.id)
327                 );
328             END IF;
329
330             RETURN NEW;
331         ELSIF OLD.call_number  <> NEW.call_number THEN
332             SELECT * INTO ocn FROM asset.call_number cn WHERE id = OLD.call_number;
333
334             IF ncn.record <> ocn.record THEN
335                 UPDATE  biblio.record_entry
336                   SET   vis_attr_vector = biblio.calculate_bib_visibility_attribute_set(ncn.record)
337                   WHERE id = ocn.record;
338
339                 -- We have to use a record-specific WHERE clause
340                 -- to avoid modifying the entries for peer-bib copies.
341                 UPDATE  asset.copy_vis_attr_cache
342                   SET   target_copy = NEW.id,
343                         record = ncn.record
344                   WHERE target_copy = OLD.id
345                         AND record = ocn.record;
346             END IF;
347         END IF;
348
349         IF OLD.location     <> NEW.location OR
350            OLD.status       <> NEW.status OR
351            OLD.opac_visible <> NEW.opac_visible OR
352            OLD.circ_lib     <> NEW.circ_lib
353         THEN
354             -- Any of these could change visibility, but
355             -- we'll save some queries and not try to calculate
356             -- the change directly.  We want to update peer-bib
357             -- entries in this case, unlike above.
358             UPDATE  asset.copy_vis_attr_cache
359               SET   target_copy = NEW.id,
360                     vis_attr_vector = asset.calculate_copy_visibility_attribute_set(NEW.id)
361               WHERE target_copy = OLD.id;
362
363         END IF;
364
365     ELSIF TG_TABLE_NAME = 'call_number' THEN -- Only ON UPDATE. Copy handler will deal with ON INSERT OR DELETE.
366
367         IF OLD.record <> NEW.record THEN
368             IF NEW.label = '##URI##' THEN
369                 UPDATE  biblio.record_entry
370                   SET   vis_attr_vector = biblio.calculate_bib_visibility_attribute_set(OLD.record)
371                   WHERE id = OLD.record;
372
373                 UPDATE  biblio.record_entry
374                   SET   vis_attr_vector = biblio.calculate_bib_visibility_attribute_set(NEW.record)
375                   WHERE id = NEW.record;
376             END IF;
377
378             UPDATE  asset.copy_vis_attr_cache
379               SET   record = NEW.record,
380                     vis_attr_vector = asset.calculate_copy_visibility_attribute_set(target_copy)
381               WHERE target_copy IN (SELECT id FROM asset.copy WHERE call_number = NEW.id)
382                     AND record = OLD.record;
383
384         ELSIF OLD.owning_lib <> NEW.owning_lib THEN
385             UPDATE  asset.copy_vis_attr_cache
386               SET   vis_attr_vector = asset.calculate_copy_visibility_attribute_set(target_copy)
387               WHERE target_copy IN (SELECT id FROM asset.copy WHERE call_number = NEW.id)
388                     AND record = NEW.record;
389
390             IF NEW.label = '##URI##' THEN
391                 UPDATE  biblio.record_entry
392                   SET   vis_attr_vector = biblio.calculate_bib_visibility_attribute_set(OLD.record)
393                   WHERE id = OLD.record;
394             END IF;
395         END IF;
396
397     ELSIF TG_TABLE_NAME = 'record_entry' THEN -- Only handles ON UPDATE OR DELETE
398
399         IF TG_OP = 'DELETE' THEN -- Shouldn't get here, normally
400             DELETE FROM asset.copy_vis_attr_cache WHERE record = OLD.id;
401             RETURN OLD;
402         ELSIF OLD.source <> NEW.source THEN
403             NEW.vis_attr_vector := biblio.calculate_bib_visibility_attribute_set(NEW.id);
404         END IF;
405
406     END IF;
407
408     RETURN NEW;
409 END;
410 $func$ LANGUAGE PLPGSQL;
411
412
413 SELECT evergreen.upgrade_deps_block_check('1081', :eg_version); -- jboyer/gmcharlt
414
415 DROP TRIGGER IF EXISTS inherit_copy_bucket_item_target_copy_fkey ON container.copy_bucket_item;
416 DROP TRIGGER IF EXISTS inherit_import_item_imported_as_fkey ON vandelay.import_item;
417 DROP TRIGGER IF EXISTS inherit_asset_copy_note_copy_fkey ON asset.copy_note;
418 DROP TRIGGER IF EXISTS inherit_asset_copy_tag_copy_map_copy_fkey ON asset.copy_tag_copy_map;
419
420 CREATE CONSTRAINT TRIGGER inherit_copy_bucket_item_target_copy_fkey
421   AFTER UPDATE OR INSERT ON container.copy_bucket_item
422   DEFERRABLE FOR EACH ROW EXECUTE PROCEDURE evergreen.container_copy_bucket_item_target_copy_inh_fkey();
423 CREATE CONSTRAINT TRIGGER inherit_import_item_imported_as_fkey
424   AFTER UPDATE OR INSERT ON vandelay.import_item
425   DEFERRABLE FOR EACH ROW EXECUTE PROCEDURE evergreen.vandelay_import_item_imported_as_inh_fkey();
426 CREATE CONSTRAINT TRIGGER inherit_asset_copy_note_copy_fkey
427   AFTER UPDATE OR INSERT ON asset.copy_note
428   DEFERRABLE FOR EACH ROW EXECUTE PROCEDURE evergreen.asset_copy_note_owning_copy_inh_fkey();
429 CREATE CONSTRAINT TRIGGER inherit_asset_copy_tag_copy_map_copy_fkey
430   AFTER UPDATE OR INSERT ON asset.copy_tag_copy_map
431   DEFERRABLE FOR EACH ROW EXECUTE PROCEDURE evergreen.asset_copy_tag_copy_map_copy_inh_fkey();
432
433
434
435 SELECT evergreen.upgrade_deps_block_check('1082', :eg_version); -- jboyer/gmcharlt
436
437 DELETE FROM asset.copy_vis_attr_cache WHERE target_copy IN (SELECT id FROM asset.copy WHERE deleted);
438
439 -- Evergreen DB patch XXXX.schema.qualify_unaccent_refs.sql
440 --
441 -- LP#1671150 Fix unaccent() function call in evergreen.unaccent_and_squash()
442 --
443
444
445 -- check whether patch can be applied
446 SELECT evergreen.upgrade_deps_block_check('1083', :eg_version);
447
448 CREATE OR REPLACE FUNCTION evergreen.unaccent_and_squash ( IN arg text) RETURNS text
449     IMMUTABLE STRICT AS $$
450         BEGIN
451         RETURN evergreen.lowercase(public.unaccent('public.unaccent', regexp_replace(arg, '[\s[:punct:]]','','g')));
452         END;
453 $$ LANGUAGE PLPGSQL;
454
455 -- Drop indexes if present, so that we can re-create them
456 DROP INDEX IF EXISTS actor.actor_usr_first_given_name_unaccent_idx;
457 DROP INDEX IF EXISTS actor.actor_usr_second_given_name_unaccent_idx;
458 DROP INDEX IF EXISTS actor.actor_usr_family_name_unaccent_idx; 
459 DROP INDEX IF EXISTS actor.actor_usr_usrname_unaccent_idx; 
460
461 -- Create (or re-create) indexes -- they may be missing if pg_restore failed to create
462 -- them due to the previously unqualified call to unaccent()
463 CREATE INDEX actor_usr_first_given_name_unaccent_idx ON actor.usr (evergreen.unaccent_and_squash(first_given_name));
464 CREATE INDEX actor_usr_second_given_name_unaccent_idx ON actor.usr (evergreen.unaccent_and_squash(second_given_name));
465 CREATE INDEX actor_usr_family_name_unaccent_idx ON actor.usr (evergreen.unaccent_and_squash(family_name));
466 CREATE INDEX actor_usr_usrname_unaccent_idx ON actor.usr (evergreen.unaccent_and_squash(usrname));
467
468
469 SELECT evergreen.upgrade_deps_block_check('1084', :eg_version);
470
471 INSERT INTO config.usr_setting_type (name, label, description, datatype)
472   VALUES ('webstaff.cat.copy.templates', 'Web Client Copy Editor Templates', 'Web Client Copy Editor Templates', 'object');
473
474 COMMIT;