X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=lib%2FDBIx%2FClass%2FRelationship%2FCascadeActions.pm;h=fde8f5df9624d91eaf200153541898d0ec450b21;hb=v0.08123;hp=aa880433dcd04aba568eada4e9ecb92b9a09e41e;hpb=b044b5d3118a1a147351cb337a49f788adc7e3be;p=dbsrgits%2FDBIx-Class.git diff --git a/lib/DBIx/Class/Relationship/CascadeActions.pm b/lib/DBIx/Class/Relationship/CascadeActions.pm index aa88043..fde8f5d 100644 --- a/lib/DBIx/Class/Relationship/CascadeActions.pm +++ b/lib/DBIx/Class/Relationship/CascadeActions.pm @@ -4,6 +4,11 @@ package # hide from PAUSE use strict; use warnings; +our %_pod_inherit_config = + ( + class_map => { 'DBIx::Class::Relationship::CascadeActions' => 'DBIx::Class::Relationship' } + ); + sub delete { my ($self, @rest) = @_; return $self->next::method(@rest) unless ref $self; @@ -11,15 +16,24 @@ sub delete { # be handling this anyway. Assuming we have joins we probably actually # *could* do them, but I'd rather not. - my $ret = $self->next::method(@rest); - my $source = $self->result_source; my %rels = map { $_ => $source->relationship_info($_) } $source->relationships; my @cascade = grep { $rels{$_}{attrs}{cascade_delete} } keys %rels; - foreach my $rel (@cascade) { - $self->search_related($rel)->delete_all; + + if (@cascade) { + my $guard = $source->schema->txn_scope_guard; + + my $ret = $self->next::method(@rest); + + foreach my $rel (@cascade) { + $self->search_related($rel)->delete_all; + } + + $guard->commit; + return $ret; } - return $ret; + + $self->next::method(@rest); } sub update { @@ -27,15 +41,31 @@ sub update { return $self->next::method(@rest) unless ref $self; # Because update cascades on a class *really* don't make sense! - my $ret = $self->next::method(@rest); - my $source = $self->result_source; my %rels = map { $_ => $source->relationship_info($_) } $source->relationships; my @cascade = grep { $rels{$_}{attrs}{cascade_update} } keys %rels; - foreach my $rel (@cascade) { - $_->update for grep defined, $self->$rel; + + if (@cascade) { + my $guard = $source->schema->txn_scope_guard; + + my $ret = $self->next::method(@rest); + + foreach my $rel (@cascade) { + next if ( + $rels{$rel}{attrs}{accessor} + && + $rels{$rel}{attrs}{accessor} eq 'single' + && + !exists($self->{_relationship_data}{$rel}) + ); + $_->update for grep defined, $self->$rel; + } + + $guard->commit; + return $ret; } - return $ret; + + $self->next::method(@rest); } 1;