/usr/local/CPAN/DBIx-Romani/DBIx/Romani/Connection/Factory.pm

• package DBIx::Romani::Connection::Factory
  • new
  • create
  • DESTROY
• EOF

package DBIx::Romani::Connection::Factory;

use DBIx::Romani::Connection;
use DBI;
use strict;

sub new
{
	my $class = shift;
	my $args  = shift;

	my $dbh;
	my $dsn;
	my $username;
	my $password;
	my $driver;

	if ( ref($args) eq 'HASH' )
	{
		$dbh      = $args->{dbh};
		$dsn      = $args->{dsn};
		$username = $args->{username};
		$password = $args->{password};
		$driver   = $args->{driver};
	}

	if ( not defined $dbh and not defined $dsn )
	{
		# Programmer error
		die "Must defined either a dsn or dbh";
	}
	if ( defined $dsn and defined $dbh )
	{
		# Programmer error
		die "Cannot defined both a dsn and dbh";
	}
	if ( not defined $driver )
	{
		# Programmer error
		die "Must define the connection driver";
	}

	my $self = {
		dbh      => $dbh,
		dsn      => $dsn,
		username => $username,
		password => $password,
		driver   => $driver
	};

	bless  $self, $class;
	return $self;
}

sub create
{
	my $self = shift;

	my $conn;

	if ( $self->{dbh} )
	{
		$conn = DBIx::Romani::Connection->new({ dbh => $self->{dbh}, driver => $self->{driver}, disconnect => 0 });
	}
	else
	{
		my $dbh = DBI->connect( $self->{dsn}, $self->{username}, $self->{password} );
		$conn = DBIx::Romani::Connection->new({ dbh => $dbh, driver => $self->{driver}, disconnect => 1 });
	}

	return $conn;
}

sub DESTROY
{
	my $self = shift;

	if ( $self->{dbh} )
	{
		$self->{dbh}->disconnect();
		$self->{dbh} = undef;
	}
}

1;