X-Git-Url: https://git.dogcows.com/gitweb?a=blobdiff_plain;ds=sidebyside;f=lib%2FDBIx%2FClass%2FResultSet%2FRecursiveUpdate.pm;h=0997ff3a8bf854ea4412fcfe89487a9ead358fb6;hb=4bb09f7fc7ffdb7adf715d4c42b9be6624809f7d;hp=ca6a40da24eab5247e5ae6061d2574ef9b3a9360;hpb=16e1ee87cb8acef90879b5276b318201fe82c802;p=chaz%2Fp5-DBIx-Class-ResultSet-RecursiveUpdate diff --git a/lib/DBIx/Class/ResultSet/RecursiveUpdate.pm b/lib/DBIx/Class/ResultSet/RecursiveUpdate.pm index ca6a40d..0997ff3 100644 --- a/lib/DBIx/Class/ResultSet/RecursiveUpdate.pm +++ b/lib/DBIx/Class/ResultSet/RecursiveUpdate.pm @@ -30,8 +30,7 @@ sub recursive_update { if ( blessed($updates) && $updates->isa('DBIx::Class::Row') ) { return $updates; } - - + # warn Dumper( $updates ); use Data::Dumper; # direct column accessors my %columns; @@ -42,8 +41,8 @@ sub recursive_update { # relations that that should be done after the row is inserted into the database # like has_many and might_have my %post_updates; + my %other_methods; my %columns_by_accessor = _get_columns_by_accessor( $self ); - for my $name ( keys %$updates ) { my $source = $self->result_source; if ( $columns_by_accessor{$name} @@ -53,7 +52,10 @@ sub recursive_update { $columns{$name} = $updates->{$name}; next; } - next if !$source->has_relationship($name); + if( !( $source->has_relationship($name) ) ){ + $other_methods{$name} = $updates->{$name}; + next; + } my $info = $source->relationship_info($name); if ( _master_relation_cond( @@ -67,7 +69,7 @@ sub recursive_update { $post_updates{$name} = $updates->{$name}; } } - # warn 'columns: ' . Dumper( \%columns ); use Data::Dumper; + # warn 'other: ' . Dumper( \%other_methods ); use Data::Dumper; my @missing = grep { !exists $columns{$_} && !exists $fixed_fields{$_} } $self->result_source->primary_columns; @@ -76,16 +78,18 @@ sub recursive_update { } $object ||= $self->new( {} ); -# first update columns and other accessors - so that later related records can be found + # first update columns and other accessors - so that later related records can be found for my $name ( keys %columns ) { $object->$name( $updates->{$name} ); } + for my $name ( keys %other_methods) { + $object->$name( $updates->{$name} ) if $object->can( $name ); + } for my $name ( keys %pre_updates ) { my $info = $object->result_source->relationship_info($name); _update_relation( $self, $name, $updates, $object, $info ); } # $self->_delete_empty_auto_increment($object); - # don't allow insert to recurse to related objects - we do the recursion ourselves # $object->{_rel_in_storage} = 1; $object->update_or_insert; @@ -150,9 +154,25 @@ sub _update_relation { } else { my $sub_updates = $updates->{$name}; - $sub_updates = { %$sub_updates, %$resolved } if $resolved && ref( $sub_updates ) eq 'HASH'; - my $sub_object = - recursive_update( resultset => $related_result, updates => $sub_updates ); + my $sub_object; + if( ref $sub_updates ){ + $sub_updates = { %$sub_updates, %$resolved } if $resolved && ref( $sub_updates ) eq 'HASH'; + # for might_have relationship + if( $info->{attrs}{accessor} eq 'single' && defined $object->$name ){ + $sub_object = recursive_update( + resultset => $related_result, + updates => $sub_updates, + object => $object->$name + ); + } + else{ + $sub_object = + recursive_update( resultset => $related_result, updates => $sub_updates ); + } + } + elsif( ! ref $sub_updates ){ + $sub_object = $related_result->find( $sub_updates ); + } $object->set_from_related( $name, $sub_object ); } }