X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=lib%2FDBIx%2FClass%2FStorage%2FDBI%2FNoBindVars.pm;h=349f658800b98a7554918851e11f86ab425b1ad3;hb=9901aad73ff9dc45b426534fe406c102fb9fb77c;hp=09a45f6e451a819f73b2971a89c9266acdc34b6a;hpb=e417cd15072587644f733d7b68153acb37fa227b;p=dbsrgits%2FDBIx-Class.git diff --git a/lib/DBIx/Class/Storage/DBI/NoBindVars.pm b/lib/DBIx/Class/Storage/DBI/NoBindVars.pm index 09a45f6..349f658 100644 --- a/lib/DBIx/Class/Storage/DBI/NoBindVars.pm +++ b/lib/DBIx/Class/Storage/DBI/NoBindVars.pm @@ -17,58 +17,51 @@ 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); - } +sub _prep_for_execute { + my $self = shift; - $sql =~ s/\?/shift(@bind)/eg; + my ($op, $extra_bind, $ident) = @_; - my $sth = eval { $self->sth($sql,$op) }; + 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) { + my $col = shift @$bound; + my $datatype = 'FIXME!!!'; + foreach my $data (@$bound) { + if(ref $data) { + $data = ''.$data; + } + $data = $self->_dbh->quote($data); + $new_sql .= shift(@sql_part) . $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