view release on metacpan or  search on metacpan

t/005provider-MMapDB.t  view on Meta::CPAN

$fo->start;
$fo->begin;
foreach my $l (split /\n/, $data) {
  next if( $l=~/^#/ );
  chomp $l;
  $fo->insert([split /\t+/, $l]);
}
$fo->commit;
$fo->stop;

$o->start;
$o->begin;
eval {$o->clear};
cmp_deeply $@, '', n 'newly created db successfully cleared';
$fo->start;
cmp_deeply $o->append($fo), 6, n 'append';
$fo->stop;
$o->commit;
$o->stop;

$ro->start;
$@='';
eval {$ro->begin};
is $@, "ERROR: read-only mode\n", n 'readonly append';
$ro->stop;

$o->start;
$ro->start;

cmp_deeply [$ro->fetch('k1', 'u1')],
           [[0, 0, 'a', re(qr/^\d+$/)],
	    [0, 1, 'b', re(qr/^\d+$/)],
	    [1, 1, 'c', re(qr/^\d+$/)]],
           n 'fetch k1 u1';

cmp_deeply [$o->fetch('k1', 'u1', 1)],
           [[0, 0, 'a', re(qr/^\d+$/), 'note1'],
	    [0, 1, 'b', re(qr/^\d+$/), undef],
	    [1, 1, 'c', re(qr/^\d+$/), 'note2']],
           n 'fetch k1 u1 with notes';

$o->begin;
$o->insert([qw/k1 u1 1 0 inserted_action inserted_note/]);
$o->commit;

$ro->start;
cmp_deeply [$ro->fetch('k1', 'u1', 1)],
           [[0, 0, 'a', re(qr/^\d+$/), 'note1'],
	    [0, 1, 'b', re(qr/^\d+$/), undef],
	    [1, 0, 'inserted_action', re(qr/^\d+$/), 'inserted_note'],
	    [1, 1, 'c', re(qr/^\d+$/), 'note2']],
           n 'fetch k1 u1 after insert';

$o->begin;
$o->update([qw/k1 u1 1 0/, $o->_db->main_index->{trans}->{db}
                             ->{actn}->{k1}->{u1}->[2]->[3]],
	   [qw/k1 u1 1 3/, "updated\naction", "updated\nnote"]);
$o->commit;

SKIP: {
  eval 'use JSON::XS; use Algorithm::Diff';
  $@ and skip 'JSON::XS or Algorithm::Diff not installed', 4;

  cmp_deeply [$ro->diff($o)],
             [
              [["-", 2,
                ["k1", "u1", 1, 0, "inserted_action", "inserted_note"]]],
              [["+", 3,
                ["k1", "u1", 1, 3, "updated\naction", "updated\nnote"]]],
             ],
             n 'diff after update';

  cmp_deeply [$ro->diff($o, qw/key k1 uri u1/)],
             [
              [["-", 2,
                ["k1", "u1", 1, 0, "inserted_action", "inserted_note"]]],
              [["+", 3,
                ["k1", "u1", 1, 3, "updated\naction", "updated\nnote"]]],
             ],
             n 'diff2 after update';

  cmp_deeply [$ro->diff($o, qw/key k1 uri u2/)],
             [],
             n 'diff3 after update';

  cmp_deeply [$ro->diff($o, qw/key hugo uri erna/)],
             [],
             n 'diff4 after update';
}

$ro->start;
cmp_deeply [$ro->fetch('k1', 'u1', 1)],
           [[0, 0, 'a', re(qr/^\d+$/), 'note1'],
	    [0, 1, 'b', re(qr/^\d+$/), undef],
	    [1, 1, 'c', re(qr/^\d+$/), 'note2'],
	    [1, 3, "updated\naction", re(qr/^\d+$/), "updated\nnote"]],
           n 'fetch k1 u1 after update';

$o->begin;
$o->delete([qw/k1 u1 1 1/, $o->_db->main_index->{trans}->{db}
                             ->{actn}->{k1}->{u1}->[2]->[3]]);
$o->commit;

$ro->start;
cmp_deeply [$ro->fetch('k1', 'u1', 1)],
           [[0, 0, 'a', re(qr/^\d+$/), 'note1'],
	    [0, 1, 'b', re(qr/^\d+$/), undef],
	    [1, 3, "updated\naction", re(qr/^\d+$/), "updated\nnote"]],
           n 'fetch k1 u1 after delete';

#$o->dump("%{KEY} / %{URI}\t%{BLOCK}/%{ORDER} %{ID}\n%{pa>> ;ACTION}\n%{pn>> ;NOTE}\n\n");

my @l=([qw/k1 u1 0 0 a note1/, re(qr/^\d+$/)],
       [qw/k1 u1 0 1 b/, undef, re(qr/^\d+$/)],
       [qw/k1 u1 1 3/, "updated\naction", "updated\nnote", re(qr/^\d+$/)],
       [qw/k1 u2 0 0 d note3/, re(qr/^\d+$/)],
       [qw/k1 u2 1 0 e note4/, re(qr/^\d+$/)],
       [qw/k1 u2 1 1 f/, undef, re(qr/^\d+$/)]);
my $i=0;
for( my $iterator=$o->iterator; my $el=$iterator->(); $i++ ) {
  cmp_deeply($el, $l[$i], n "iterator $i");
}