File Coverage

blib/lib/ResourcePool/Command/DBI/Execute.pm

Criterion	Covered	Total	%
statement	18	36	50.0
branch	0	8	0.0
condition	0	6	0.0
subroutine	6	7	85.7
pod	1	1	100.0
total	25	58	43.1

#*********************************************************************
#*** lib/ResourcePool/Command/DBI/Execute.pm
#*** Copyright (c) 2004 by Markus Winand
#*** $Id: Execute.pm,v 1.5 2004/05/02 07:48:55 mws Exp $
#*********************************************************************
package ResourcePool::Command::DBI::Execute;

use ResourcePool::Command;
use ResourcePool::Command::NoFailoverException;
use ResourcePool::Command::DBI::Common;
use strict;
use DBI;
use vars qw(@ISA $VERSION);

$VERSION = "1.0101";
push @ISA, qw(ResourcePool::Command::DBI::Common ResourcePool::Command);

sub execute($$@) {
	my ($self, $dbh, @args) = @_;

	my $sql = $self->getSQLfromargs(\@args);
	my $sth = $self->prepare($dbh, $sql);

	$self->bind($sth, \@args);

	my $rc = 1;
	eval {
		$rc = $sth->execute();
	};

	if ($rc && ! $@) {
		if (! $dbh->{AutoCommit}) {
			$rc = $dbh->commit();
		}
		return $rc;
	} else {
		# test if failover should occure
		eval {
			if (! $dbh->{AutoCommit}) {
				$rc = $dbh->rollback();
			} else {
				$rc = $dbh->ping();
			}
		};
		if ($rc && ! @_) {
			die 'Execution of "' . $sql . '" failed: ' . $dbh->errstr() . "\n";
		} else {
			die ResourcePool::Command::NoFailoverException->new(
				'Execution of "' . $sql . '" failed: ' . $dbh->errstr() . "\n"
			);
		}
	}
}

1;