lib/Frey/SQL.pm

package Frey::SQL;
use Moose;

use MooseX::Types::Moose qw(Str Int ArrayRef);
use MooseX::Types::Structured qw/Dict/;

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

has 'query' => (
        is => 'rw',
        isa => 'Str',
        required => 1,
        default => 'select * from sponge',
);

has table => (
        is => 'rw',
        isa => 'Str',
        required => 1,
        default => 'sponge',
);

has 'sponge' => (
        is => 'rw',
        isa => Dict[
                rows => ArrayRef[ArrayRef],
                NAME => ArrayRef[Str],
        ],
        required => 1,
);

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

        my $dbh=DBI->connect('dbi:AnyData(RaiseError=>1):');


        my $data = $self->sponge->{rows};
        unshift @$data, $self->sponge->{NAME};

        warn "# data = ",dump( $data );

        $dbh->func( $self->table, 'ARRAY', $data, 'ad_import' );

        return $dbh->selectall_arrayref( $self->query );
}

1;
1	dpavlin	370	package Frey::SQL;
2			use Moose;
3
4			use MooseX::Types::Moose qw(Str Int ArrayRef);
5			use MooseX::Types::Structured qw/Dict/;
6
7			use DBI;
8			use Data::Dump qw/dump/;
9
10			has 'query' => (
11			is => 'rw',
12			isa => 'Str',
13			required => 1,
14	dpavlin	371	default => 'select * from sponge',
15	dpavlin	370	);
16
17			has table => (
18			is => 'rw',
19			isa => 'Str',
20			required => 1,
21			default => 'sponge',
22			);
23
24			has 'sponge' => (
25			is => 'rw',
26			isa => Dict[
27			rows => ArrayRef[ArrayRef],
28			NAME => ArrayRef[Str],
29			],
30			required => 1,
31			);
32
33			sub data {
34			my ($self) = @_;
35
36			my $dbh=DBI->connect('dbi:AnyData(RaiseError=>1):');
37
38
39
40			my $data = $self->sponge->{rows};
41			unshift @$data, $self->sponge->{NAME};
42
43			warn "# data = ",dump( $data );
44
45			$dbh->func( $self->table, 'ARRAY', $data, 'ad_import' );
46
47			return $dbh->selectall_arrayref( $self->query );
48			}
49
50			1;