lib/Frey/Collection.pm

package Frey::Collection;
use Moose::Role;

use Data::Dump qw/dump/;
use Carp;

=head1 NAME

Frey::Collection - role for Fey::ORM to get all results

=head1 METHODS

=cut

=head2 total_entries

  my $rows = $o->total_entries;

=cut

sub total_entries {
        my $self = shift;
        my $table = $self->_table;
        my $count = Fey::Literal::Function->new( 'COUNT', $table->column('id') );       # FIXME id?
        my $select = $self->_sql->select( $count )->from( $self->_table );
        my $dbh = $self->_dbh($select);
        my $sth = $dbh->prepare( $select->sql($dbh) );
        $sth->execute;
        return $sth->fetchrow_arrayref->[0];
}

sub _table {
        my $self = shift;
        return $self->SchemaClass()->Schema()->table( $self->collection_table );
}

sub _sql {
        my $self = shift;
        return $self->SchemaClass()->SQLFactoryClass()->new_select();
}

=head2 collection

  my $pager = Frey::Pager->new( per_page => 20, page => 1 );
  my $Fey_Object_Iterator = $o->collection($pager);

=cut

sub collection {
        my ( $self, $pager ) = @_;

        my $table = $self->_table;

        my $select = $self->_sql->select( $table )
                ->from( $table )
#               ->where( $message_t->column('message_date'), '>=',
#                       DateTime->today()->subtract( days => 7 )->strftime( '%Y-%m-%d' ) )
        ;

        if ( blessed $pager ) {
                if ( ref($pager) eq 'Frey::Pager' ) {
                        warn "FIXING wrong pager object to collection!";
                        $pager = $pager->pager;
                }
                warn "## using pager";
                $pager->total_entries( $self->total_entries );
                $select->limit( $pager->entries_per_page, $pager->skipped );
        }

        my $dbh = $self->_dbh($select);
        my $sth = $dbh->prepare( $select->sql($dbh) );

        my $i =
                Fey::Object::Iterator->new(
                        classes     => [ $self->meta()->ClassForTable( $table ) ],
                        handle      => $sth,
                        bind_params => [ $select->bind_params() ],
                );

        confess "LEGACY: this calling convention is no longer supported" if wantarray;
        return $i;
}

1;
1	dpavlin	106	package Frey::Collection;
2			use Moose::Role;
3
4			use Data::Dump qw/dump/;
5	dpavlin	109	use Carp;
6	dpavlin	106
7	dpavlin	143	=head1 NAME
8
9			Frey::Collection - role for Fey::ORM to get all results
10
11			=head1 METHODS
12
13			=cut
14
15			=head2 total_entries
16
17			my $rows = $o->total_entries;
18
19			=cut
20
21			sub total_entries {
22	dpavlin	111	my $self = shift;
23			my $table = $self->_table;
24			my $count = Fey::Literal::Function->new( 'COUNT', $table->column('id') ); # FIXME id?
25			my $select = $self->_sql->select( $count )->from( $self->_table );
26			my $dbh = $self->_dbh($select);
27			my $sth = $dbh->prepare( $select->sql($dbh) );
28			$sth->execute;
29			return $sth->fetchrow_arrayref->[0];
30			}
31
32			sub _table {
33			my $self = shift;
34			return $self->SchemaClass()->Schema()->table( $self->collection_table );
35			}
36
37			sub _sql {
38			my $self = shift;
39			return $self->SchemaClass()->SQLFactoryClass()->new_select();
40			}
41
42	dpavlin	143	=head2 collection
43	dpavlin	109
44	dpavlin	143	my $pager = Frey::Pager->new( per_page => 20, page => 1 );
45			my $Fey_Object_Iterator = $o->collection($pager);
46	dpavlin	109
47	dpavlin	143	=cut
48	dpavlin	109
49	dpavlin	143	sub collection {
50			my ( $self, $pager ) = @_;
51	dpavlin	106
52	dpavlin	143	my $table = $self->_table;
53	dpavlin	106
54	dpavlin	143	my $select = $self->_sql->select( $table )
55			->from( $table )
56	dpavlin	106	# ->where( $message_t->column('message_date'), '>=',
57			# DateTime->today()->subtract( days => 7 )->strftime( '%Y-%m-%d' ) )
58	dpavlin	143	;
59	dpavlin	106
60	dpavlin	143	if ( blessed $pager ) {
61			if ( ref($pager) eq 'Frey::Pager' ) {
62			warn "FIXING wrong pager object to collection!";
63			$pager = $pager->pager;
64			}
65			warn "## using pager";
66			$pager->total_entries( $self->total_entries );
67			$select->limit( $pager->entries_per_page, $pager->skipped );
68			}
69
70	dpavlin	111	my $dbh = $self->_dbh($select);
71	dpavlin	106	my $sth = $dbh->prepare( $select->sql($dbh) );
72
73	dpavlin	111	my $i =
74	dpavlin	106	Fey::Object::Iterator->new(
75	dpavlin	143	classes => [ $self->meta()->ClassForTable( $table ) ],
76	dpavlin	106	handle => $sth,
77			bind_params => [ $select->bind_params() ],
78			);
79	dpavlin	111
80	dpavlin	143	confess "LEGACY: this calling convention is no longer supported" if wantarray;
81	dpavlin	111	return $i;
82	dpavlin	106	}
83
84			1;