sql/Pg-upgrade2/orderitems_delivery_order_items_positions.pl

   1 # @tag: orderitems_delivery_order_items_positions
   2 # @description: Spalte für Positionen der Einträge in Angeboten/Auftträgen und Lieferscheinen.
   3 # @depends: release_3_1_0
   4 # @encoding: utf-8
   5 package SL::DBUpgrade2::orderitems_delivery_order_items_positions;
   6
   7 use strict;
   8 use utf8;
   9
  10 use parent qw(SL::DBUpgrade2::Base);
  11
  12 sub run {
  13   my ($self) = @_;
  14
  15   my %order_id_cols = (
  16     orderitems           => 'trans_id',
  17     delivery_order_items => 'delivery_order_id',
  18   );
  19
  20   foreach my $table ( keys %order_id_cols ) {
  21
  22     my $query = qq|ALTER TABLE $table ADD position INTEGER|;
  23     $self->db_query($query);
  24
  25
  26     my $order_id_col = $order_id_cols{ $table };
  27     $query = qq|SELECT * FROM $table ORDER BY $order_id_col, id|;
  28     my $query2 = qq|UPDATE $table SET position = ? WHERE id = ?|;
  29
  30     my $sth = $self->dbh->prepare($query);
  31     my $sth2 = $self->dbh->prepare($query2);
  32     $sth->execute || $::form->dberror($query);
  33
  34     # set new position field in order of ids, starting by one for each order
  35     my $last_order_id;
  36     my $position;
  37     while (my $ref = $sth->fetchrow_hashref("NAME_lc")) {
  38       if ($ref->{ $order_id_col } != $last_order_id) {
  39         $position = 1;
  40       } else {
  41         $position++;
  42       }
  43       $last_order_id = $ref->{ $order_id_col };
  44
  45       $sth2->execute($position, $ref->{id});
  46     }
  47     $sth->finish;
  48     $sth2->finish;
  49
  50
  51     $query = qq|ALTER TABLE $table ALTER COLUMN position SET NOT NULL|;
  52     $self->db_query($query);
  53   }
  54
  55   return 1;
  56 }
  57
  58 1;