view release on metacpan or  search on metacpan

lib/AC/Yenta/Store/LevelDB.pm  view on Meta::CPAN

# -*- perl -*-

# Copyright (c) 2009 AdCopy
# Author: Jeff Weisberg
# Created: 2009-Mar-30 18:39 (EDT)
# Function: interface with LevelDB
#
# $Id$

package AC::Yenta::Store::LevelDB;
use AC::Yenta::Debug 'ldb';
use strict;

# does not support concurrent access
# does not work on sparc


BEGIN {
    # only if we have it (no LevelDB on sparc)
    eval {
        require Tie::LevelDB;
        AC::Yenta::Store::Map->add_backend( ldb 	=> 'AC::Yenta::Store::LevelDB' );
        AC::Yenta::Store::Map->add_backend( leveldb 	=> 'AC::Yenta::Store::LevelDB' );
    };
};

my %OPEN;

sub new {
    my $class = shift;
    my $name  = shift;
    my $conf  = shift;

    my $file  = $conf->{dbfile};
    unless( $file ){
        problem("no dbfile specified for '$name'");
        return;
    }

    debug("opening LevelDB file=$file");
    my $db = $OPEN{$file} || Tie::LevelDB::DB->new( $file );
    $OPEN{$file} = $db;

    problem("cannot open db file $file") unless $db;

    # web server will need access
    chmod 0777, $file;

    return bless {
        file	=> $file,
        db	=> $db,
    }, $class;
}

sub get {
    my $me  = shift;
    my $map = shift;
    my $sub = shift;
    my $key = shift;

    my $v;
    debug("get $map/$sub/$key");
    my $v = $me->{db}->Get( _key($map,$sub,$key) );

    return unless $v; # not found

    if( wantarray ){
        return ($v, 1);
    }
    return $v;
}

sub put {
    my $me  = shift;
    my $map = shift;
    my $sub = shift;
    my $key = shift;
    my $val = shift;

    debug("put $map/$sub/$key");