X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=lib%2FDBIx%2FClass%2FStorage%2FDBI%2FNoBindVars.pm;h=80f367d5435535b5dc89106c9276810bf81a115c;hb=7195d6d12f808e6b4f76dbf3c76e6b173e298e8b;hp=23887622d204ef9718442041eb5d84b9adb558f8;hpb=a4c8f60de274a233052d373013c45af06df2a76c;p=dbsrgits%2FDBIx-Class.git diff --git a/lib/DBIx/Class/Storage/DBI/NoBindVars.pm b/lib/DBIx/Class/Storage/DBI/NoBindVars.pm index 2388762..80f367d 100644 --- a/lib/DBIx/Class/Storage/DBI/NoBindVars.pm +++ b/lib/DBIx/Class/Storage/DBI/NoBindVars.pm @@ -17,58 +17,46 @@ well, as is the case with L =head1 METHODS -=head2 sth +=head2 connect_info -Uses C instead of the usual C, seeing as we can't cache very effectively without bind variables. +We can't cache very effectively without bind variables, so force the C setting to be turned on when the connect info is set. =cut -sub sth { - my ($self, $sql) = @_; - return $self->dbh->prepare($sql); +sub connect_info { + my $self = shift; + my $retval = $self->next::method(@_); + $self->disable_sth_caching(1); + $retval; } -=head2 _execute +=head2 _prep_for_execute -Manually subs in the values for the usual C placeholders before calling L on the generated SQL. +Manually subs in the values for the usual C placeholders. =cut -sub _execute { - my ($self, $op, $extra_bind, $ident, @args) = @_; - my ($sql, @bind) = $self->sql_maker->$op($ident, @args); - unshift(@bind, @$extra_bind) if $extra_bind; - if ($self->debug) { - my @debug_bind = map { defined $_ ? qq{'$_'} : q{'NULL'} } @bind; - $self->debugobj->query_start($sql, @debug_bind); - } - - $sql =~ s/\?/$self->_dbh->quote(shift(@bind))/eg; - - my $sth = eval { $self->sth($sql,$op) }; +sub _prep_for_execute { + my $self = shift; + my ($sql, $bind) = $self->next::method(@_); - if (!$sth || $@) { - $self->throw_exception( - 'no sth generated via sql (' . ($@ || $self->_dbh->errstr) . "): $sql" - ); - } + # stringify args, quote via $dbh, and manually insert - my $rv; - if ($sth) { - my $time = time(); - $rv = eval { $sth->execute }; + my @sql_part = split /\?/, $sql; + my $new_sql; - if ($@ || !$rv) { - $self->throw_exception("Error executing '$sql': ".($@ || $sth->errstr)); + foreach my $bound (@$bind) { + shift @$bound; + foreach my $data (@$bound) { + if(ref $data) { + $data = ''.$data; + } + $new_sql .= shift(@sql_part) . $self->_dbh->quote($data); } - } else { - $self->throw_exception("'$sql' did not generate a statement."); - } - if ($self->debug) { - my @debug_bind = map { defined $_ ? qq{`$_'} : q{`NULL'} } @bind; - $self->debugobj->query_end($sql, @debug_bind); } - return (wantarray ? ($rv, $sth, @bind) : $rv); + $new_sql .= join '', @sql_part; + + return ($new_sql); } =head1 AUTHORS