File Coverage

blib/lib/DBIx/Custom/Query.pm

Criterion	Covered	Total	%
statement	51	51	100.0
branch	17	18	94.4
condition	10	12	83.3
subroutine	4	4	100.0
pod	0	1	0.0
total	82	86	95.3

package DBIx::Custom::Query;
use Object::Simple -base;

use DBIx::Custom::Util qw/_array_to_hash _subname _deprecate/;

use Carp 'croak';

has 'sql';
has 'bind_type';
has 'columns';
has 'param';
has 'bind_values';
has 'bind_value_types';

sub build {
  my $self = shift;

  my $param = $self->{param};
  my $columns = $self->{columns};

  # Create bind values
  my @bind_values;
  my %count;
  my %not_exists;
  for my $column (@$columns) {
    my $value = $param->{$column};

    # Bind value
    if(ref $value eq 'ARRAY') {
      my $i = $count{$column} || 0;
      $i += $not_exists{$column} || 0;
      my $found;
      for (my $k = $i; $i < @$value; $k++) {
        if (ref $value->[$k] eq 'DBIx::Custom::NotExists') {
            $not_exists{$column}++;
        }
        else  {
          push @bind_values, $value->[$k];
          $found = 1;
          last
        }
      }
      next unless $found;
    }
    else { push @bind_values, $value }

    # Count up
    $count{$column}++;
  }

  # Bind type
  if ($self->{bind_type}) {
    my @bind_value_types;
    my $bind_type = $self->bind_type || {};
    for (my $i = 0; $i < @$columns; $i++) {
      my $column = $columns->[$i];
      push @bind_value_types, $bind_type->{$column};
    }
    $self->bind_value_types(\@bind_value_types);
  }
  else {
    $self->{bind_value_types} = undef;
  }

  # Has filter
  if ($self->{_f}) {
    my $filter = $self->{_filter};
    my $type_filters = $self->{_type_filters};

    for (my $i = 0; $i < @$columns; $i++) {
      my $column = $columns->[$i];

      # Filter
      if ($filter) {
        if (defined $filter->{$column}) {
          my $f = $filter->{$column};
          $bind_values[$i] = $f->($bind_values[$i]);
        }
      }

      # Type rule
      my $tf1 = $self->{"_into1"}->{dot}->{$column}
        || $type_filters->{1}->{$column};
      $bind_values[$i] = $tf1->($bind_values[$i]) if $tf1;
      my $tf2 = $self->{"_into2"}->{dot}->{$column}
        || $type_filters->{2}->{$column};
      $bind_values[$i] = $tf2->($bind_values[$i]) if $tf2;
    }
  }

  $self->{bind_values} = \@bind_values;
}

1;