File Coverage

blib/lib/DBIx/DataModel/Schema/ResultAs/Correlated_update.pm

Criterion	Covered	Total	%
statement	31	31	100.0
branch			n/a
condition			n/a
subroutine	7	7	100.0
pod	1	2	50.0
total	39	40	97.5

#----------------------------------------------------------------------
package DBIx::DataModel::Schema::ResultAs::Correlated_update;
#----------------------------------------------------------------------
use warnings;
use strict;
use DBIx::DataModel::Statement;

use parent 'DBIx::DataModel::Schema::ResultAs';

sub new {
  my ($class, $to_set) = @_;
  bless {to_set => $to_set}, $class;
}

sub get_result {
  my ($self, $statement) = @_;

  $statement->_forbid_callbacks(__PACKAGE__);
  $statement->sqlize;

  my ($sql, @bind)   = $statement->sql;
  my $schema         = $statement->schema;
  my $to_set         = $self->{to_set};
  $sql = "UPDATE ($sql) SET " . join ", ", map {"$_=$to_set->{$_}"} keys %$to_set;
  $schema->_debug(do {no warnings 'uninitialized'; $sql . " / " . CORE::join(", ", @bind);});

  my $prepare_method = $schema->dbi_prepare_method;
  my $sth            = $schema->dbh->$prepare_method($sql);

  $statement->sql_abstract->bind_params($sth, @bind);
  return $sth->execute(); # will return the number of updated records
}

1;

__END__