lib/Frey/DBI.pm

package Frey::DBI;
use Moose;

extends 'Frey';

use DBI;
use Moose::Util::TypeConstraints;

subtype 'dsn'
=> as 'Str'
=> where {
        DBI->parse_dsn( $_ );
};

has 'dsn' => (
        is => 'ro',
        isa => 'dsn',
        default => 'DBI:Pg:dbname=template1',
        required => 1,
);

has 'query' => (
        is => 'ro',
        isa => 'Str',
        required => 1,
        default => 'select 42 as meaning_of_life',
);

sub as_sponge {
        my ( $self ) = @_;

        warn "# dsn: ", $self->dsn;
        my $dbh = DBI->connect( $self->dsn, '', '', { RaiseError => 1 } ) || die $DBI::errstr;
        $dbh->do( qq{ set client_encoding='utf-8' } );

        warn "# query: ", $self->query;
        my $sth = $dbh->prepare( $self->query );
        $sth->execute();

        return {
                NAME => $sth->{NAME},
                rows => $sth->fetchall_arrayref,
        };
}

1;
1	dpavlin	366	package Frey::DBI;
2			use Moose;
3
4			extends 'Frey';
5
6			use DBI;
7			use Moose::Util::TypeConstraints;
8
9			subtype 'dsn'
10			=> as 'Str'
11			=> where {
12			DBI->parse_dsn( $_ );
13			};
14
15			has 'dsn' => (
16			is => 'ro',
17			isa => 'dsn',
18			default => 'DBI:Pg:dbname=template1',
19			required => 1,
20			);
21
22			has 'query' => (
23			is => 'ro',
24			isa => 'Str',
25			required => 1,
26			default => 'select 42 as meaning_of_life',
27			);
28
29	dpavlin	455	sub as_sponge {
30	dpavlin	366	my ( $self ) = @_;
31
32	dpavlin	885	warn "# dsn: ", $self->dsn;
33	dpavlin	366	my $dbh = DBI->connect( $self->dsn, '', '', { RaiseError => 1 } ) \|\| die $DBI::errstr;
34			$dbh->do( qq{ set client_encoding='utf-8' } );
35
36	dpavlin	885	warn "# query: ", $self->query;
37	dpavlin	366	my $sth = $dbh->prepare( $self->query );
38			$sth->execute();
39
40			return {
41			NAME => $sth->{NAME},
42			rows => $sth->fetchall_arrayref,
43			};
44			}
45
46			1;