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 => sub {
                my ($self) = @_;
                'select * from ' . $self->table;
        },
);

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	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	default => sub {
15	my ($self) = @_;
16	'select * from ' . $self->table;
17	},
18	);
19
20	has table => (
21	is => 'rw',
22	isa => 'Str',
23	required => 1,
24	default => 'sponge',
25	);
26
27	has 'sponge' => (
28	is => 'rw',
29	isa => Dict[
30	rows => ArrayRef[ArrayRef],
31	NAME => ArrayRef[Str],
32	],
33	required => 1,
34	);
35
36	sub data {
37	my ($self) = @_;
38
39	my $dbh=DBI->connect('dbi:AnyData(RaiseError=>1):');
40
41
42
43	my $data = $self->sponge->{rows};
44	unshift @$data, $self->sponge->{NAME};
45
46	warn "# data = ",dump( $data );
47
48	$dbh->func( $self->table, 'ARRAY', $data, 'ad_import' );
49
50	return $dbh->selectall_arrayref( $self->query );
51	}
52
53	1;