return 0;
}
$self->debugobj->svp_begin($name) if $self->debug;
- $self->_svp_begin($self->dbh(), $name);
+ $self->_svp_begin($name);
}
sub svp_release {
return 0;
}
$self->debugobj->svp_release($name) if $self->debug;
- $self->_svp_release($self->dbh(), $name);
+ $self->_svp_release($name);
}
sub svp_rollback {
return 0;
}
$self->debugobj->svp_rollback($name) if $self->debug;
- $self->_svp_rollback($self->dbh(), $name);
+ $self->_svp_rollback($name);
}
sub txn_begin {
}
sub _svp_begin {
- my ($self, $dbh, $name) = @_;
+ my ($self, $name) = @_;
- $dbh->do("SAVEPOINT $name");
+ $self->dbh->do("SAVEPOINT $name");
}
# Would've implemented _svp_release here, but Oracle doesn't support it.
sub _svp_rollback {
- my ($self, $dbh, $name) = @_;
+ my ($self, $name) = @_;
- $dbh->do("ROLLBACK TO SAVEPOINT $name")
+ $self->dbh->do("ROLLBACK TO SAVEPOINT $name")
}
1;
}
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;
}
sub _svp_begin {
- my ($self, $dbh, $name) = @_;
+ my ($self, $name) = @_;
- $dbh->do("SAVEPOINT $name");
+ $self->dbh->do("SAVEPOINT $name");
}
sub _svp_release {
- my ($self, $dbh, $name) = @_;
+ my ($self, $name) = @_;
- $dbh->do("RELEASE SAVEPOINT $name");
+ $self->dbh->do("RELEASE SAVEPOINT $name");
}
sub _svp_rollback {
- my ($self, $dbh, $name) = @_;
+ my ($self, $name) = @_;
- $dbh->do("ROLLBACK TO SAVEPOINT $name")
+ $self->dbh->do("ROLLBACK TO SAVEPOINT $name")
}
1;