while (my $row = $sth->fetchrow_hashref() ) {
my $key = join('_', map { $row->{$_} } @pk);
+ $key ||= "o.$offset";
my $biblionumber = $row->{biblionumber};
if ( my $marcxml = delete $row->{marcxml} ) {
}
$riak->request( 'PUT' => "/koha.$table/$key", $row, $headers );
+
+ $offset++;
}
- $offset += $sth->rows;
last if $sth->rows < $batch_size;
}