$req->header( $_ => $headers->{$_} ) foreach keys %$headers;
$req->header( 'Host' => $1 ) if $self->{url} =~ m{http://([^/]+)};
- warn "# $method $full_url ", dump($req, $content);
+# warn "## $method $full_url ", dump($req, $content);
my $response = $self->{ua}->request($req);
if ($response->is_success) {
use RiakSearch;
use Data::Dump qw/dump/;
-my $limit = "limit 5";
+
my $riak_url = 'http://10.60.0.92:8098';
my $dbi = 'DBI:mysql:dbname=koha;host=10.60.0.10;port=3306';
my @tables = qw(
biblio
);
+my $limit;
+$limit = "LIMIT $ENV{LIMIT}" if $ENV{LIMIT};
+
my $dbh = DBI->connect($dbi,"","") || die $DBI::errstr;
my $riak = RiakSearch->new( $riak_url );
} );
}
- warn "# $key ",dump($row);
+# warn "## $key ",dump($row);
my $headers;
- if ( exists $row->{biblionumber} && $key !~ m/biblionumber/ ) {
- $headers->{Links} = '/koha.biblio/' . $row->{biblionumber};
+ if ( my $biblionumber = $row->{biblionumber} ) {
+ $headers->{Link} = qq|</riak/koha.biblio/$biblionumber>; riaktag="biblio"| unless $key =~ m/biblionumber/;
}
$riak->request( 'PUT' => "/koha.$table/$key", $row, $headers );
}