$dbi ||= 'DBI:mysql:dbname=koha;host=10.60.0.10;port=3306';
my $batch_size = 1000;
+my $offset = $ENV{OFFSET} || 0;
my $dbh = DBI->connect($dbi,"","") || die $DBI::errstr;
my $riak = RiakSearch->new( $riak_url );
-#$riak->{args} = 'w=2';
+#$riak->{args} = 'w=1';
sub riak_search_kv_hook {
riak_search_kv_hook 'koha.marcxml';
riak_search_kv_hook "koha.$table";
-my $offset = 0;
while(1) {
my $limit = "LIMIT $batch_size OFFSET $offset";