X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=lib%2FDBIx%2FClass%2FRow.pm;h=bf2c408147b5f3e23b7675d6191e5584d3cf4b0e;hb=7e38d85069fbeeff050dc736b756b60c01f85fc6;hp=77e80502c89971b4bf816e010ce4af4f1f473b0c;hpb=bacf6f128dbf3c78308153eab2101bdbf6ca08df;p=dbsrgits%2FDBIx-Class.git diff --git a/lib/DBIx/Class/Row.pm b/lib/DBIx/Class/Row.pm index 77e8050..bf2c408 100644 --- a/lib/DBIx/Class/Row.pm +++ b/lib/DBIx/Class/Row.pm @@ -50,7 +50,9 @@ sub new { my ($class, $attrs) = @_; $class = ref $class if ref $class; - my $new = { _column_data => {} }; + my $new = { + _column_data => {}, + }; bless $new, $class; if (my $handle = delete $attrs->{-source_handle}) { @@ -138,6 +140,9 @@ be set, or the class to have a result_source_instance method. To insert an entirely new object into the database, use C (see L). +To fetch an uninserted row object, call +L on a resultset. + This will also insert any uninserted, related objects held inside this one, see L for more details. @@ -159,11 +164,9 @@ sub insert { %{$self->{_inflated_column} || {}}); if(!$self->{_rel_in_storage}) { - $source->storage->txn_begin; # The guard will save us if we blow out of this scope via die - - $rollback_guard = Scope::Guard->new(sub { $source->storage->txn_rollback }); + $rollback_guard = $source->storage->txn_scope_guard; ## Should all be in relationship_data, but we need to get rid of the ## 'filter' reltype.. @@ -206,7 +209,8 @@ sub insert { } } - $source->storage->insert($source, { $self->get_columns }); + my $updated_cols = $source->storage->insert($source, { $self->get_columns }); + $self->set_columns($updated_cols); ## PK::Auto my @auto_pri = grep { @@ -246,8 +250,7 @@ sub insert { } } } - $source->storage->txn_commit; - $rollback_guard->dismiss; + $rollback_guard->commit; } $self->in_storage(1); @@ -262,7 +265,13 @@ sub insert { $obj->in_storage; # Get value $obj->in_storage(1); # Set value -Indicates whether the object exists as a row in the database or not +Indicates whether the object exists as a row in the database or +not. This is set to true when L, +L or L +are used. + +Creating a row object using L, or calling +L on one, sets it to false. =cut @@ -281,11 +290,26 @@ UPDATE query to commit any changes to the object to the database if required. Also takes an options hashref of C<< column_name => value> pairs >> to update -first. But be awawre that the hashref will be passed to +first. But be aware that the hashref will be passed to C, which might edit it in place, so dont rely on it being the same after a call to C. If you need to preserve the hashref, it is sufficient to pass a shallow copy to C, e.g. ( { %{ $href } } ) +If the values passed or any of the column values set on the object +contain scalar references, eg: + + $obj->last_modified(\'NOW()'); + # OR + $obj->update({ last_modified => \'NOW()' }); + +The update will pass the values verbatim into SQL. (See +L docs). The values in your Row object will NOT change +as a result of the update call, if you want the object to be updated +with the actual values from the database, call L +after the update. + + $obj->update()->discard_changes(); + =cut sub update { @@ -356,10 +380,11 @@ sub delete { my $val = $obj->get_column($col); -Gets a column value from a row object. Does not do any queries; the column -must have already been fetched from the database and stored in the object. If -there is an inflated value stored that has not yet been deflated, it is deflated -when the method is invoked. +Returns a raw column value from the row object, if it has already +been fetched from the database or set by an accessor. + +If an L has been set, it +will be deflated and returned. =cut @@ -397,7 +422,7 @@ sub has_column_loaded { my %data = $obj->get_columns; -Does C, for all column values at once. +Does C, for all loaded column values at once. =cut @@ -426,11 +451,26 @@ sub get_dirty_columns { keys %{$self->{_dirty_columns}}; } +=head2 make_column_dirty + +Marks a column dirty regardless if it has really changed. Throws an +exception if the column does not exist. + +=cut +sub make_column_dirty { + my ($self, $column) = @_; + + $self->throw_exception( "No such column '${column}'" ) + unless exists $self->{_column_data}{$column} || $self->has_column($column); + $self->{_dirty_columns}{$column} = 1; +} + =head2 get_inflated_columns - my $inflated_data = $obj->get_inflated_columns; + my %inflated_data = $obj->get_inflated_columns; -Similar to get_columns but objects are returned for inflated columns instead of their raw non-inflated values. +Similar to get_columns but objects are returned for inflated columns +instead of their raw non-inflated values. =cut @@ -446,9 +486,13 @@ sub get_inflated_columns { $obj->set_column($col => $val); -Sets a column value. If the new value is different from the old one, +Sets a raw column value. If the new value is different from the old one, the column is marked as dirty for when you next call $obj->update. +If passed an object or reference, this will happily attempt store the +value, and a later insert/update will try and stringify/numify as +appropriate. + =cut sub set_column { @@ -458,7 +502,11 @@ sub set_column { my $old = $self->get_column($column); my $ret = $self->store_column(@_); $self->{_dirty_columns}{$column} = 1 - if (defined $old ^ defined $ret) || (defined $old && $old ne $ret); + if (defined $old xor defined $ret) || (defined $old && $old ne $ret); + + # XXX clear out the relation cache for this column + delete $self->{related_resultsets}{$column}; + return $ret; } @@ -528,7 +576,9 @@ sub set_inflated_columns { my $copy = $orig->copy({ change => $to, ... }); -Inserts a new row with the specified changes. +Inserts a new row with the specified changes. If the row has related +objects in a C then those objects may be copied too depending +on the C relationship attribute. =cut @@ -662,7 +712,8 @@ sub inflate_result { $obj->update_or_insert -Updates the object if it's already in the db, else inserts it. +Updates the object if it's already in the database, according to +L, else inserts it. =head2 insert_or_update @@ -748,6 +799,29 @@ sub register_column { $class->mk_group_accessors('column' => $acc); } +=head2 get_from_storage ($attrs) + +Returns a new Row which is whatever the Storage has for the currently created +Row object. You can use this to see if the storage has become inconsistent with +whatever your Row object is. + +$attrs is expected to be a hashref of attributes suitable for passing as the +second argument to $resultset->search($cond, $attrs); + +=cut + +sub get_from_storage { + my $self = shift @_; + my $attrs = shift @_; + my @primary_columns = map { $self->$_ } $self->primary_columns; + my $resultset = $self->result_source->resultset; + + if(defined $attrs) { + $resultset = $resultset->search(undef, $attrs); + } + + return $resultset->find(@primary_columns); +} =head2 throw_exception @@ -764,6 +838,22 @@ sub throw_exception { } } +=head2 id + +Returns the primary key(s) for a row. Can't be called as a class method. +Actually implemented in L + +=head2 discard_changes + +Re-selects the row from the database, losing any changes that had +been made. + +This method can also be used to refresh from storage, retrieving any +changes made since the row was last read from storage. Actually +implemented in L + +=cut + 1; =head1 AUTHORS