/[webpac2]/trunk/lib/WebPAC/Input/ISIS.pm

This is repository of my old source code which isn't updated any more. Go to git.rot13.org for current projects!

Diff of /trunk/lib/WebPAC/Input/ISIS.pm

Parent Directory | Revision Log | View Patch Patch

-revision 8 by dpavlin,
Sat Jul 16 16:48:35 2005 UTC
+revision 21 by dpavlin,
Sun Jul 17 22:28:11 2005 UTC
 Line 5 
 use strict;
  use WebPAC::Common;
  use base qw/WebPAC::Input WebPAC::Common/;
+ use Text::Iconv;
  =head1 NAME
-Line 61 
 from database (so you can skip beginning
+Line 62 
 from database (so you can skip beginning
  If optional parametar C<limit_mfn> is set, it will read just 500 records
  from database in example above.
- Returns number of last record read into memory (size of database, really).
+ Returns size of database, regardless of C<start_mfn> and C<limit_mfn>
+ parametars, see also C<$isis->size>.
  =cut
-Line 77 
 sub open {
+Line 79 
 sub open {
          $log->logdie("can't find database ",$arg->{'filename'}) unless (glob($arg->{'filename'}.'.*'));
          # store data in object
-         $self->{'isis_filename'} = $arg->{'filename'};
          $self->{'isis_code_page'} = $code_page;
+         foreach my $v (qw/isis_filename start_mfn limit_mfn/) {
-         #$self->{'isis_code_page'} = $code_page;
+                 $self->{$v} = $arg->{$v} if ($arg->{$v});
+         }
          # create Text::Iconv object
          my $cp = Text::Iconv->new($code_page,$self->{'code_page'});
-Line 88 
 sub open {
+Line 90 
 sub open {
          $log->info("reading ISIS database '",$arg->{'filename'},"'");
          $log->debug("isis code page: $code_page");
-         my ($isis_db,$maxmfn);
+         my ($isis_db,$db_size);
          if ($have_openisis) {
                  $log->debug("using OpenIsis perl bindings");
                  $isis_db = OpenIsis::open($arg->{'filename'});
-                 $maxmfn = OpenIsis::maxRowid( $isis_db ) || 1;
+                 $db_size = OpenIsis::maxRowid( $isis_db ) || 1;
          } elsif ($have_biblio_isis) {
                  $log->debug("using Biblio::Isis");
                  use Biblio::Isis;
-Line 106 
 sub open {
+Line 108 
 sub open {
                                  return $l;
                          },
                  );
-                 $maxmfn = $isis_db->count;
+                 $db_size = $isis_db->count;
-                 unless ($maxmfn) {
+                 unless ($db_size) {
                          $log->logwarn("no records in database ", $arg->{'filename'}, ", skipping...");
                          return;
                  }
-Line 119 
 sub open {
+Line 121 
 sub open {
          my $startmfn = 1;
+         my $maxmfn = $db_size;
          if (my $s = $self->{'start_mfn'}) {
                  $log->info("skipping to MFN $s");
-Line 127 
 sub open {
+Line 130 
 sub open {
                  $self->{'start_mfn'} = $startmfn;
          }
-         $maxmfn = $startmfn + $self->{limit_mfn} if ($self->{limit_mfn});
+         if ($self->{limit_mfn}) {
+                 $log->info("limiting to ",$self->{limit_mfn}," records");
+                 $maxmfn = $startmfn + $self->{limit_mfn} - 1;
+                 $maxmfn = $db_size if ($maxmfn > $db_size);
+         }
+         # store size for later
+         $self->{'size'} = ($maxmfn - $startmfn) ? ($maxmfn - $startmfn + 1) : 0;
          $log->info("processing ",($maxmfn-$startmfn)." records using ",( $have_openisis ? 'OpenIsis' : 'Biblio::Isis'));
-Line 193 
 sub open {
+Line 203 
 sub open {
          $log->debug("max mfn: $maxmfn");
          # store max mfn and return it.
-         return $self->{'max_mfn'} = $maxmfn;
+         $self->{'max_mfn'} = $maxmfn;
+         return $db_size;
  }
- =head2 fetch_rec
+ =head2 fetch
  Fetch next record from database. It will also displays progress bar.
-  my $rec = $webpac->fetch_rec;
+  my $rec = $isis->fetch;
- You should rearly have the need to call this function directly. Instead use
+ Record from this function should probably go to C<data_structure> for
- C<fetch_data_structure> which returns normalised data.
+ normalisation.
  =cut
- sub fetch_rec {
+ sub fetch {
          my $self = shift;
          my $log = $self->_get_logger();
-Line 237 
 sub fetch_rec {
+Line 249 
 sub fetch_rec {
          }
  }
- =head2 fetch_data_structure
+ =head2 pos
+ Returns current record number (MFN).
- Fetch data structure of next record from database.
+  print $isis->pos;
-  my @ds = $webpac->fetch_data_structure;
+ First record in database has position 1.
  =cut
- sub fetch_data_structure {
+ sub pos {
          my $self = shift;
+         return $self->{'current_mfn'};
+ }
+ =head2 size
+ Returns number of records in database
+  print $isis->size;
+ Result from this function can be used to loop through all records
-         return $self->data_structure(
+  foreach my $mfn ( 1 ... $isis->size ) { ... }
-                 $self->fetch_rec(@_)
-         );
+ because it takes into account C<start_mfn> and C<limit_mfn>.
+ =cut
+ sub size {
+         my $self = shift;
+         return $self->{'size'};
  }
- =head2 mfn
+ =head2 seek
- Returns current record number (MFN).
+ Seek to specified MFN in file.
+  $isis->seek(42);
-  print $webpac->mfn;
+ First record in database has position 1.
  =cut
- sub mfn {
+ sub seek {
          my $self = shift;
-         return $self->{'current_mfn'};
+         my $pos = shift || return;
+         my $log = $self->_get_logger();
+         if ($pos < 1) {
+                 $log->warn("seek before first record");
+                 $pos = 1;
+         } elsif ($pos > $self->{'max_mfn'}) {
+                 $log->warn("seek beyond last record");
+                 $pos = $self->{'max_mfn'};
+         }
+         return $self->{'current_mfn'} = (($pos - 1) || -1);
  }
  =head1 AUTHOR

 Legend:



Removed from v.8
 


changed lines


 
Added in v.21
 Legend:



Removed from v.8
 


changed lines


 
Added in v.21
-Removed from v.8
+Added in v.21

	ViewVC Help
Powered by ViewVC 1.1.26