File Coverage

blib/lib/Test/DBChanges/Role/DBIC.pm

Criterion	Covered	Total	%
statement	9	24	37.5
branch			n/a
condition			n/a
subroutine	3	10	30.0
pod			n/a
total	12	34	35.2

package Test::DBChanges::Role::DBIC;
use Moo::Role;
use Types::Standard qw(HasMethods);
use namespace::autoclean;

our $VERSION = '1.0.0'; # VERSION
# ABSTRACT: adapt DBChanges to DBIC


has schema => ( is => 'ro', required => 1, isa => HasMethods[qw(storage resultset)] );
sub _storage { shift->schema->storage }
sub _db_do {
    my ($self,$sql,@args) = @_;
    $self->_storage->dbh_do(
        sub {
            my (undef,$dbh) = @_;
            # silence "NOTICE: the relation already exists"
            local $dbh->{PrintWarn} = 0;
            $dbh->do($sql,{},@args);
        }
    );
}

sub _db_fetch {
    my ($self,$sql,@args) = @_;
    return $self->_storage->dbh_do(
        sub {
            my (undef,$dbh) = @_;
            return $dbh->selectall_arrayref($sql, { Slice => {} }, @args);
        }
    );
}

sub _table_and_factory_for_source {
    my ($self, $source_name) = @_;

    # source names are resultset names, and we inflate the result of
    # _db_fetch into row objects

    my $rs = $self->schema->resultset($source_name);
    my $table_name = $rs->result_source->name;

    return ($table_name, sub { $rs->new_result(shift) } );
}

1;

__END__