#********************************************************************* 
#*** lib/ResourcePool/Command/DBI/Execute.pm
#*** Copyright (c) 2004 by Markus Winand <mws@fatalmind.com>
#*** $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;