X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=lib%2FDBIx%2FClass%2FPK.pm;h=ed0b830a4302fae3d52ef7ac3a8a11ea8c012792;hb=1a14aa3f5016c456db28c148abab256ea72776df;hp=2725ff963fca23d22523daf12cda960d53490fb5;hpb=510ca9120ab2fea50a0852ee4ed6a13735ed7ebc;p=dbsrgits%2FDBIx-Class.git diff --git a/lib/DBIx/Class/PK.pm b/lib/DBIx/Class/PK.pm index 2725ff9..ed0b830 100644 --- a/lib/DBIx/Class/PK.pm +++ b/lib/DBIx/Class/PK.pm @@ -2,11 +2,30 @@ package DBIx::Class::PK; use strict; use warnings; +use Tie::IxHash; -use base qw/Class::Data::Inheritable DBIx::Class::SQL/; +use base qw/Class::Data::Inheritable/; __PACKAGE__->mk_classdata('_primaries' => {}); +=head1 NAME + +DBIx::Class::PK - Primary Key class + +=head1 SYNOPSIS + +=head1 DESCRIPTION + +This class represents methods handling primary keys +and depending on them. + +=head1 METHODS + +=over 4 + +=cut + + sub _ident_cond { my ($class) = @_; return join(" AND ", map { "$_ = ?" } keys %{$class->_primaries}); @@ -20,32 +39,76 @@ sub _ident_values { sub set_primary_key { my ($class, @cols) = @_; my %pri; - $pri{$_} = {} for @cols; + tie %pri, 'Tie::IxHash'; + %pri = map { $_ => {} } @cols; $class->_primaries(\%pri); } -sub retrieve { +sub find { my ($class, @vals) = @_; + my $attrs = (@vals > 1 && ref $vals[$#vals] eq 'HASH' ? pop(@vals) : {}); my @pk = keys %{$class->_primaries}; - die "Can't retrieve unless primary columns are defined" unless @pk; + $class->throw( "Can't find unless primary columns are defined" ) + unless @pk; my $query; if (ref $vals[0] eq 'HASH') { $query = $vals[0]; } elsif (@pk == @vals) { - return ($class->retrieve_from_sql($class->_ident_cond, @vals))[0]; + $query = {}; + @{$query}{@pk} = @vals; + #my $ret = ($class->search_literal($class->_ident_cond, @vals, $attrs))[0]; + #warn "$class: ".join(', ', %{$ret->{_column_data}}); + #return $ret; } else { $query = {@vals}; } - die "Can't retrieve unless all primary keys are specified" + $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 - return ($class->search($query))[0]; + #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) : ()); } sub discard_changes { my ($self) = @_; delete $self->{_dirty_columns}; - $_[0] = $self->retrieve($self->id); + 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_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; +} + +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]); +} + +sub primary_columns { + return keys %{shift->_primaries}; } 1; + +=back + +=head1 AUTHORS + +Matt S. Trout + +=head1 LICENSE + +You may distribute this code under the same terms as Perl itself. + +=cut +