File Coverage

blib/lib/Geoffrey/Action/Constraint/Default.pm

Criterion	Covered	Total	%
statement	31	41	75.6
branch	4	8	50.0
condition	0	3	0.0
subroutine	10	10	100.0
pod	3	3	100.0
total	48	65	73.8

package Geoffrey::Action::Constraint::Default;

use utf8;
use 5.016;
use strict;
use warnings;
use Geoffrey::Utils;
use Geoffrey::Exception::NotSupportedException;

use parent 'Geoffrey::Role::Action';

$Geoffrey::Action::Constraint::Default::VERSION = '0.000203';

sub add {
   my ($self, $params) = @_;
   Geoffrey::Exception::RequiredValue::throw_table_name() if !$params->{table};
   my $sequence = $self->converter->sequence;
   if (!$sequence->can('nextval')) {
      Geoffrey::Exception::NotSupportedException::throw_sequence('nextval', $self->converter);
   }

   my $s_table = $params->{table} =~ s/"//gr;
   $params->{name} =~ s/"//g;
   $params->{name} //= qq~seq_$s_table~ . q/_/ . time;
   my $sql = Geoffrey::Utils::replace_spare($sequence->add,
      [$params->{name}, 1, 1, $Geoffrey::Utils::INT_64BIT_SIGNED, 1, 1]);
   $self->do($sql);
   return Geoffrey::Utils::replace_spare($sequence->nextval, [$params->{name}]);
}

sub drop {
   my ($self, $name) = @_;
   my $sequence = $self->converter->sequence;
   if (!$sequence->can('drop')) {
      Geoffrey::Exception::NotSupportedException::throw_sequence('drop', $self->converter);
   }
   return $self->do(Geoffrey::Utils::replace_spare($sequence->drop, [$name]));
}

sub list_from_schema {
   my ($self, $schema) = @_;
   my $sequence = $self->converter->sequence;
   if (!$sequence->can('list')) {
      Geoffrey::Exception::NotSupportedException::throw_sequence('list', $self->converter);
   }
   return $self->converter->sequence_information($self->do_arrayref($sequence->list($schema), []));
}

1;

__END__