X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=lib%2FDBIx%2FClass%2FStorage%2FDBI%2FPg.pm;h=91418a4f1beede0672b8edbafb3e768e6a74ad44;hb=bc144884abdf828846ecc29122647fdaf1ac2487;hp=8513a64d7a3f16192be90afa95bd6f6f53a665a2;hpb=6528878c9901803efb8cdd8561ae17a9d9409d2a;p=dbsrgits%2FDBIx-Class-Historic.git diff --git a/lib/DBIx/Class/Storage/DBI/Pg.pm b/lib/DBIx/Class/Storage/DBI/Pg.pm index 8513a64..91418a4 100644 --- a/lib/DBIx/Class/Storage/DBI/Pg.pm +++ b/lib/DBIx/Class/Storage/DBI/Pg.pm @@ -15,7 +15,7 @@ warn "DBD::Pg 2.9.2 or greater is strongly recommended\n" sub with_deferred_fk_checks { my ($self, $sub) = @_; - $self->dbh->do('SET CONSTRAINTS ALL DEFERRED'); + $self->last_dbh->do('SET CONSTRAINTS ALL DEFERRED'); $sub->(); } @@ -79,7 +79,7 @@ sub bind_attribute_by_data_type { bytea => { pg_type => DBD::Pg::PG_BYTEA }, blob => { pg_type => DBD::Pg::PG_BYTEA }, }; - + if( defined $bind_attributes->{$data_type} ) { return $bind_attributes->{$data_type}; } @@ -90,26 +90,26 @@ sub bind_attribute_by_data_type { sub _sequence_fetch { my ( $self, $type, $seq ) = @_; - my ($id) = $self->dbh->selectrow_array("SELECT nextval('${seq}')"); + my ($id) = $self->last_dbh->selectrow_array("SELECT nextval('${seq}')"); return $id; } sub _svp_begin { my ($self, $name) = @_; - $self->dbh->pg_savepoint($name); + $self->last_dbh->pg_savepoint($name); } sub _svp_release { my ($self, $name) = @_; - $self->dbh->pg_release($name); + $self->last_dbh->pg_release($name); } sub _svp_rollback { my ($self, $name) = @_; - $self->dbh->pg_rollback_to($name); + $self->last_dbh->pg_rollback_to($name); } 1;