File Coverage

blib/lib/Helios/ObjectDriver/DBI.pm

Criterion	Covered	Total	%
statement	11	26	42.3
branch	0	12	0.0
condition			n/a
subroutine	4	6	66.6
pod	0	1	0.0
total	15	45	33.3

package Helios::ObjectDriver::DBI;

use 5.008;
use strict;
use warnings;
use base qw(Data::ObjectDriver::Driver::DBI);

our $VERSION = '2.61';

# [LH] 2012-07-11: Changed the DBI connection creation to use connect_cached()
# instead of connect() to implement connection caching.  Also added
# 'private_heliconn_$pid' option to ensure connections opened by separate
# processes stay separated.


my %Handles;
sub init_db {
    my $driver = shift;
    my $dbh;
    if ($driver->reuse_dbh) {
        $dbh = $Handles{$driver->dsn};
    }
    unless ($dbh) {
        eval {
        	# [LH] 2012-07-11: Changed the DBI connection creation to use
        	# connect_cached() instead of connect() to implement connection
        	# caching.  Also added 'private_heliconn_$pid' option to ensure
        	# connections opened by separate processes stay separated.
            $dbh = DBI->connect_cached($driver->dsn, $driver->username, $driver->password,
                { RaiseError => 1, PrintError => 0, AutoCommit => 1, 'private_heliconn_'.$$ => $$,
                %{$driver->connect_options || {}} })
                or Carp::croak("Connection error: " . $DBI::errstr);
        };
        if ($@) {
            Carp::croak($@);
        }
    }
    if ($driver->reuse_dbh) {
        $Handles{$driver->dsn} = $dbh;
    }
    $driver->dbd->init_dbh($dbh);
    $driver->{__dbh_init_by_driver} = 1;
    return $dbh;
}


sub DESTROY {
   	# [LH] 2012-07-11: Removed DBI->disconnect() call.
	# Unlike in the base Data::ObjectDriver::Driver::DBI
	# we don't want to disconnect the database connection
	# EVEN IF we created it.
	# We'll let DBI handle disconnection exclusively
}

1;
__END__