view release on metacpan or  search on metacpan

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

# -*- perl -*-

# Copyright (c) 2010 AdCopy
# Author: Jeff Weisberg
# Created: 2010-Jun-15 17:21 (EDT)
# Function: sqlite example storage backend
#
# $Id$

package AC::Yenta::Store::SQLite;
use AC::Yenta::Debug 'sqlite';
use MIME::Base64;
use DBI;
use strict;

my $initsql;

AC::Yenta::Store::Map->add_backend( sql    => 'AC::Yenta::Store::SQLite' );
AC::Yenta::Store::Map->add_backend( sqlite => 'AC::Yenta::Store::SQLite' );

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 sqlite file=$file");

    my $dsn = "dbi:SQLite:dbname=$file";

    my $db = DBI->connect( $dsn, '', '', {
        AutoCommit => 1,
        RaiseError => 1,
    } );

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

    _init( $db );

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

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

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

    my $st = _do($me->{db}, 'select value, 1 from ykv where map = ? and sub = ? and key = ?', $map, $sub, $key);

    my($v, $found) = $st->fetchrow_array();
    return unless $found;

    $v = decode_base64($v);

    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");

    my $st = _do($me->{db}, 'select 1 from ykv where map = ? and sub = ? and key = ?', $map, $sub, $key);
    my($found) = $st->fetchrow_array();

    if( $found ){
        _do($me->{db}, 'update ykv set value = ? where map = ? and sub = ? and key = ?', encode_base64($val), $map, $sub, $key);
    }else{
        _do($me->{db}, 'insert into ykv (map,sub,key,value) values (?,?,?,?)',  $map, $sub, $key, encode_base64($val));
    }

    return 1;
}

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

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

    _do($me->{db}, 'delete from ykv where map = ? and sub = ? and key = ?', $map, $sub, $key);

    return 1;
}