added Link header

diff --git a/koha/RiakSearch.pm b/koha/RiakSearch.pm
index ceebb9c..ddd4aa3 100644 (file)
--- a/koha/RiakSearch.pm
+++ b/koha/RiakSearch.pm
@@ -43,7 +43,7 @@ sub request {
        $req->header( $_ => $headers->{$_} ) foreach keys %$headers;
        $req->header( 'Host' => $1 ) if $self->{url} =~ m{http://([^/]+)};
 
        $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) {
        my $response = $self->{ua}->request($req);
 
        if ($response->is_success) {

diff --git a/koha/koha2riak-search.pl b/koha/koha2riak-search.pl
index ace3441..d89853f 100755 (executable)
--- a/koha/koha2riak-search.pl
+++ b/koha/koha2riak-search.pl
@@ -5,7 +5,7 @@ use DBI;
 use RiakSearch;
 use Data::Dump qw/dump/;
 
 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(
 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(


@@ -13,6 +13,9 @@ biblioitems
 biblio
 );
 
 biblio
 );
 

+my $limit;
+$limit = "LIMIT $ENV{LIMIT}" if $ENV{LIMIT};
+

 my $dbh = DBI->connect($dbi,"","") || die $DBI::errstr;
 my $riak = RiakSearch->new( $riak_url );
 
 my $dbh = DBI->connect($dbi,"","") || die $DBI::errstr;
 my $riak = RiakSearch->new( $riak_url );
 


@@ -44,11 +47,11 @@ foreach my $table ( @tables ) {
                        } );
         }
 
                        } );
         }
 

-        warn "# $key ",dump($row);
+#              warn "## $key ",dump($row);

 
                my $headers;
 
                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 );
     }
                }
                $riak->request( 'PUT' => "/koha.$table/$key", $row, $headers );
     }