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	package Frey::Collection;
2	use Moose::Role;
3
4	use Data::Dump qw/dump/;
5	use Carp;
6
7	=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	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	=head2 collection
43
44	my $pager = Frey::Pager->new( per_page => 20, page => 1 );
45	my $Fey_Object_Iterator = $o->collection($pager);
46
47	=cut
48
49	sub collection {
50	my ( $self, $pager ) = @_;
51
52	my $table = $self->_table;
53
54	my $select = $self->_sql->select( $table )
55	->from( $table )
56	# ->where( $message_t->column('message_date'), '>=',
57	# DateTime->today()->subtract( days => 7 )->strftime( '%Y-%m-%d' ) )
58	;
59
60	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	my $dbh = $self->_dbh($select);
71	my $sth = $dbh->prepare( $select->sql($dbh) );
72
73	my $i =
74	Fey::Object::Iterator->new(
75	classes => [ $self->meta()->ClassForTable( $table ) ],
76	handle => $sth,
77	bind_params => [ $select->bind_params() ],
78	);
79
80	confess "LEGACY: this calling convention is no longer supported" if wantarray;
81	return $i;
82	}
83
84	1;