WebPAC/Input/Koha.pm

package WebPAC::Input::Koha;

use warnings;
use strict;

use DBI;
use MARC::Fast;
use base qw/WebPAC::Common/;
use Carp qw/confess/;
use Data::Dump qw/dump/;

=head1 NAME

WebPAC::Input::Koha - read MARC records from Koha

=cut

our $VERSION = '0.01';

=head1 FUNCTIONS

=head2 new

  my $input = new WebPAC::Input::Koha(
        dsn => '',
        filter => \&code_ref,
  }

=cut

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

        my $arg = {@_};

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

        $log->info("opening Koha database '$arg->{dsn}'");

        $self->{_dbh} = DBI->connect( $arg->{dsn}, $arg->{user}, $arg->{passwd}, { RaiseError => 1 } );
        $self->{_sth} = $self->{_dbh}->prepare( $arg->{sql} );
        $self->{_sth}->execute;

        warn "got ", $self->{_sth}->rows, " rows for ", $arg->{sql};

        open( $self->{_koha_fh}, '>', $arg->{path} ) || warn "not creating $arg->{path}: $!";

        $self ? return $self : return undef;
}

=head2 fetch_rec

Return record with ID C<$mfn> from database

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

=cut

sub fetch_rec {
        my $self = shift;

        my $mfn = shift;

        my $row = $self->{_sth}->fetchrow_hashref;

        if ( my $fh = $self->{_koha_fh} ) {
                if ( my $marc = $row->{marc} ) {
                        print $fh $marc;
                } else {
                        warn "MFN $mfn no marc in ",dump($row);
                }
        }

        push @{$row->{'000'}}, $mfn;
        return $row;
}

=head2 size

Return number of records in database

  my $size = $isis->size;

=cut

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


=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;
1	package WebPAC::Input::Koha;
2
3	use warnings;
4	use strict;
5
6	use DBI;
7	use MARC::Fast;
8	use base qw/WebPAC::Common/;
9	use Carp qw/confess/;
10	use Data::Dump qw/dump/;
11
12	=head1 NAME
13
14	WebPAC::Input::Koha - read MARC records from Koha
15
16	=cut
17
18	our $VERSION = '0.01';
19
20	=head1 FUNCTIONS
21
22	=head2 new
23
24	my $input = new WebPAC::Input::Koha(
25	dsn => '',
26	filter => \&code_ref,
27	}
28
29	=cut
30
31	sub new {
32	my $class = shift;
33	my $self = {@_};
34	bless($self, $class);
35
36	my $arg = {@_};
37
38	my $log = $self->_get_logger();
39
40	$log->info("opening Koha database '$arg->{dsn}'");
41
42	$self->{_dbh} = DBI->connect( $arg->{dsn}, $arg->{user}, $arg->{passwd}, { RaiseError => 1 } );
43	$self->{_sth} = $self->{_dbh}->prepare( $arg->{sql} );
44	$self->{_sth}->execute;
45
46	warn "got ", $self->{_sth}->rows, " rows for ", $arg->{sql};
47
48	open( $self->{_koha_fh}, '>', $arg->{path} ) \|\| warn "not creating $arg->{path}: $!";
49
50	$self ? return $self : return undef;
51	}
52
53	=head2 fetch_rec
54
55	Return record with ID C<$mfn> from database
56
57	my $rec = $input->fetch_rec( $mfn );
58
59	=cut
60
61	sub fetch_rec {
62	my $self = shift;
63
64	my $mfn = shift;
65
66	my $row = $self->{_sth}->fetchrow_hashref;
67
68	if ( my $fh = $self->{_koha_fh} ) {
69	if ( my $marc = $row->{marc} ) {
70	print $fh $marc;
71	} else {
72	warn "MFN $mfn no marc in ",dump($row);
73	}
74	}
75
76	push @{$row->{'000'}}, $mfn;
77	return $row;
78	}
79
80	=head2 size
81
82	Return number of records in database
83
84	my $size = $isis->size;
85
86	=cut
87
88	sub size {
89	my $self = shift;
90	return $self->{_sth}->rows;
91	}
92
93
94	=head1 AUTHOR
95
96	Dobrica Pavlinusic, C<< <dpavlin@rot13.org> >>
97
98	=head1 COPYRIGHT & LICENSE
99
100	Copyright 2009 Dobrica Pavlinusic, All Rights Reserved.
101
102	This program is free software; you can redistribute it and/or modify it
103	under the same terms as Perl itself.
104
105	=cut
106
107	1;