X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=lib%2FDBIx%2FClass%2FPK.pm;h=ab135e0b604a138f940bd011adaf70c8fb26882b;hb=103647d504eeadac7d179057e9f4d5eda0cd7c1b;hp=e420ac62497daf7b861e1bc51f14ad2a153f3f14;hpb=656796f2088da66cc80f4eb127c39c923ef3c1dd;p=dbsrgits%2FDBIx-Class.git diff --git a/lib/DBIx/Class/PK.pm b/lib/DBIx/Class/PK.pm index e420ac6..ab135e0 100644 --- a/lib/DBIx/Class/PK.pm +++ b/lib/DBIx/Class/PK.pm @@ -25,7 +25,6 @@ and depending on them. =cut - sub _ident_cond { my ($class) = @_; return join(" AND ", map { "$_ = ?" } keys %{$class->_primaries}); @@ -36,14 +35,25 @@ sub _ident_values { return (map { $self->{_column_data}{$_} } keys %{$self->_primaries}); } +=item set_primary_key <@cols> + +define one or more columns as primary key for this class + +=cut + sub set_primary_key { my ($class, @cols) = @_; my %pri; - tie %pri, 'Tie::IxHash'; - %pri = map { $_ => {} } @cols; + tie %pri, 'Tie::IxHash', map { $_ => {} } @cols; $class->_primaries(\%pri); } +=item find + +Finds columns based on the primary key(s). + +=cut + sub find { my ($class, @vals) = @_; my $attrs = (@vals > 1 && ref $vals[$#vals] eq 'HASH' ? pop(@vals) : {}); @@ -54,36 +64,50 @@ sub find { if (ref $vals[0] eq 'HASH') { $query = $vals[0]; } elsif (@pk == @vals) { - my $ret = ($class->search_literal($class->_ident_cond, @vals, $attrs))[0]; + $query = {}; + @{$query}{@pk} = @vals; + #my $ret = ($class->search_literal($class->_ident_cond, @vals, $attrs))[0]; #warn "$class: ".join(', ', %{$ret->{_column_data}}); - return $ret; + #return $ret; } else { $query = {@vals}; } $class->throw( "Can't find unless all primary keys are specified" ) unless (keys %$query >= @pk); # If we check 'em we run afoul of uc/lc # column names etc. Not sure what to do yet - my $ret = ($class->search($query))[0]; - #warn "$class: ".join(', ', %{$ret->{_column_data}}); - return $ret; + #return $class->search($query)->next; + my @cols = $class->_select_columns; + my @row = $class->storage->select_single($class->_table_name, \@cols, $query); + return (@row ? $class->_row_to_object(\@cols, \@row) : ()); } +=item discard_changes + +Roll back changes that hasn't been comitted to the database. + +=cut + sub discard_changes { my ($self) = @_; delete $self->{_dirty_columns}; - return unless $self->in_database; # Don't reload if we aren't real! + return unless $self->in_storage; # Don't reload if we aren't real! my ($reload) = $self->find($self->id); unless ($reload) { # If we got deleted in the mean-time - $self->in_database(0); + $self->in_storage(0); return $self; } delete @{$self}{keys %$self}; @{$self}{keys %$reload} = values %$reload; - #$self->store_column($_ => $reload->get_column($_)) - # foreach keys %{$self->_columns}; return $self; } +=item id + +returns the primary key(s) for the current row. Can't be called as +a class method. + +=cut + sub id { my ($self) = @_; $self->throw( "Can't call id() as a class method" ) unless ref $self; @@ -91,17 +115,44 @@ sub id { return (wantarray ? @pk : $pk[0]); } +=item primary_columns + +read-only accessor which returns a list of primary keys. + +=cut + sub primary_columns { return keys %{shift->_primaries}; } +sub ID { + my ($self) = @_; + $self->throw( "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}{$_} } keys %{$self->_primaries}); +} + +sub _create_ID { + my ($class,%vals) = @_; + return undef unless 0 == grep { !defined } values %vals; + $class = ref $class || $class; + return join '|', $class, map { $_ . '=' . $vals{$_} } sort keys %vals; +} + +sub ident_condition { + my ($self) = @_; + my %cond; + $cond{$_} = $self->get_column($_) for $self->primary_columns; + return \%cond; +} + 1; =back =head1 AUTHORS -Matt S. Trout +Matt S. Trout =head1 LICENSE