From 2fd683a151a9a4bdaf64d44468fbde4fa5226602 Mon Sep 17 00:00:00 2001 From: Mainframe2008 Date: Fri, 1 Feb 2013 12:46:04 +0100 Subject: Added support for searching with secondary indexes --- lib/Net/Riak/Object.pm | 29 +++++++++++++++++++++++++++++ 1 file changed, 29 insertions(+) (limited to 'lib/Net/Riak/Object.pm') diff --git a/lib/Net/Riak/Object.pm b/lib/Net/Riak/Object.pm index 7148d4f..8e48dcb 100644 --- a/lib/Net/Riak/Object.pm +++ b/lib/Net/Riak/Object.pm @@ -5,6 +5,7 @@ package Net::Riak::Object; use Moose; use Scalar::Util; use Net::Riak::Link; +use Data::Dumper; with 'Net::Riak::Role::Replica' => {keys => [qw/r w dw/]}; with 'Net::Riak::Role::Base' => {classes => @@ -23,6 +24,9 @@ has vtag => (is => 'rw', isa => 'Str'); has content_type => (is => 'rw', isa => 'Str', default => 'application/json'); has location => ( is => 'rw', isa => 'Str' ); has _jsonize => (is => 'rw', isa => 'Bool', lazy => 1, default => 1); + +has i2indexes => ( is => 'rw', isa => 'HashRef' ); + has links => ( traits => ['Array'], is => 'rw', @@ -69,6 +73,31 @@ sub store { $self->client->store_object($w, $dw, $self); } +sub i2index { + my($self, $args) = @_; + + if ( defined($args) ) { + my %args = %{$args}; + my $ref = undef; + if ( defined($self->i2indexes) ) { $ref = $self->i2indexes; } + foreach my $i (keys %args) + { + + #$i = lc($i); + print $i,"\n"; + if ( defined($args{$i}) && length($args{$i}) > 0 ) + { + $ref->{$i} = $args{$i}; + + } else { + delete $ref->{$i}; + } + } + $self->i2indexes($ref); + } + $self->i2indexes; +} + sub status { my ($self) = @_; warn "DEPRECATED: status method will be removed in the 0.17 release, please use ->client->status."; -- cgit 1.4.1