view release on metacpan or  search on metacpan

t/003provider-BDB.t  view on Meta::CPAN

  );

my $o=Apache2::Translation::BDB->new(BDBEnv=>$bdbenv);
my $ro=Apache2::Translation::BDB->new(BDBEnv=>$bdbenv, ReadOnly=>1);

ok $o, n 'provider object';
ok $ro, n 'readonly provider';

$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;
$fo->start;
cmp_deeply $o->append($fo), 6, n 'append';
$fo->stop;
$o->commit;
$o->stop;

$ro->start;
$ro->begin;
$fo->start;
cmp_deeply $ro->append($fo), 0, n 'readonly append';
$fo->stop;
$ro->commit;
$ro->stop;

$o->start;
cmp_deeply [$ro->fetch('k1', 'u1')],
           [[0, 0, 'a', 1],
	    [0, 1, 'b', 2],
	    [1, 1, 'c', 3]],
           n 'fetch k1 u1';

cmp_deeply [$o->fetch('k1', 'u1', 1)],
           [[0, 0, 'a', 1, 'note1'],
	    [0, 1, 'b', 2, undef],
	    [1, 1, 'c', 3, 'note2']],
           n 'fetch k1 u1 with notes';

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

cmp_deeply [$ro->fetch('k1', 'u1', 1)],
           [[0, 0, 'a', 1, 'note1'],
	    [0, 1, 'b', 2, undef],
	    [1, 0, 'inserted_action', 7, 'inserted_note'],
	    [1, 1, 'c', 3, 'note2']],
           n 'fetch k1 u1 after insert';

$o->begin;
$o->update([qw/k1 u1 1 0 7/],
	   [qw/k1 u1 1 3/, "updated\naction", "updated\nnote"]);
$o->commit;

cmp_deeply [$ro->fetch('k1', 'u1', 1)],
           [[0, 0, 'a', 1, 'note1'],
	    [0, 1, 'b', 2, undef],
	    [1, 1, 'c', 3, 'note2'],
	    [1, 3, "updated\naction", 7, "updated\nnote"]],
           n 'fetch k1 u1 after update';

$o->begin;
$o->delete([qw/k1 u1 1 1 3/]);
$o->commit;

cmp_deeply [$ro->fetch('k1', 'u1', 1)],
           [[0, 0, 'a', 1, 'note1'],
	    [0, 1, 'b', 2, undef],
	    [1, 3, "updated\naction", 7, "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 1/],
       [qw/k1 u1 0 1 b/, undef, 2],
       [qw/k1 u1 1 3/, "updated\naction", "updated\nnote", 7],
       [qw/k1 u2 0 0 d note3 4/],
       [qw/k1 u2 1 0 e note4 5/],
       [qw/k1 u2 1 1 f/, undef, 6]);
my $i=0;
for( my $iterator=$o->iterator; my $el=$iterator->(); $i++ ) {
  cmp_deeply($el, $l[$i], n "iterator $i");
}
cmp_deeply( $i, 6, n 'iteratorloop count' );

$o->begin;
$o->clear;
$o->commit;

cmp_deeply [$ro->fetch('k1', 'u1', 1)],
           [],
           n 'cleared';

$o->stop;

$o->begin;
cmp_deeply( $o->timestamp(123), 0, n 'set timestamp' );
$o->commit;

cmp_deeply( $o->timestamp(), 123, n 'get timestamp' );