diff options
Diffstat (limited to 'lib/KiokuDB/Backend')
| -rw-r--r-- | lib/KiokuDB/Backend/Memcachedb.pm | 141 |
1 files changed, 128 insertions, 13 deletions
diff --git a/lib/KiokuDB/Backend/Memcachedb.pm b/lib/KiokuDB/Backend/Memcachedb.pm index d4f4aff..4a336cd 100644 --- a/lib/KiokuDB/Backend/Memcachedb.pm +++ b/lib/KiokuDB/Backend/Memcachedb.pm @@ -1,33 +1,148 @@ package KiokuDB::Backend::Memcachedb; +use Moose; -use strict; -use warnings; -our $VERSION = '0.01'; +use Data::Stream::Bulk::Util qw(bulk); + +use Cache::Memcached; +use namespace::clean -except => 'meta'; + +use Carp; + +our $VERSION = "0.01"; + +with qw( + KiokuDB::Backend + KiokuDB::Backend::Serialize::Delegate + KiokuDB::Backend::Role::UnicodeSafe + KiokuDB::Backend::Role::TXN::Memory + KiokuDB::Backend::Role::Concurrency::POSIX +); + +has create => ( + isa => "Bool", + is => "ro", + default => 0, +); + +sub BUILD { + my $self = shift; +} + +has db => ( + isa => "Cache::Memcached", + is => "ro", + handles => [qw(document)], +); + +sub new_from_dsn_params { + my ( $self, %args ) = @_; + + my $servers = delete $args{ servers }; + my @servers = split /,/, $servers; + my $db = Cache::Memcached->new( { 'servers' => \@servers } ); + $self->new( %args, db => $db ); +} + +sub insert { + my ( $self, @entries ) = @_; + my $db = $self->db; + foreach my $entry ( @entries ) { + $db->set( $entry->id, $self->serialize( $entry ) ); + } +} + +sub get { + my ( $self, @ids ) = @_; + + my $db = $self->db; + + my @objs = map { $self->deserialize( $db->get( $_ ) ) } @ids; + scalar @objs == 1 ? return shift @objs : @objs; +} + +sub commit_entries { + my ( $self, @entries ) = @_; + my $db = $self->db; + my @checks = $self->exists( map { $_->id } @entries ); + + foreach my $entry ( @entries ) { + my $id = $entry->id; + + my $status = shift @checks; + if ( $entry->deleted ) { + if ( !$status ) { + croak "Entry $id doesn't exist in the database"; + } + $db->delete( $id ); + } else { + if ( $status and not $entry->has_prev ) { + croak "Entry $id already exists in the database"; + } + $db->set( $id, $self->serialize( $entry ) ); + } + } +} + +sub exists { + my ( $self, @ids ) = @_; + my $check = $self->db->get_multi( @ids ); + map { exists $check->{ $_ } ? 1 : 0 } @ids; +} + +sub delete { + my ($self, @ids_or_entries) = @_; + my @ids = map { ref($_) ? $_->id : $_ } @ids_or_entries; + $self->db->delete($_) foreach (@ids); +} + +__PACKAGE__->meta->make_immutable; + +__PACKAGE__ -1; __END__ +=pod + =head1 NAME -KiokuDB::Backend::Memcachedb - +KiokuDB::Backend::Memcachedb - Memcachedb backend for L<KiokuDB> =head1 SYNOPSIS - use KiokuDB::Backend::Memcachedb; + KiokuDB->connect( + "memcachedb:servers=127.0.0.1:112200,127.0.0.1:112222" + ); =head1 DESCRIPTION -KiokuDB::Backend::Memcachedb is +This backend provides L<KiokuDB> support for Memcachedb using +L<Cache::Memcached> -=head1 AUTHOR +=head1 ATTRIBUTES + +=over 4 -franck cuny E<lt>franck.cuny@rtgi.frE<gt> +=item db + +An L<Cache::Memcachedb> instance. + +Required. + +=back + +=head1 VERSION CONTROL + +L<http://github.com/franckcuny/kiokudb-backend-memcachedb> + +=head1 AUTHOR -=head1 SEE ALSO +Nils Grunwald E<lt>nils.grunwald@rtgi.frE<gt> +Franck Cuny E<lt>franck.cuny@rtgi.frE<gt> -=head1 LICENSE +=head1 COPYRIGHT -This library is free software; you can redistribute it and/or modify -it under the same terms as Perl itself. + Copyright (c) 2009, nils grunwald, franck cuny, RTGI. All + rights reserved This program is free software; you can redistribute + it and/or modify it under the same terms as Perl itself. =cut |