X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=lib%2FDBIx%2FClass%2FPK.pm;h=ddd37b9f0c9bcdd9186d800f391bb1b615dbe570;hb=2f5911b218245dc41531709d141e308e53608155;hp=20576bdd3712f42ad5c7257d7742cb55b0b66b68;hpb=daec44b85cffd777869c9652273670b27625e167;p=dbsrgits%2FDBIx-Class-Historic.git diff --git a/lib/DBIx/Class/PK.pm b/lib/DBIx/Class/PK.pm index 20576bd..ddd37b9 100644 --- a/lib/DBIx/Class/PK.pm +++ b/lib/DBIx/Class/PK.pm @@ -4,7 +4,7 @@ use strict; use warnings; use Tie::IxHash; -use base qw/Class::Data::Inheritable/; +use base qw/DBIx::Class::Row/; __PACKAGE__->mk_classdata('_primaries' => {}); @@ -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,20 +64,29 @@ 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}; @@ -79,11 +98,16 @@ sub discard_changes { } 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,10 +115,37 @@ 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