view release on metacpan or  search on metacpan

t/00-basic.t  view on Meta::CPAN

#!/usr/bin/perl
use strict;
use warnings;
use Test::More tests => 22;
use Test::Deep;
use Data::Dumper;

use_ok('MemcacheDBI');

my $memd_server = $ENV{'memd_server'};
my $user = $ENV{'dbi_user'};
my $password = $ENV{'dbi_pass'};
my $database = $ENV{'dbi_table'} // 'test';
my $table = $ENV{'dbi_table'} // 'test';
my $data_source = $ENV{'dbi_source'} // "dbi:CSV:f_dir=./t";

my $dbh_outside = DBI->connect($data_source, $user, $password, {
    'AutoCommit'         => 1,
    'ChopBlanks'         => 1,
    'ShowErrorStatement' => 1,
    'pg_enable_utf8'     => 1,
    'mysql_enable_utf8'  => 1,
});
cmp_ok(ref $dbh_outside,'eq','DBI::db', 'DBH created successfully');


SKIP: {
    skip 'Failed to connect to database', 20 unless ref $dbh_outside;

    foreach my $AutoCommit ( 1, 0 ) {
        SKIP: {
            skip 'dbi:CSV does not support transactions', 10 if !$AutoCommit && $data_source =~ /^dbi:CSV:/;

            my $testData = 'abc'.$AutoCommit;
            my $dbh = MemcacheDBI->connect($data_source, $user, $password, {
                'AutoCommit'         => $AutoCommit,
                'ChopBlanks'         => 1,
                'ShowErrorStatement' => 1,
                'pg_enable_utf8'     => 1,
                'mysql_enable_utf8'  => 1,
            });
            ok(ref $dbh, 'MemcacheDBH created successfully AutoCommit='.$AutoCommit);





            my $sth = $dbh->prepare("update $table set district = '' where locationnum = 126");
            $sth->execute;
            $dbh->commit unless $dbh->{'AutoCommit'};
            $sth = $dbh->prepare("select locationnum,custnum,district from $table where locationnum = 126");
            $sth->execute;
            my $data_dbh = $sth->fetchrow_hashref;
            cmp_ok( $data_dbh->{'locationnum'},'==', 126, "Retrieved a row");





            SKIP: {
                skip 'no memcache server configured eg "export memd_server=localhost:11211"', 7 unless 0 && $memd_server;
                my $newdbh = $dbh->memd_init({
                    servers => [$memd_server],
                    namespace => 'oaxlinMemcacheDBItests:',
                    close_on_error => 1,
                    max_failures => 3,
                    failure_timeout => 2,
                });
                ok( $dbh->{'MemcacheDBI'}->{'memd'}->server_versions , 'Memcache successfully initialized');




                ok( $dbh->memd->set('test1',$data_dbh) , 'Memcache set success');
                my $data_memd = $dbh->memd->get('test1');
                cmp_deeply($data_memd,$data_dbh, 'Memcache get success, before commit') unless $dbh->{'AutoCommit'};
                $dbh->commit unless $dbh->{'AutoCommit'};
                $data_memd = $dbh->memd->get('test1');
                cmp_deeply($data_memd,$data_dbh, 'Memcache get success');




                my $data_memd_updated = $dbh->memd->get('test1');
                $data_memd_updated->{'district'} = $testData;
                $sth = $dbh->prepare("update $table set district = ? where locationnum = 126");
                $sth->execute($testData);
                ok( $dbh->memd->set('test1',$data_memd_updated) , 'Memcache set success');

                my $data_memd2 = $dbh->memd->get('test1');
                my $data_cmp;
                if (! $dbh->{'AutoCommit'}) {
                    my $data_memd3 = $dbh->memd->get('test1');
                    my $sth = $dbh->prepare("select locationnum,custnum,district from $table where locationnum = 126");
                    $sth->execute;
                    my $data_dbh = $sth->fetchrow_hashref;
                    cmp_deeply($data_memd3,$data_dbh, 'Memcache get success, before rollback');
                    $dbh->rollback;
                } else {
                    my $data_memd3 = $dbh->memd->get('test1');