--- lib/Redis.pm 2009/03/21 21:25:52 2 +++ 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 @@ -66,7 +67,7 @@ =head2 ping - $r->ping || die "no server?"; + $r->ping || die "no server?"; =cut @@ -76,6 +77,94 @@ die "ping failed, got ", dump($pong) unless $pong eq "+PONG\r\n"; } +=head1 Commands operating on string values + +=head2 set + + $r->set( foo => 'bar', $new ); + +=cut + +sub set { + my ( $self, $k, $v, $new ) = @_; + print $sock ( $new ? "SETNX" : "SET" ) . " $k " . length($v) . "\r\n$v\r\n"; + my $ok = <$sock>; + confess dump($ok) unless $ok eq "+OK\r\n"; +} + +=head2 get + + my $value = $r->get( 'foo' ); + +=cut + +sub get { + 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<< >>