use DBIx::Class::Carp;
use DBIx::Class::_Util 'UNRESOLVABLE_CONDITION';
+use SQL::Abstract 'is_literal_value';
use Devel::GlobalDestruction;
use Try::Tiny;
use List::Util 'first';
#
## returns a hash
# condition
-# join_free_condition (maybe undef)
-# inferred_values (maybe undef, always complete or empty)
+# identity_map
+# join_free_condition (maybe unset)
+# inferred_values (always either complete or unset)
#
sub _resolve_relationship_condition {
my $self = shift;
if !defined $args->{$_} or length ref $args->{$_};
}
- my $rel_info = $self->relationship_info($args->{rel_name});
- # or $self->throw_exception( "No such relationship '$args->{rel_name}'" );
-
my $exception_rel_id = "relationship '$args->{rel_name}' on source '@{[ $self->source_name ]}'";
+ my $rel_info = $self->relationship_info($args->{rel_name});
+ # or $self->throw_exception( "No such $exception_rel_id" );
+
$self->throw_exception("No practical way to resolve $exception_rel_id between two objects")
if defined $args->{self_resultobj} and defined $args->{foreign_resultobj};
+ $self->throw_exception( "Argument to infer_values_based_on must be a hash" )
+ if exists $args->{infer_values_based_on} and ref $args->{infer_values_based_on} ne 'HASH';
- $self->throw_exception( "Object '$args->{foreign_resultobj}' must be of class '$rel_info->{class}'" )
- if defined blessed $args->{foreign_resultobj} and ! $args->{foreign_resultobj}->isa($rel_info->{class});
+ $args->{require_join_free_condition} ||= !!$args->{infer_values_based_on};
$args->{condition} ||= $rel_info->{cond};
- $self->throw_exception( "Argument to infer_values_based_on must be a hash" )
- if exists $args->{infer_values_based_on} and ref $args->{infer_values_based_on} ne 'HASH';
+ if (exists $args->{self_resultobj}) {
+ if (defined blessed $args->{self_resultobj}) {
+# $self->throw_exception( "Object '$args->{self_resultobj}' must be of class '@{[ $self->result_class ]}'" )
+# unless $args->{self_resultobj}->isa($self->result_class);
+ }
+ else {
+ $args->{self_resultobj} = DBIx::Class::Core->new({
+ -result_source => $self,
+ %{ $args->{self_resultobj}||{} }
+ });
+ }
+ }
- $args->{require_join_free_condition} ||= !!$args->{infer_values_based_on};
+ if (exists $args->{foreign_resultobj}) {
+ if (defined blessed $args->{foreign_resultobj}) {
+# $self->throw_exception( "Object '$args->{foreign_resultobj}' must be of class '$rel_info->{class}'" )
+# unless $args->{foreign_resultobj}->isa($rel_info->{class});
+ }
+ else {
+ $args->{foreign_resultobj} = DBIx::Class::Core->new({
+ -result_source => $self->related_source($args->{rel_name}),
+ %{ $args->{foreign_resultobj}||{} }
+ });
+ }
+ }
my $ret;
push @l_cols, $lc;
}
- # construct the crosstable condition
- $ret->{condition} = { map
- {( "$args->{foreign_alias}.$f_cols[$_]" => { -ident => "$args->{self_alias}.$l_cols[$_]" } )}
- (0..$#f_cols)
+ # construct the crosstable condition and the identity map
+ for (0..$#f_cols) {
+ $ret->{condition}{"$args->{foreign_alias}.$f_cols[$_]"} = { -ident => "$args->{self_alias}.$l_cols[$_]" };
+ $ret->{identity_map}{$l_cols[$_]} = $f_cols[$_];
};
if (exists $args->{self_resultobj} or exists $args->{foreign_resultobj}) {
for my $i (0..$#$obj_cols) {
- # FIXME - temp shim
- if (! blessed $obj) {
- $ret->{join_free_condition}{"$plain_alias.$plain_cols->[$i]"} = $obj->{$obj_cols->[$i]};
- }
- elsif (
+ if (
defined $args->{self_resultobj}
and
! $obj->has_column_loaded($obj_cols->[$i])
for keys %{$args->{infer_values_based_on}};
}
+ # add the identities based on the main condition
+ # (may already be there, since easy to calculate on the fly in the HASH case)
+ if ( ! $ret->{identity_map} ) {
+
+ my $col_eqs = $self->schema->storage->_extract_fixed_condition_columns($ret->{condition});
+
+ my $colinfos;
+ for my $lhs (keys %$col_eqs) {
+
+ next if $col_eqs->{$lhs} eq UNRESOLVABLE_CONDITION;
+ my ($rhs) = @{ is_literal_value( $ret->{condition}{$lhs} ) || next };
+
+ # there is no way to know who is right and who is left
+ # therefore the ugly scan below
+ $colinfos ||= $self->schema->storage->_resolve_column_info([
+ { -alias => $args->{self_alias}, -rsrc => $self },
+ { -alias => $args->{foreign_alias}, -rsrc => $self->related_source($args->{rel_name}) },
+ ]);
+
+ my ($l_col, $l_alias, $r_col, $r_alias) = map {
+ ( reverse $_ =~ / ^ (?: ([^\.]+) $ | ([^\.]+) \. (.+) ) /x )[0,1]
+ } ($lhs, $rhs);
+
+ if (
+ $colinfos->{$l_col}
+ and
+ $colinfos->{$r_col}
+ and
+ $colinfos->{$l_col}{-source_alias} ne $colinfos->{$r_col}{-source_alias}
+ ) {
+ ( $colinfos->{$l_col}{-source_alias} eq $args->{self_alias} )
+ ? ( $ret->{identity_map}{$l_col} = $r_col )
+ : ( $ret->{identity_map}{$r_col} = $l_col )
+ ;
+ }
+ }
+ }
+
$ret
}