File Coverage

blib/lib/DBIx/DataModel/Statement/JDBC.pm

Criterion	Covered	Total	%
statement	18	44	40.9
branch	0	14	0.0
condition	0	2	0.0
subroutine	6	13	46.1
pod	0	4	0.0
total	24	77	31.1

#----------------------------------------------------------------------
package DBIx::DataModel::Statement::JDBC;
#----------------------------------------------------------------------
use strict;
use warnings;
no strict 'refs';

use parent qw/DBIx::DataModel::Statement/;
use mro    qw/c3/;
use DBI    qw/SQL_INTEGER/;

# methods on the JDBC ResultSet object, without argument
foreach my $method (qw/size           getRow
                       getMemberCount getSQLStatement
                       beforeFirst    afterLast
                       isBeforeFirst  isAfterLast/) {
  *{$method} = sub {
    my ($self) = @_;
    $self->execute() if !$self->{sth};
    $self->{sth}->jdbc_func("ResultSet.$method");
  };
}

# methods on the JDBC ResultSet object, with an INT argument
foreach my $method (qw/relative absolute/) {
  *{$method} = sub {
    my ($self, $int_arg) = @_;
    $self->execute() if !$self->{sth};
    $self->{sth}->jdbc_func([$int_arg => SQL_INTEGER], "ResultSet.$method");
  };
}


# methods on the JDBC Statement object, with an INT argument
foreach my $method (qw/setMaxRows setQueryTimeout/) {
  *{$method} = sub {
    my ($self, $int_arg) = @_;
    $self->prepare() if !$self->{sth};
    $self->{sth}->jdbc_func([$int_arg => SQL_INTEGER], "Statement.$method");
  };
}

sub sqlize {
  my ($self, @args) = @_;

  # merge new args into $self->{args}
  $self->refine(@args) if @args;

  # remove -limit and -offset from args; they will be handled later in
  # prepare() and execute(), see below
  $self->{jdbc_limit} = delete $self->{args}{-limit};
  $self->{offset}     = delete $self->{args}{-offset} || 0;

  $self->next::method();
}


sub prepare {
  my ($self, @args) = @_;
  $self->next::method(@args);
  my $limit = $self->{jdbc_limit};
  $self->setMaxRows($limit + $self->{offset}) if $limit;
  return $self;
}

sub execute {
  my ($self, @args) = @_;
  $self->next::method(@args);
  $self->absolute($self->{offset}) if $self->{offset};
  return $self;
}

sub row_count {
  my ($self) = @_;
  $self->{row_count} = $self->getMemberCount unless exists $self->{row_count};
  return $self->{row_count};
}

1;

__END__