X-Git-Url: https://git.dogcows.com/gitweb?p=chaz%2Fp5-DBIx-Class-ResultSet-RecursiveUpdate;a=blobdiff_plain;f=lib%2FDBIx%2FClass%2FResultSet%2FRecursiveUpdate.pm;h=20158603eb191e82e672e138c2e2c20bd0aec591;hp=c3a1356047ce1984751a8eb861ddbb6df17bfe63;hb=836cf9832dc52973f698b000d7df8604c0b0d342;hpb=0e11e6eb9eb4c5cd9c65ba395fc3f9420715ebbb diff --git a/lib/DBIx/Class/ResultSet/RecursiveUpdate.pm b/lib/DBIx/Class/ResultSet/RecursiveUpdate.pm index c3a1356..2015860 100644 --- a/lib/DBIx/Class/ResultSet/RecursiveUpdate.pm +++ b/lib/DBIx/Class/ResultSet/RecursiveUpdate.pm @@ -49,16 +49,29 @@ sub recursive_update { my $source = $self->result_source; + croak "first parameter needs to be defined" + unless defined $updates; + + croak "first parameter needs to be a hashref" + unless ref($updates) eq 'HASH'; + # warn 'entering: ' . $source->from(); croak 'fixed fields needs to be an arrayref' if defined $fixed_fields && ref $fixed_fields ne 'ARRAY'; + # always warn about additional parameters if storage debugging is enabled + $unknown_params_ok = 0 + if $source->storage->debug; + if ( blessed($updates) && $updates->isa('DBIx::Class::Row') ) { return $updates; } - if ( exists $updates->{id} ) { + + if ( !defined $object && exists $updates->{id} ) { + # warn "finding object by id " . $updates->{id} . "\n"; $object = $self->find( $updates->{id}, { key => 'primary' } ); + # warn "object not found by id\n" # unless defined $object; } @@ -68,15 +81,16 @@ sub recursive_update { my @missing = grep { !exists $updates->{$_} && !exists $fixed_fields{$_} } $source->primary_columns; - if ( !$object && !scalar @missing ) { + + # warn "MISSING: " . join(', ', @missing) . "\n"; + if ( !defined $object && scalar @missing == 0 ) { # warn 'finding by: ' . Dumper( $updates ); use Data::Dumper; $object = $self->find( $updates, { key => 'primary' } ); } $updates = { %$updates, %$resolved }; - @missing = - grep { !exists $resolved->{$_} } @missing; - if ( !$object && !scalar @missing ) { + @missing = grep { !exists $resolved->{$_} } @missing; + if ( !defined $object && scalar @missing == 0 ) { # warn 'finding by +resolved: ' . Dumper( $updates ); use Data::Dumper; $object = $self->find( $updates, { key => 'primary' } ); @@ -104,6 +118,7 @@ sub recursive_update { # warn 'updates: ' . Dumper( $updates ); use Data::Dumper; # warn 'columns: ' . Dumper( \%columns_by_accessor ); for my $name ( keys %$updates ) { + # columns if ( exists $columns_by_accessor{$name} && !( $source->has_relationship($name) @@ -197,7 +212,7 @@ sub recursive_update { #warn "update m2m $name\n"; # TODO: only first pk col is used my ($pk) = _get_pk_for_related( $self, $name ); - my @rows = (); + my @rows; my $result_source = $object->$name->result_source; my @updates; if ( defined $value && ref $value eq 'ARRAY' ) { @@ -206,16 +221,20 @@ sub recursive_update { elsif ( defined $value && !ref $value ) { @updates = ($value); } - else { - carp "value of many-to-many rel '$name' must be an arrayref or scalar"; + elsif ( defined $value ) { + carp + "value of many-to-many rel '$name' must be an arrayref or scalar: $value"; } for my $elem (@updates) { - if ( ref $elem ) { + if ( blessed($elem) && $elem->isa('DBIx::Class::Row') ) { push @rows, $elem; - # recursive_update( - # resultset => $result_source->resultset, - # updates => $elem - # ); + } + elsif ( ref $elem eq 'HASH' ) { + push @rows, + recursive_update( + resultset => $result_source->resultset, + updates => $elem + ); } else { push @rows, @@ -280,6 +299,8 @@ sub _update_relation { && $DBIx::Class::ResultSource::UNRESOLVABLE_CONDITION == $resolved; + #warn "RESOLVED: " . Dumper($resolved); use Data::Dumper; + my @rel_cols = keys %{ $info->{cond} }; map {s/^foreign\.//} @rel_cols; @@ -378,9 +399,12 @@ sub _update_relation { #warn "\tupdating rel '$name': $if_not_submitted\n"; my $sub_object; if ( ref $updates ) { + if ( blessed($updates) && $updates->isa('DBIx::Class::Row') ) { + $sub_object = $updates; + } # for might_have relationship - if ( $info->{attrs}{accessor} eq 'single' + elsif ( $info->{attrs}{accessor} eq 'single' && defined $object->$name ) { $sub_object = recursive_update(