my $dbh = DBI->connect($dbi,"","") || die $DBI::errstr;
my $riak = Net::Riak->new(host => $riak_url );
-#my $marcxml_bucket = $riak->bucket( 'koha.marcxml' );
+my $xml_bucket = $riak->bucket( 'koha.marcxml' );
+$xml_bucket->set_properties({
+ precommit => [ { mod => 'riak_search_kv_hook', fun => 'precommit' } ],
+});
+
foreach my $table ( @tables ) {
print "import ", $sth->rows, " rows from $table pk:",dump( @pk ),"...\n";
my $bucket = $riak->bucket( 'koha.' . $table );
+ $bucket->set_properties({
+ precommit => [ { mod => 'riak_search_kv_hook', fun => 'precommit' } ],
+ });
while (my $row = $sth->fetchrow_hashref() ) {