}
sub _svp_begin {
- my ($self, $dbh, $name) = @_;
+ my ($self, $name) = @_;
- $dbh->pg_savepoint($name);
+ $self->dbh->pg_savepoint($name);
}
sub _svp_release {
- my ($self, $dbh, $name) = @_;
+ my ($self, $name) = @_;
- $dbh->pg_release($name;)
+ $self->dbh->pg_release($name);
}
sub _svp_rollback {
- my ($self, $dbh, $name) = @_;
+ my ($self, $name) = @_;
- $dbh->pg_rollback_to($name);
+ $self->dbh->pg_rollback_to($name);
}
1;