/[BackupPC]/trunk/sql/09_backup_parts_trigger.sql
This is repository of my old source code which isn't updated any more. Go to git.rot13.org for current projects!
ViewVC logotype

Diff of /trunk/sql/09_backup_parts_trigger.sql

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 324 by dpavlin, Tue Jan 31 16:22:21 2006 UTC revision 329 by dpavlin, Tue Jan 31 22:04:47 2006 UTC
# Line 6  declare Line 6  declare
6          b_counted integer;          b_counted integer;
7          b_id    integer;          b_id    integer;
8  begin  begin
9            -- raise notice ''old/new parts %/% backup_id %/%'', old.parts, new.parts, old.id, new.id;
10          if (TG_OP=''UPDATE'') then          if (TG_OP=''UPDATE'') then
11                  b_id := old.id;                  b_id := new.id;
12                  b_parts := old.parts;                  b_parts := new.parts;
13          elsif (TG_OP = ''INSERT'') then          elsif (TG_OP = ''INSERT'') then
14                  b_id := new.id;                  b_id := new.id;
15                  b_parts := new.parts;                  b_parts := new.parts;
# Line 28  create trigger do_backup_parts_check Line 29  create trigger do_backup_parts_check
29          after insert or update or delete on backups          after insert or update or delete on backups
30          for each row execute procedure backup_parts_check();          for each row execute procedure backup_parts_check();
31    
32    create or replace function backup_backup_parts_check() returns trigger as '
33    declare
34            b_id            integer;
35            my_part_nr      integer;
36            calc_part       integer;
37    begin
38            if (TG_OP = ''INSERT'') then
39                    -- raise notice ''trigger: % backup_id %'', TG_OP, new.backup_id;
40                    b_id = new.backup_id;
41                    my_part_nr = new.part_nr;
42                    execute ''update backups set parts = parts + 1 where id = '' || b_id;
43            elsif (TG_OP = ''DELETE'') then
44                    -- raise notice ''trigger: % backup_id %'', TG_OP, old.backup_id;
45                    b_id = old.backup_id;
46                    my_part_nr = old.part_nr;
47                    execute ''update backups set parts = parts - 1 where id = '' || b_id;
48            end if;
49            calc_part := (select count(part_nr) from backup_parts where backup_id = b_id);
50            if ( my_part_nr != calc_part ) then
51                    raise exception ''Update of backup_parts with backup_id % aborted, requested part_nr is % and calulated next is %'', b_id, my_part_nr, calc_part;
52            end if;
53            return null;
54    end;
55    ' language plpgsql;
56    
57    drop trigger do_backup_backup_parts_check on backup_parts;
58    
59    create trigger do_backup_backup_parts_check
60            after insert or update or delete on backup_parts
61            for each row execute procedure backup_backup_parts_check();
62    
Legend:
Removed from v.324  
changed lines
  Added in v.329
  ViewVC Help
Powered by ViewVC 1.1.26