--- lib/Redis.pm 2009/03/21 21:40:53 3 +++ lib/Redis.pm 2009/03/21 22:54:10 9 @@ -5,6 +5,7 @@ use IO::Socket::INET; use Data::Dump qw/dump/; +use Carp qw/confess/; =head1 NAME @@ -80,15 +81,15 @@ =head2 set - $r->set( foo => 'bar' ); + $r->set( foo => 'bar', $new ); =cut sub set { - my ( $self, $k, $v ) = @_; - print $sock "SET $k " . length($v) . "\r\n$v\r\n"; + my ( $self, $k, $v, $new ) = @_; + print $sock ( $new ? "SETNX" : "SET" ) . " $k " . length($v) . "\r\n$v\r\n"; my $ok = <$sock>; - die dump($ok) unless $ok eq "+OK\r\n"; + confess dump($ok) unless $ok eq "+OK\r\n"; } =head2 get @@ -101,11 +102,69 @@ my ( $self, $k ) = @_; print $sock "GET $k\r\n"; my $len = <$sock>; +# warn "# len: ",dump($len); + return undef if $len eq "nil\r\n"; my $v; read($sock, $v, $len) || die $!; +# warn "# v: ",dump($v); + my $crlf; + read($sock, $crlf, 2); # skip cr/lf return $v; } +=head2 incr + + $r->incr('counter'); + $r->incr('tripplets', 3); + +=cut + +sub incr { + my ( $self, $key, $value ) = @_; + if ( defined $value ) { + print $sock "INCRBY $key $value\r\n"; + } else { + print $sock "INCR $key\r\n"; + } + my $count = <$sock>; + warn "# $key = $count"; + return $count; +} + +=head2 decr + + $r->decr('counter'); + $r->decr('tripplets', 3); + +=cut + +sub decr { + my ( $self, $key, $value ) = @_; + if ( defined $value ) { + print $sock "DECRBY $key $value\r\n"; + } else { + print $sock "DECR $key\r\n"; + } + my $count = <$sock>; + warn "# $key = $count"; + return $count; +} + +=head2 exists + + $r->exists( 'key' ) && print "got key!"; + +=cut + +sub exists { + my ( $self, $key ) = @_; + print $sock "EXISTS $key\r\n"; + my $found = <$sock>; + $found =~ s{\r\n$}{}; + warn "# exists $key = $found"; + return $found; +} + =head1 AUTHOR Dobrica Pavlinusic, C<< >>