Open-ILS/src/sql/Pg/999.functions.global.sql

   1 /*
   2  * Copyright (C) 2008 Equinox Software, Inc.
   3  * Bill Erickson <erickson@esilibrary.com>
   4  *
   5  * This program is free software; you can redistribute it and/or
   6  * modify it under the terms of the GNU General Public License
   7  * as published by the Free Software Foundation; either version 2
   8  * of the License, or (at your option) any later version.
   9  *
  10  * This program is distributed in the hope that it will be useful,
  11  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  13  * GNU General Public License for more details.
  14  *
  15  */
  16
  17 CREATE OR REPLACE FUNCTION actor.usr_merge_rows( table_name TEXT, col_name TEXT, src_usr INT, dest_usr INT ) RETURNS VOID AS $$
  18 DECLARE
  19     sel TEXT;
  20     upd TEXT;
  21     del TEXT;
  22     cur_row RECORD;
  23 BEGIN
  24     sel := 'SELECT id::BIGINT FROM ' || table_name || ' WHERE ' || quote_ident(col_name) || ' = ' || quote_literal(src_usr);
  25     upd := 'UPDATE ' || table_name || ' SET ' || quote_ident(col_name) || ' = ' || quote_literal(dest_usr) || ' WHERE id = ';
  26     del := 'DELETE FROM ' || table_name || ' WHERE id = ';
  27     FOR cur_row IN EXECUTE sel LOOP
  28         BEGIN
  29             --RAISE NOTICE 'Attempting to merge % %', table_name, cur_row.id;
  30             EXECUTE upd || cur_row.id;
  31         EXCEPTION WHEN unique_violation THEN
  32             --RAISE NOTICE 'Deleting conflicting % %', table_name, cur_row.id;
  33             EXECUTE del || cur_row.id;
  34         END;
  35     END LOOP;
  36 END;
  37 $$ LANGUAGE plpgsql;
  38
  39 COMMENT ON FUNCTION actor.usr_merge_rows(TEXT, TEXT, INT, INT) IS $$
  40 /**
  41  * Attempts to move each row of the specified table from src_user to dest_user.
  42  * Where conflicts exist, the conflicting "source" row is deleted.
  43  */
  44 $$;
  45
  46
  47 CREATE OR REPLACE FUNCTION actor.usr_merge( src_usr INT, dest_usr INT ) RETURNS VOID AS $$
  48 BEGIN
  49
  50     -- actor.*
  51     UPDATE actor.card SET usr = dest_usr WHERE usr = src_usr;
  52     UPDATE actor.usr_note SET usr = dest_usr WHERE usr = src_usr;
  53     -- dupes are technically OK in actor.usr_standing_penalty, should manually delete them...
  54     UPDATE actor.usr_standing_penalty SET usr = dest_usr WHERE usr = src_usr;
  55     UPDATE actor.usr_address SET usr = dest_usr WHERE usr = src_usr;
  56     PERFORM actor.usr_merge_rows('actor.usr_org_unit_opt_in', 'usr', src_usr, dest_usr);
  57     PERFORM actor.usr_merge_rows('actor.usr_setting', 'usr', src_usr, dest_usr);
  58
  59     -- permission.*
  60     PERFORM actor.usr_merge_rows('permission.usr_perm_map', 'usr', src_usr, dest_usr);
  61     PERFORM actor.usr_merge_rows('permission.usr_object_perm_map', 'usr', src_usr, dest_usr);
  62     PERFORM actor.usr_merge_rows('permission.usr_grp_map', 'usr', src_usr, dest_usr);
  63     PERFORM actor.usr_merge_rows('permission.usr_work_ou_map', 'usr', src_usr, dest_usr);
  64
  65
  66     -- container.*
  67     PERFORM actor.usr_merge_rows('container.biblio_record_entry_bucket', 'owner', src_usr, dest_usr);
  68     PERFORM actor.usr_merge_rows('container.call_number_bucket', 'owner', src_usr, dest_usr);
  69     PERFORM actor.usr_merge_rows('container.copy_bucket', 'owner', src_usr, dest_usr);
  70     PERFORM actor.usr_merge_rows('container.user_bucket', 'owner', src_usr, dest_usr);
  71     PERFORM actor.usr_merge_rows('container.user_bucket_item', 'target_user', src_usr, dest_usr);
  72
  73     -- vandelay.*
  74     PERFORM actor.usr_merge_rows('vandelay.queue', 'owner', src_usr, dest_usr);
  75
  76     -- money.*
  77     PERFORM actor.usr_merge_rows('money.collections_tracker', 'usr', src_usr, dest_usr);
  78     PERFORM actor.usr_merge_rows('money.collections_tracker', 'collector', src_usr, dest_usr);
  79     UPDATE money.billable_xact SET usr = dest_usr WHERE usr = src_usr;
  80     UPDATE money.billing SET voider = dest_usr WHERE voider = src_usr;
  81     UPDATE money.bnm_payment SET accepting_usr = dest_usr WHERE accepting_usr = src_usr;
  82
  83     -- action.*
  84     UPDATE action.circulation SET usr = dest_usr WHERE usr = src_usr;
  85     UPDATE action.circulation SET circ_staff = dest_usr WHERE circ_staff = src_usr;
  86     UPDATE action.circulation SET checkin_staff = dest_usr WHERE checkin_staff = src_usr;
  87
  88     UPDATE action.hold_request SET usr = dest_usr WHERE usr = src_usr;
  89     UPDATE action.hold_request SET fulfillment_staff = dest_usr WHERE fulfillment_staff = src_usr;
  90     UPDATE action.hold_request SET requestor = dest_usr WHERE requestor = src_usr;
  91     UPDATE action.hold_notification SET notify_staff = dest_usr WHERE notify_staff = src_usr;
  92
  93     UPDATE action.in_house_use SET staff = dest_usr WHERE staff = src_usr;
  94     UPDATE action.non_cataloged_circulation SET staff = dest_usr WHERE staff = src_usr;
  95     UPDATE action.non_cataloged_circulation SET patron = dest_usr WHERE patron = src_usr;
  96     UPDATE action.non_cat_in_house_use SET staff = dest_usr WHERE staff = src_usr;
  97     UPDATE action.survey_response SET usr = dest_usr WHERE usr = src_usr;
  98
  99     -- acq.*
 100     UPDATE acq.fund_allocation SET allocator = dest_usr WHERE allocator = src_usr;
 101     PERFORM actor.usr_merge_rows('acq.picklist', 'owner', src_usr, dest_usr);
 102     UPDATE acq.purchase_order SET owner = dest_usr WHERE owner = src_usr;
 103     UPDATE acq.po_note SET creator = dest_usr WHERE creator = src_usr;
 104     UPDATE acq.po_note SET editor = dest_usr WHERE editor = src_usr;
 105     UPDATE acq.lineitem_note SET creator = dest_usr WHERE creator = src_usr;
 106     UPDATE acq.lineitem_note SET editor = dest_usr WHERE editor = src_usr;
 107     UPDATE acq.lineitem_usr_attr_definition SET usr = dest_usr WHERE usr = src_usr;
 108
 109     -- asset.*
 110     UPDATE asset.copy SET creator = dest_usr WHERE creator = src_usr;
 111     UPDATE asset.copy SET editor = dest_usr WHERE editor = src_usr;
 112     UPDATE asset.copy_note SET creator = dest_usr WHERE creator = src_usr;
 113     UPDATE asset.call_number SET creator = dest_usr WHERE creator = src_usr;
 114     UPDATE asset.call_number SET editor = dest_usr WHERE editor = src_usr;
 115     UPDATE asset.call_number_note SET creator = dest_usr WHERE creator = src_usr;
 116
 117
 118     -- reporter.*
 119     -- It's not uncommon to define the reporter schema in a replica
 120     -- DB only, so don't assume these tables exist in the write DB.
 121     BEGIN
 122         PERFORM actor.usr_merge_rows('reporter.template', 'owner', src_usr, dest_usr);
 123     EXCEPTION WHEN undefined_table THEN
 124         -- do nothing
 125     END;
 126     BEGIN
 127         PERFORM actor.usr_merge_rows('reporter.report', 'owner', src_usr, dest_usr);
 128     EXCEPTION WHEN undefined_table THEN
 129         -- do nothing
 130     END;
 131     BEGIN
 132         PERFORM actor.usr_merge_rows('reporter.schedule', 'runner', src_usr, dest_usr);
 133     EXCEPTION WHEN undefined_table THEN
 134         -- do nothing
 135     END;
 136     BEGIN
 137         PERFORM actor.usr_merge_rows('reporter.template_folder', 'owner', src_usr, dest_usr);
 138     EXCEPTION WHEN undefined_table THEN
 139         -- do nothing
 140     END;
 141     BEGIN
 142         PERFORM actor.usr_merge_rows('reporter.report_folder', 'owner', src_usr, dest_usr);
 143     EXCEPTION WHEN undefined_table THEN
 144         -- do nothing
 145     END;
 146     BEGIN
 147         PERFORM actor.usr_merge_rows('reporter.output_folder', 'owner', src_usr, dest_usr);
 148     EXCEPTION WHEN undefined_table THEN
 149         -- do nothing
 150     END;
 151
 152     -- Finally, clean and delete the source user
 153     UPDATE actor.usr SET card = NULL WHERE id = src_usr;
 154     UPDATE actor.usr SET mailing_address = NULL WHERE id = src_usr;
 155     UPDATE actor.usr SET billing_address = NULL WHERE id = src_usr;
 156     DELETE FROM actor.usr WHERE id = src_usr;
 157
 158 END;
 159 $$ LANGUAGE plpgsql;
 160
 161 COMMENT ON FUNCTION actor.usr_merge(INT, INT) IS $$
 162 /**
 163  * Merges all user date from src_usr to dest_usr.  When collisions occur,
 164  * keep dest_usr's data and delete src_usr's data.
 165  */
 166 $$;
 167
 168
 169
 170 CREATE OR REPLACE FUNCTION actor.approve_pending_address(pending_id INT) RETURNS VOID AS $$
 171 DECLARE
 172     old_id INT;
 173 BEGIN
 174     SELECT INTO old_id replaces FROM actor.usr_address where id = pending_id;
 175     IF old_id IS NULL THEN
 176         RAISE NOTICE 'Address % does not replace any address', pending_id;
 177         RETURN;
 178     END IF;
 179     DELETE FROM actor.usr_address WHERE id = -old_id;
 180     UPDATE actor.usr_address SET id = -id WHERE id = old_id;
 181     UPDATE actor.usr_address SET replaces = NULL, id = old_id WHERE id = pending_id;
 182 END
 183 $$ LANGUAGE plpgsql;
 184
 185 COMMENT ON FUNCTION actor.approve_pending_address(INT) IS $$
 186 /**
 187  * Replaces an address with a pending address.  This is done by giving the pending
 188  * address the ID of the old address.  The replaced address is retained with -id.
 189  */
 190 $$;
 191
 192
 193