File Coverage

lib/DBIx/EAV/Table.pm

Criterion	Covered	Total	%
statement	9	67	13.4
branch	0	22	0.0
condition	0	9	0.0
subroutine	3	12	25.0
pod	6	7	85.7
total	18	117	15.3

package DBIx::EAV::Table;

use Moo;
use SQL::Abstract;
use constant {
    SQL_DEBUG => $ENV{DBIX_EAV_TRACE}
};

my $sql = SQL::Abstract->new;

has '_dbh', is => 'ro', required => 1, init_arg => 'dbh';
has 'name', is => 'ro', required => 1;
has 'columns', is => 'ro', required => 1;
has 'tenant_id', is => 'ro';


sub BUILD {
    my $self = shift;

    die sprintf "Error instantiating table '%s': tenant_id is required!"
        if $self->has_column('tenant_id') && !defined $self->tenant_id;
}



sub has_column {
    my ($self, $name) = @_;
    foreach (@{$self->columns}) {
        return 1 if $_ eq $name;
    }
    0;
}

sub select {
    my ($self, $where) = @_;
    $where //= {};
    $where = $self->_mangle_where($where);

    my ($stmt, @bind) = $sql->select($self->name.' AS me', $self->columns, $where);
    my ($rv, $sth) = $self->_do($stmt, \@bind);
    $sth;
}

sub select_one {
    my ($self, $where) = @_;
    $self->select($where)->fetchrow_hashref;
}

sub insert {
    my ($self, $data) = @_;

    $data->{tenant_id} = $self->tenant_id
        if $self->has_column('tenant_id');

    my ($stmt, @bind) = $sql->insert($self->name, $data);
    my ($rv, $sth) = $self->_do($stmt, \@bind);

    if ($rv == 1) {
        return $self->_dbh->last_insert_id(undef, undef, undef, undef) || 1;
    }
    else {
        $rv;
    }

}

sub update {
    my ($self, $data, $where) = @_;
    $where = $self->_mangle_where($where);

    my ($stmt, @bind) = $sql->update($self->name, $data, $where);
    my ($rv, $sth) = $self->_do($stmt, \@bind);
    $rv;
}

sub delete {
    my ($self, $where, $opts) = @_;
    $opts //= {};

    my $stmt = $opts->{join} ? sprintf("DELETE me FROM %s AS me", $self->name)
                             : sprintf("DELETE FROM %s", $self->name);

    # JOIN
    while (my ($table, $spec) = each %{ $opts->{join} || {} }) {

        my ($join_criteria, @bind) = $sql->where($spec);
        while ( (my $offset = index($join_criteria, '?')) > -1) {
            my $val = shift @bind;
            substr($join_criteria, $offset, 1, $val);
        }
        $join_criteria =~ s/^\s*WHERE//;
        $join_criteria =~ s/\btheir\./$table./g;
        $stmt .= " INNER JOIN $table ON $join_criteria";
    }

    # WHERE
    my ($where_part, @bind);
    if ($where) {
        $where = $self->_mangle_where($where);
        ($where_part, @bind) = $sql->where($where);
        $stmt .= " $where_part";
    }

    my ($rv, $sth) = $self->_do($stmt, \@bind);
    $rv;
}

sub _mangle_where {
    my ($self, $where) = @_;

    return $where unless $self->has_column('tenant_id');

    if (ref $where eq 'HASH') {
        $where->{tenant_id} = $self->tenant_id;
    }
    else {
        $where = { -and => [ tenant_id => $self->tenant_id, $where ] };
    }

    $where;
}



sub _do {
    my ($self, $stmt, $bind) = @_;

    if (SQL_DEBUG) {
        my $i = 0;
        printf STDERR "$stmt: %s\n",
            join('  ', map { $i++.'='.$_ } @$bind);
    }

    my $sth = $self->_dbh->prepare($stmt);
    my $rv = $sth->execute(ref $bind eq 'ARRAY' ? @$bind : ());
    die $sth->errstr unless defined $rv;

    return ($rv, $sth);
}





1;

__END__