File Coverage

blib/lib/DBIx/Handler/Sunny.pm

Criterion	Covered	Total	%
statement	9	33	27.2
branch	0	14	0.0
condition			n/a
subroutine	3	10	30.0
pod	5	5	100.0
total	17	62	27.4

package DBIx::Handler::Sunny;
use strict;
use warnings;

our $VERSION = '0.02';

# cpan
use parent qw(DBIx::Handler);

sub _do_selectrow { # see DBI::_do_selectrow
    my ($self, $method, @args) = @_;
    my $sth = $self->query(@args)
        or return undef;
    my $row = $sth->$method()
        and $sth->finish;
    return $row;
}

sub select_one {
    my ($self, @args) = @_;
    my $row = $self->_do_selectrow('fetchrow_arrayref', @args);
    return undef unless $row;
    return $row->[0];
}

sub select_row {
    my ($self, @args) = @_;
    my $row = $self->_do_selectrow('fetchrow_hashref', @args);
    return unless $row;
    return $row;
}

sub select_all {
    my ($self, @args) = @_;
    my $sth = $self->query(@args)
        or return [];
    return $sth->fetchall_arrayref({});
}

sub last_insert_id {
    my $self = shift;
    my $dsn = $self->{_connect_info}->[0];
    if ($dsn =~ /^(?i:dbi):SQLite\b/) {
        return $self->dbh->func('last_insert_rowid');
    }
    elsif ( $dsn =~ /^(?i:dbi):mysql\b/) {
        return $self->dbh->{mysql_insertid};
    }
    $self->dbh->last_insert_id(@_);
}

sub txn {
    my ($self, $coderef) = @_;
    $self->SUPER::txn(sub { $coderef->($self) });
}

1;
__END__