Open-ILS/src/sql/Pg/upgrade/0480.schema.actor_usr_purge_data.sql

   1 BEGIN;
   2
   3 INSERT INTO config.upgrade_log (version) VALUES ('0480'); -- phasefx
   4
   5 CREATE OR REPLACE FUNCTION actor.usr_purge_data(
   6         src_usr  IN INTEGER,
   7         specified_dest_usr IN INTEGER
   8 ) RETURNS VOID AS $$
   9 DECLARE
  10         suffix TEXT;
  11         renamable_row RECORD;
  12         dest_usr INTEGER;
  13 BEGIN
  14
  15         IF specified_dest_usr IS NULL THEN
  16                 dest_usr := 1; -- Admin user on stock installs
  17         ELSE
  18                 dest_usr := specified_dest_usr;
  19         END IF;
  20
  21         UPDATE actor.usr SET
  22                 active = FALSE,
  23                 card = NULL,
  24                 mailing_address = NULL,
  25                 billing_address = NULL
  26         WHERE id = src_usr;
  27
  28         -- acq.*
  29         UPDATE acq.fund_allocation SET allocator = dest_usr WHERE allocator = src_usr;
  30         UPDATE acq.lineitem SET creator = dest_usr WHERE creator = src_usr;
  31         UPDATE acq.lineitem SET editor = dest_usr WHERE editor = src_usr;
  32         UPDATE acq.lineitem SET selector = dest_usr WHERE selector = src_usr;
  33         UPDATE acq.lineitem_note SET creator = dest_usr WHERE creator = src_usr;
  34         UPDATE acq.lineitem_note SET editor = dest_usr WHERE editor = src_usr;
  35         DELETE FROM acq.lineitem_usr_attr_definition WHERE usr = src_usr;
  36
  37         -- Update with a rename to avoid collisions
  38         FOR renamable_row in
  39                 SELECT id, name
  40                 FROM   acq.picklist
  41                 WHERE  owner = src_usr
  42         LOOP
  43                 suffix := ' (' || src_usr || ')';
  44                 LOOP
  45                         BEGIN
  46                                 UPDATE  acq.picklist
  47                                 SET     owner = dest_usr, name = name || suffix
  48                                 WHERE   id = renamable_row.id;
  49                         EXCEPTION WHEN unique_violation THEN
  50                                 suffix := suffix || ' ';
  51                                 CONTINUE;
  52                         END;
  53                         EXIT;
  54                 END LOOP;
  55         END LOOP;
  56
  57         UPDATE acq.picklist SET creator = dest_usr WHERE creator = src_usr;
  58         UPDATE acq.picklist SET editor = dest_usr WHERE editor = src_usr;
  59         UPDATE acq.po_note SET creator = dest_usr WHERE creator = src_usr;
  60         UPDATE acq.po_note SET editor = dest_usr WHERE editor = src_usr;
  61         UPDATE acq.purchase_order SET owner = dest_usr WHERE owner = src_usr;
  62         UPDATE acq.purchase_order SET creator = dest_usr WHERE creator = src_usr;
  63         UPDATE acq.purchase_order SET editor = dest_usr WHERE editor = src_usr;
  64         UPDATE acq.claim_event SET creator = dest_usr WHERE creator = src_usr;
  65
  66         -- action.*
  67         DELETE FROM action.circulation WHERE usr = src_usr;
  68         UPDATE action.circulation SET circ_staff = dest_usr WHERE circ_staff = src_usr;
  69         UPDATE action.circulation SET checkin_staff = dest_usr WHERE checkin_staff = src_usr;
  70         UPDATE action.hold_notification SET notify_staff = dest_usr WHERE notify_staff = src_usr;
  71         UPDATE action.hold_request SET fulfillment_staff = dest_usr WHERE fulfillment_staff = src_usr;
  72         UPDATE action.hold_request SET requestor = dest_usr WHERE requestor = src_usr;
  73         DELETE FROM action.hold_request WHERE usr = src_usr;
  74         UPDATE action.in_house_use SET staff = dest_usr WHERE staff = src_usr;
  75         UPDATE action.non_cat_in_house_use SET staff = dest_usr WHERE staff = src_usr;
  76         DELETE FROM action.non_cataloged_circulation WHERE patron = src_usr;
  77         UPDATE action.non_cataloged_circulation SET staff = dest_usr WHERE staff = src_usr;
  78         DELETE FROM action.survey_response WHERE usr = src_usr;
  79         UPDATE action.fieldset SET owner = dest_usr WHERE owner = src_usr;
  80
  81         -- actor.*
  82         DELETE FROM actor.card WHERE usr = src_usr;
  83         DELETE FROM actor.stat_cat_entry_usr_map WHERE target_usr = src_usr;
  84
  85         -- The following update is intended to avoid transient violations of a foreign
  86         -- key constraint, whereby actor.usr_address references itself.  It may not be
  87         -- necessary, but it does no harm.
  88         UPDATE actor.usr_address SET replaces = NULL
  89                 WHERE usr = src_usr AND replaces IS NOT NULL;
  90         DELETE FROM actor.usr_address WHERE usr = src_usr;
  91         DELETE FROM actor.usr_note WHERE usr = src_usr;
  92         UPDATE actor.usr_note SET creator = dest_usr WHERE creator = src_usr;
  93         DELETE FROM actor.usr_org_unit_opt_in WHERE usr = src_usr;
  94         UPDATE actor.usr_org_unit_opt_in SET staff = dest_usr WHERE staff = src_usr;
  95         DELETE FROM actor.usr_setting WHERE usr = src_usr;
  96         DELETE FROM actor.usr_standing_penalty WHERE usr = src_usr;
  97         UPDATE actor.usr_standing_penalty SET staff = dest_usr WHERE staff = src_usr;
  98
  99         -- asset.*
 100         UPDATE asset.call_number SET creator = dest_usr WHERE creator = src_usr;
 101         UPDATE asset.call_number SET editor = dest_usr WHERE editor = src_usr;
 102         UPDATE asset.call_number_note SET creator = dest_usr WHERE creator = src_usr;
 103         UPDATE asset.copy SET creator = dest_usr WHERE creator = src_usr;
 104         UPDATE asset.copy SET editor = dest_usr WHERE editor = src_usr;
 105         UPDATE asset.copy_note SET creator = dest_usr WHERE creator = src_usr;
 106
 107         -- auditor.*
 108         DELETE FROM auditor.actor_usr_address_history WHERE id = src_usr;
 109         DELETE FROM auditor.actor_usr_history WHERE id = src_usr;
 110         UPDATE auditor.asset_call_number_history SET creator = dest_usr WHERE creator = src_usr;
 111         UPDATE auditor.asset_call_number_history SET editor  = dest_usr WHERE editor  = src_usr;
 112         UPDATE auditor.asset_copy_history SET creator = dest_usr WHERE creator = src_usr;
 113         UPDATE auditor.asset_copy_history SET editor  = dest_usr WHERE editor  = src_usr;
 114         UPDATE auditor.biblio_record_entry_history SET creator = dest_usr WHERE creator = src_usr;
 115         UPDATE auditor.biblio_record_entry_history SET editor  = dest_usr WHERE editor  = src_usr;
 116
 117         -- biblio.*
 118         UPDATE biblio.record_entry SET creator = dest_usr WHERE creator = src_usr;
 119         UPDATE biblio.record_entry SET editor = dest_usr WHERE editor = src_usr;
 120         UPDATE biblio.record_note SET creator = dest_usr WHERE creator = src_usr;
 121         UPDATE biblio.record_note SET editor = dest_usr WHERE editor = src_usr;
 122
 123         -- container.*
 124         -- Update buckets with a rename to avoid collisions
 125         FOR renamable_row in
 126                 SELECT id, name
 127                 FROM   container.biblio_record_entry_bucket
 128                 WHERE  owner = src_usr
 129         LOOP
 130                 suffix := ' (' || src_usr || ')';
 131                 LOOP
 132                         BEGIN
 133                                 UPDATE  container.biblio_record_entry_bucket
 134                                 SET     owner = dest_usr, name = name || suffix
 135                                 WHERE   id = renamable_row.id;
 136                         EXCEPTION WHEN unique_violation THEN
 137                                 suffix := suffix || ' ';
 138                                 CONTINUE;
 139                         END;
 140                         EXIT;
 141                 END LOOP;
 142         END LOOP;
 143
 144         FOR renamable_row in
 145                 SELECT id, name
 146                 FROM   container.call_number_bucket
 147                 WHERE  owner = src_usr
 148         LOOP
 149                 suffix := ' (' || src_usr || ')';
 150                 LOOP
 151                         BEGIN
 152                                 UPDATE  container.call_number_bucket
 153                                 SET     owner = dest_usr, name = name || suffix
 154                                 WHERE   id = renamable_row.id;
 155                         EXCEPTION WHEN unique_violation THEN
 156                                 suffix := suffix || ' ';
 157                                 CONTINUE;
 158                         END;
 159                         EXIT;
 160                 END LOOP;
 161         END LOOP;
 162
 163         FOR renamable_row in
 164                 SELECT id, name
 165                 FROM   container.copy_bucket
 166                 WHERE  owner = src_usr
 167         LOOP
 168                 suffix := ' (' || src_usr || ')';
 169                 LOOP
 170                         BEGIN
 171                                 UPDATE  container.copy_bucket
 172                                 SET     owner = dest_usr, name = name || suffix
 173                                 WHERE   id = renamable_row.id;
 174                         EXCEPTION WHEN unique_violation THEN
 175                                 suffix := suffix || ' ';
 176                                 CONTINUE;
 177                         END;
 178                         EXIT;
 179                 END LOOP;
 180         END LOOP;
 181
 182         FOR renamable_row in
 183                 SELECT id, name
 184                 FROM   container.user_bucket
 185                 WHERE  owner = src_usr
 186         LOOP
 187                 suffix := ' (' || src_usr || ')';
 188                 LOOP
 189                         BEGIN
 190                                 UPDATE  container.user_bucket
 191                                 SET     owner = dest_usr, name = name || suffix
 192                                 WHERE   id = renamable_row.id;
 193                         EXCEPTION WHEN unique_violation THEN
 194                                 suffix := suffix || ' ';
 195                                 CONTINUE;
 196                         END;
 197                         EXIT;
 198                 END LOOP;
 199         END LOOP;
 200
 201         DELETE FROM container.user_bucket_item WHERE target_user = src_usr;
 202
 203         -- money.*
 204         DELETE FROM money.billable_xact WHERE usr = src_usr;
 205         DELETE FROM money.collections_tracker WHERE usr = src_usr;
 206         UPDATE money.collections_tracker SET collector = dest_usr WHERE collector = src_usr;
 207
 208         -- permission.*
 209         DELETE FROM permission.usr_grp_map WHERE usr = src_usr;
 210         DELETE FROM permission.usr_object_perm_map WHERE usr = src_usr;
 211         DELETE FROM permission.usr_perm_map WHERE usr = src_usr;
 212         DELETE FROM permission.usr_work_ou_map WHERE usr = src_usr;
 213
 214         -- reporter.*
 215         -- Update with a rename to avoid collisions
 216         BEGIN
 217                 FOR renamable_row in
 218                         SELECT id, name
 219                         FROM   reporter.output_folder
 220                         WHERE  owner = src_usr
 221                 LOOP
 222                         suffix := ' (' || src_usr || ')';
 223                         LOOP
 224                                 BEGIN
 225                                         UPDATE  reporter.output_folder
 226                                         SET     owner = dest_usr, name = name || suffix
 227                                         WHERE   id = renamable_row.id;
 228                                 EXCEPTION WHEN unique_violation THEN
 229                                         suffix := suffix || ' ';
 230                                         CONTINUE;
 231                                 END;
 232                                 EXIT;
 233                         END LOOP;
 234                 END LOOP;
 235         EXCEPTION WHEN undefined_table THEN
 236                 -- do nothing
 237         END;
 238
 239         BEGIN
 240                 UPDATE reporter.report SET owner = dest_usr WHERE owner = src_usr;
 241         EXCEPTION WHEN undefined_table THEN
 242                 -- do nothing
 243         END;
 244
 245         -- Update with a rename to avoid collisions
 246         BEGIN
 247                 FOR renamable_row in
 248                         SELECT id, name
 249                         FROM   reporter.report_folder
 250                         WHERE  owner = src_usr
 251                 LOOP
 252                         suffix := ' (' || src_usr || ')';
 253                         LOOP
 254                                 BEGIN
 255                                         UPDATE  reporter.report_folder
 256                                         SET     owner = dest_usr, name = name || suffix
 257                                         WHERE   id = renamable_row.id;
 258                                 EXCEPTION WHEN unique_violation THEN
 259                                         suffix := suffix || ' ';
 260                                         CONTINUE;
 261                                 END;
 262                                 EXIT;
 263                         END LOOP;
 264                 END LOOP;
 265         EXCEPTION WHEN undefined_table THEN
 266                 -- do nothing
 267         END;
 268
 269         BEGIN
 270                 UPDATE reporter.schedule SET runner = dest_usr WHERE runner = src_usr;
 271         EXCEPTION WHEN undefined_table THEN
 272                 -- do nothing
 273         END;
 274
 275         BEGIN
 276                 UPDATE reporter.template SET owner = dest_usr WHERE owner = src_usr;
 277         EXCEPTION WHEN undefined_table THEN
 278                 -- do nothing
 279         END;
 280
 281         -- Update with a rename to avoid collisions
 282         BEGIN
 283                 FOR renamable_row in
 284                         SELECT id, name
 285                         FROM   reporter.template_folder
 286                         WHERE  owner = src_usr
 287                 LOOP
 288                         suffix := ' (' || src_usr || ')';
 289                         LOOP
 290                                 BEGIN
 291                                         UPDATE  reporter.template_folder
 292                                         SET     owner = dest_usr, name = name || suffix
 293                                         WHERE   id = renamable_row.id;
 294                                 EXCEPTION WHEN unique_violation THEN
 295                                         suffix := suffix || ' ';
 296                                         CONTINUE;
 297                                 END;
 298                                 EXIT;
 299                         END LOOP;
 300                 END LOOP;
 301         EXCEPTION WHEN undefined_table THEN
 302         -- do nothing
 303         END;
 304
 305         -- vandelay.*
 306         -- Update with a rename to avoid collisions
 307         FOR renamable_row in
 308                 SELECT id, name
 309                 FROM   vandelay.queue
 310                 WHERE  owner = src_usr
 311         LOOP
 312                 suffix := ' (' || src_usr || ')';
 313                 LOOP
 314                         BEGIN
 315                                 UPDATE  vandelay.queue
 316                                 SET     owner = dest_usr, name = name || suffix
 317                                 WHERE   id = renamable_row.id;
 318                         EXCEPTION WHEN unique_violation THEN
 319                                 suffix := suffix || ' ';
 320                                 CONTINUE;
 321                         END;
 322                         EXIT;
 323                 END LOOP;
 324         END LOOP;
 325
 326 END;
 327 $$ LANGUAGE plpgsql;
 328
 329 COMMIT;