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.02';

=head1 FUNCTIONS

=head2 new

  my $input = new WebPAC::Input::Koha(
        dsn    => 'dbi:mysql:database=koha',
        user   => $ENV{KOHA_USER},
        passwd => $ENV{KOHA_PASSWD},
  }

=cut

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

        my $arg = {@_};

        my $log = $self->_get_logger();
        $log->debug( 'arg = ', dump($arg) );

        if ( -e $arg->{path} ) {
                $log->info("Koha marc dump ", $arg->{path}, " exists");
                $self->{_koha_size} = 0;
        } else {

                $arg->{dsn}    ||= 'dbi:mysql:database=koha';
                $arg->{user}   ||= $ENV{KOHA_USER};
                $arg->{passwd} ||= $ENV{KOHA_PASSWD},
                $arg->{sql}    ||= 'select biblionumber as mfn, marc from biblioitems';
                $arg->{sql}    .= ' limit ' . $arg->{limit} if $arg->{limit};
                $arg->{sql}    .= ' offset ' . $arg->{offset} if $arg->{offset};

                $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;
                $self->{_koha_size} = $self->{_sth}->rows;

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

                open( $self->{_koha_fh}, '>', $arg->{path} ) || die "can't create $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->{_koha_size} + $self->{offset};
}


=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.02';
19
20	=head1 FUNCTIONS
21
22	=head2 new
23
24	my $input = new WebPAC::Input::Koha(
25	dsn => 'dbi:mysql:database=koha',
26	user => $ENV{KOHA_USER},
27	passwd => $ENV{KOHA_PASSWD},
28	}
29
30	=cut
31
32	sub new {
33	my $class = shift;
34	my $self = {@_};
35	bless($self, $class);
36
37	my $arg = {@_};
38
39	my $log = $self->_get_logger();
40	$log->debug( 'arg = ', dump($arg) );
41
42	if ( -e $arg->{path} ) {
43	$log->info("Koha marc dump ", $arg->{path}, " exists");
44	$self->{_koha_size} = 0;
45	} else {
46
47	$arg->{dsn} \|\|= 'dbi:mysql:database=koha';
48	$arg->{user} \|\|= $ENV{KOHA_USER};
49	$arg->{passwd} \|\|= $ENV{KOHA_PASSWD},
50	$arg->{sql} \|\|= 'select biblionumber as mfn, marc from biblioitems';
51	$arg->{sql} .= ' limit ' . $arg->{limit} if $arg->{limit};
52	$arg->{sql} .= ' offset ' . $arg->{offset} if $arg->{offset};
53
54	$log->info("opening Koha database '$arg->{dsn}'");
55
56	$self->{_dbh} = DBI->connect( $arg->{dsn}, $arg->{user}, $arg->{passwd}, { RaiseError => 1 } );
57	$self->{_sth} = $self->{_dbh}->prepare( $arg->{sql} );
58	$self->{_sth}->execute;
59	$self->{_koha_size} = $self->{_sth}->rows;
60
61	warn "got ", $self->{_koha_size}, " rows for ", $arg->{sql};
62
63	open( $self->{_koha_fh}, '>', $arg->{path} ) \|\| die "can't create $arg->{path}: $!";
64
65	}
66
67	$self ? return $self : return undef;
68	}
69
70	=head2 fetch_rec
71
72	Return record with ID C<$mfn> from database
73
74	my $rec = $input->fetch_rec( $mfn );
75
76	=cut
77
78	sub fetch_rec {
79	my $self = shift;
80
81	my $mfn = shift;
82
83	my $row = $self->{_sth}->fetchrow_hashref;
84
85	if ( my $fh = $self->{_koha_fh} ) {
86	if ( my $marc = $row->{marc} ) {
87	print $fh $marc;
88	} else {
89	warn "MFN $mfn no marc in ",dump($row);
90	}
91	}
92
93	push @{$row->{'000'}}, $mfn;
94	return $row;
95	}
96
97	=head2 size
98
99	Return number of records in database
100
101	my $size = $isis->size;
102
103	=cut
104
105	sub size {
106	my $self = shift;
107	return $self->{_koha_size} + $self->{offset};
108	}
109
110
111	=head1 AUTHOR
112
113	Dobrica Pavlinusic, C<< <dpavlin@rot13.org> >>
114
115	=head1 COPYRIGHT & LICENSE
116
117	Copyright 2009 Dobrica Pavlinusic, All Rights Reserved.
118
119	This program is free software; you can redistribute it and/or modify it
120	under the same terms as Perl itself.
121
122	=cut
123
124	1;