WebPAC/Input/CSV.pm

package WebPAC::Input::CSV;

use warnings;
use strict;

use WebPAC::Input;
use base qw/WebPAC::Common/;

use Text::CSV;
use Data::Dump qw/dump/;

=head1 NAME

WebPAC::Input::CSV - support for CSV Export Format

=cut

our $VERSION = '0.01';

=head1 FUNCTIONS

=head2 new

Returns new low-level input API object

  my $input = new WebPAC::Input::CSV(
        path => '/path/to/records.csv',
  );

Options:

=over 4

=item path

path to CSV file

=back

Default encoding of input file is C<utf-8>

=cut

sub new {
        my $class = shift;
        my $self = {@_};
        bless($self, $class);

        my $arg = {@_};

        my $log = $self->_get_logger();

        open( my $fh, '<:encoding(utf-8)', $arg->{path} ) || $log->logconfess("can't open $arg->{path}: $!");

        my $csv = Text::CSV->new({ binary => 1 });

        $self->{size} = 0;

        while ( 1 ) {
                my $line = $csv->getline( $fh );
                last if $csv->eof;

                $log->logdie( "can't parse CSV file ", $csv->error_diag ) unless $line;

                my $rec;
                $rec->{'000'} = [ ++$self->{size} ];

                my $col = 'A';
                $rec->{ $col++ } = $_ foreach @$line;

                push @{ $self->{_rec} }, $rec;

        };

        $log->debug("loaded ", $self->size, " records");

        $self ? return $self : return undef;
}

=head2 fetch_rec

Return record with ID C<$mfn> from database

  my $rec = $input->fetch_rec( $mfn, $filter_coderef );

=cut

sub fetch_rec {
        my $self = shift;

        my ( $mfn, $filter_coderef ) = @_;

        return $self->{_rec}->[$mfn-1];
}


=head2 size

Return number of records in database

  my $size = $input->size;

=cut

sub size {
        my $self = shift;
        return $self->{size};
}

=head1 AUTHOR

Dobrica Pavlinusic, C<< <dpavlin@rot13.org> >>

=head1 COPYRIGHT & LICENSE

Copyright 2009 Dobrica Pavlinusic, All Rights Reserved.

This program is free software; you can redistribute it and/or modify it
under the same terms as Perl itself.

=cut

1; # End of WebPAC::Input::CSV
1	dpavlin	1186	package WebPAC::Input::CSV;
2
3			use warnings;
4			use strict;
5
6			use WebPAC::Input;
7			use base qw/WebPAC::Common/;
8
9			use Text::CSV;
10			use Data::Dump qw/dump/;
11
12			=head1 NAME
13
14			WebPAC::Input::CSV - support for CSV Export Format
15
16			=cut
17
18			our $VERSION = '0.01';
19
20			=head1 FUNCTIONS
21
22			=head2 new
23
24			Returns new low-level input API object
25
26			my $input = new WebPAC::Input::CSV(
27			path => '/path/to/records.csv',
28			);
29
30			Options:
31
32			=over 4
33
34			=item path
35
36			path to CSV file
37
38			=back
39
40			Default encoding of input file is C<utf-8>
41
42			=cut
43
44			sub new {
45			my $class = shift;
46			my $self = {@_};
47			bless($self, $class);
48
49			my $arg = {@_};
50
51			my $log = $self->_get_logger();
52
53			open( my $fh, '<:encoding(utf-8)', $arg->{path} ) \|\| $log->logconfess("can't open $arg->{path}: $!");
54
55			my $csv = Text::CSV->new({ binary => 1 });
56
57			$self->{size} = 0;
58
59			while ( 1 ) {
60			my $line = $csv->getline( $fh );
61			last if $csv->eof;
62
63			$log->logdie( "can't parse CSV file ", $csv->error_diag ) unless $line;
64
65			my $rec;
66			$rec->{'000'} = [ ++$self->{size} ];
67
68			my $col = 'A';
69			$rec->{ $col++ } = $_ foreach @$line;
70
71			push @{ $self->{_rec} }, $rec;
72
73			};
74
75			$log->debug("loaded ", $self->size, " records");
76
77			$self ? return $self : return undef;
78			}
79
80			=head2 fetch_rec
81
82			Return record with ID C<$mfn> from database
83
84			my $rec = $input->fetch_rec( $mfn, $filter_coderef );
85
86			=cut
87
88			sub fetch_rec {
89			my $self = shift;
90
91			my ( $mfn, $filter_coderef ) = @_;
92
93			return $self->{_rec}->[$mfn-1];
94			}
95
96
97			=head2 size
98
99			Return number of records in database
100
101			my $size = $input->size;
102
103			=cut
104
105			sub size {
106			my $self = shift;
107			return $self->{size};
108			}
109
110			=head1 AUTHOR
111
112			Dobrica Pavlinusic, C<< <dpavlin@rot13.org> >>
113
114			=head1 COPYRIGHT & LICENSE
115
116			Copyright 2009 Dobrica Pavlinusic, All Rights Reserved.
117
118			This program is free software; you can redistribute it and/or modify it
119			under the same terms as Perl itself.
120
121			=cut
122
123			1; # End of WebPAC::Input::CSV