File Coverage

lib/Metadata/DB/Indexer.pm

Criterion	Covered	Total	%
statement	6	6	100.0
branch			n/a
condition			n/a
subroutine	2	2	100.0
pod			n/a
total	8	8	100.0

package Metadata::DB::Indexer;
use strict;
use base 'Metadata::DB::Base';
use LEOCHARRE::DEBUG;
use LEOCHARRE::Class2;
use Carp;
use vars qw($VERSION);
$VERSION = sprintf "%d.%02d", q$Revision: 1.3 $ =~ /(\d+)/g;

__PACKAGE__->make_constructor;
__PACKAGE__->make_accessor_setget({
   records_to_index => [],
   records_indexed_count => 0,
});


sub records_to_index_count {
   my $self = shift;

   my $records = $self->records_to_index
      or warn('records_to_index was not set yet, cant get count')
      and return;
   ref $records eq 'ARRAY' or confess('records to index must be array ref');

   my $count = scalar @$records;
   return $count;
}


# overrite me
sub record_identifier_to_metadata {
   warn ( __PACKAGE__."::record_to_metadata() overrite me please, see Metadata::DB::Indexer");
   return;
}

sub run {
   my $self = shift;

   my $count = $self->records_to_index_count
      or return;

   debug("will index $count records");


   my $autocommit_original_setting = $self->dbh->{AutoCommit};

   # should we localize?
   $self->dbh->{AutoCommit} = 0;


   # drop/reset/create the table
   my $name = $self->table_metadata_name;

   debug("reseting '$name' table");
   $self->table_metadata_reset;


   my $record_identifiers = $self->records_to_index;

   ITERATION: for my $identifier ( @$record_identifiers ){

       $self->_index_one_record($identifier);
   }

   # commit and set back the autocommit setting to what it was
   debug("Done. Committing changes to db..");
   $self->dbh->commit;
   $self->dbh->{AutoCommit} = $autocommit_original_setting;


   debug( sprintf "Indexed %s/%s records", $self->records_indexed_count, $count );

   return 1;
}


sub _index_one_record {
   my($self,$identifier) = @_;
   defined $identifier or confess;

   no strict 'refs';
   my $meta = &{__PACKAGE__.'::record_identifier_to_metadata'}($identifier);

   if( ! defined $meta ){
      warn("record_identifier_to_metadata() returns undef for [$identifier]");
      return;
   }

   elsif( ! ((ref $meta) and (ref $meta eq 'HASH')) ){
      warn("record_identifier_to_metadata() does not return hash ref");
      return;
   }
   elsif( ! ( keys %$meta ) ){
      warn("record_identified_to_metadata() has ref has nothing?");
      return;
   }

   my $id = ( $self->records_indexed_count + 1 );

   unless( $self->_table_metadata_insert_multiple($id,$meta) ){
      warn("could not insert record[$id],[meta ref:$meta], ".$self->dbh->errstr);
      return;
   }

  # hack:
  $self->records_indexed_count($id); #increment, we only get here if we inserter properly

  return 1;
}





1;


__END__