X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=lib%2FDBIx%2FClass%2FPK.pm;h=c4d3b93944dcf88765ce95cfc8796b2036bc5775;hb=572338e0c6b2b119362ae59880813b0d5188c62f;hp=4889b637aa1e810ae9b6d3ca4a86e3090089ae86;hpb=fea3d0452969e98afc0296ba80f90a91ab7dc1be;p=dbsrgits%2FDBIx-Class.git diff --git a/lib/DBIx/Class/PK.pm b/lib/DBIx/Class/PK.pm index 4889b63..c4d3b93 100644 --- a/lib/DBIx/Class/PK.pm +++ b/lib/DBIx/Class/PK.pm @@ -2,11 +2,10 @@ package DBIx::Class::PK; use strict; use warnings; -use Tie::IxHash; use base qw/DBIx::Class::Row/; -=head1 NAME +=head1 NAME DBIx::Class::PK - Primary Key class @@ -14,84 +13,113 @@ DBIx::Class::PK - Primary Key class =head1 DESCRIPTION -This class contains methods for handling primary keys and methods +This class contains methods for handling primary keys and methods depending on them. =head1 METHODS =cut -sub _ident_cond { - my ($class) = @_; - return join(" AND ", map { "$_ = ?" } $class->primary_columns); -} - -sub _ident_values { - my ($self) = @_; - return (map { $self->{_column_data}{$_} } $self->primary_columns); -} - -=head2 discard_changes +=head2 id -Re-selects the row from the database, losing any changes that had -been made. +Returns the primary key(s) for a row. Can't be called as +a class method. =cut -sub discard_changes { +sub id { my ($self) = @_; - delete $self->{_dirty_columns}; - return unless $self->in_storage; # Don't reload if we aren't real! - my ($reload) = $self->find(map { $self->$_ } $self->primary_columns); - unless ($reload) { # If we got deleted in the mean-time - $self->in_storage(0); - return $self; - } - delete @{$self}{keys %$self}; - @{$self}{keys %$reload} = values %$reload; - return $self; + $self->throw_exception( "Can't call id() as a class method" ) + unless ref $self; + my @id_vals = $self->_ident_values; + return (wantarray ? @id_vals : $id_vals[0]); } -=head2 id +sub _ident_values { + my ($self) = @_; -Returns the primary key(s) for a row. Can't be called as -a class method. + my (@ids, @missing); -=cut + for ($self->_pri_cols) { + push @ids, $self->get_column($_); + push @missing, $_ if (! defined $ids[-1] and ! $self->has_column_loaded ($_) ); + } -sub id { - my ($self) = @_; - $self->throw( "Can't call id() as a class method" ) unless ref $self; - my @pk = $self->_ident_values; - return (wantarray ? @pk : $pk[0]); + if (@missing && $self->in_storage) { + $self->throw_exception ( + 'Unable to uniquely identify row object with missing PK columns: ' + . join (', ', @missing ) + ); + } + + return @ids; } =head2 ID Returns a unique id string identifying a row object by primary key. -Used by L and +Used by L and L. +=over + +=item WARNING + +The default C<_create_ID> method used by this function orders the returned +values by the alphabetical order of the primary column names, B +the L method, which follows the same order in which columns were fed +to L. + +=back + =cut sub ID { my ($self) = @_; - $self->throw( "Can't call ID() as a class method" ) unless ref $self; + $self->throw_exception( "Can't call ID() as a class method" ) + unless ref $self; return undef unless $self->in_storage; - return $self->_create_ID(map { $_ => $self->{_column_data}{$_} } $self->primary_columns); + return $self->_create_ID(%{$self->ident_condition}); } sub _create_ID { - my ($class,%vals) = @_; + my ($self, %vals) = @_; return undef unless 0 == grep { !defined } values %vals; - $class = ref $class || $class; - return join '|', $class, map { $_ . '=' . $vals{$_} } sort keys %vals; + return join '|', ref $self || $self, $self->result_source->name, + map { $_ . '=' . $vals{$_} } sort keys %vals; } +=head2 ident_condition + + my $cond = $result_source->ident_condition(); + + my $cond = $result_source->ident_condition('alias'); + +Produces a condition hash to locate a row based on the primary key(s). + +=cut + sub ident_condition { my ($self, $alias) = @_; - my %cond; - $cond{(defined $alias ? "${alias}.$_" : $_)} = $self->get_column($_) for $self->primary_columns; + + my @pks = $self->_pri_cols; + my @vals = $self->_ident_values; + + my (%cond, @undef); + my $prefix = defined $alias ? $alias.'.' : ''; + for my $col (@pks) { + if (! defined ($cond{$prefix.$col} = shift @vals) ) { + push @undef, $col; + } + } + + if (@undef && $self->in_storage) { + $self->throw_exception ( + 'Unable to construct row object identity condition due to NULL PK columns: ' + . join (', ', @undef) + ); + } + return \%cond; }