From: erickson Date: Mon, 26 Jan 2009 17:10:10 +0000 (+0000) Subject: enable direct use of xact_begin/rollback/commit for managing transactions. change... X-Git-Url: https://old-git.evergreen-ils.org/?a=commitdiff_plain;h=d24aa9855fafee9c8deeeff8ec7742a89746aa6d;p=evergreen%2Ftadl.git enable direct use of xact_begin/rollback/commit for managing transactions. change xact_start to xact_begin for consistency git-svn-id: svn://svn.open-ils.org/ILS/trunk@11972 dcc99617-32d9-48b4-a31d-7c20da2025e4 --- diff --git a/Open-ILS/src/perlmods/OpenILS/Utils/CStoreEditor.pm b/Open-ILS/src/perlmods/OpenILS/Utils/CStoreEditor.pm index 7576b9bb7e..b332f296c1 100644 --- a/Open-ILS/src/perlmods/OpenILS/Utils/CStoreEditor.pm +++ b/Open-ILS/src/perlmods/OpenILS/Utils/CStoreEditor.pm @@ -183,7 +183,7 @@ sub session { } $self->{session}->connect if $self->{xact} or $self->{connect} or $always_xact; - $self->xact_start if $self->{xact} or $always_xact; + $self->xact_begin if $self->{xact} or $always_xact; } $xact_ed_cache{$self->{xact_id}} = $self if $always_xact; @@ -194,12 +194,13 @@ sub session { # ----------------------------------------------------------------------------- # Starts a storage transaction # ----------------------------------------------------------------------------- -sub xact_start { +sub xact_begin { my $self = shift; - $self->log(D, "starting new db session"); + $self->log(D, "starting new database transaction"); my $stat = $self->request($self->app . '.transaction.begin') unless $self->{xact_id}; $self->log(E, "error starting database transaction") unless $stat; $self->{xact_id} = $stat; + $self->{xact} = 1; return $stat; } @@ -213,6 +214,7 @@ sub xact_commit { my $stat = $self->request($self->app.'.transaction.commit'); $self->log(E, "error comitting database transaction") unless $stat; delete $self->{xact_id}; + delete $self->{xact}; return $stat; } @@ -221,11 +223,12 @@ sub xact_commit { # ----------------------------------------------------------------------------- sub xact_rollback { my $self = shift; - return unless $self->{session} and $self->{xact_id}; + return unless $self->{session} and $self->{xact_id}; $self->log(I, "rolling back db session"); my $stat = $self->request($self->app.".transaction.rollback"); $self->log(E, "error rolling back database transaction") unless $stat; delete $self->{xact_id}; + delete $self->{xact}; return $stat; } @@ -237,14 +240,13 @@ sub xact_rollback { sub rollback { my $self = shift; $self->xact_rollback; - delete $self->{xact}; $self->disconnect; } sub disconnect { my $self = shift; $self->session->disconnect if $self->{session}; - delete $self->{session}; + delete $self->{session}; }