trunk/t/disjoint.t

#!/usr/bin/perl -w

use strict;

use Test::More;
use File::Path qw(rmtree);
use blib;

BEGIN { use_ok('WAIT::Database'); }

plan tests => 31;

if (-e './test') {
        warn "test directory exists, removing!\n";
        rmtree('./test',0,1);
}

ok(my $db = WAIT::Database->create(name => 'test'), "create");

ok(my $tb = $db->create_table(name => 'sample', attr => ['docid', 'term'],
  djk => ['docid']), "create_table");

my $etid = 1;
my @db;
while (<DATA>) {
  chomp;
  my($weight, $did, $term) = split;
  my $tid = $tb->insert($weight, docid => $did, term => $term);
  push @db, [$did, $term, $weight];
  cmp_ok ($tid, '==', $etid++, "insert $etid");
}

ok(my $sc = $tb->open_scan(), "open_scan");

my $tid = 0; 
while (my %tp = $sc->next()) {
  ok (
        ($tp{docid} == $db[$tid]->[0] and $tp{term} eq $db[$tid]->[1]),
        "next ".$tid++);
}

ok($sc = $tb->open_scan(sub {$_[0]->{term} eq 'IR'}),"open_scan IR");

$tid=0;
my @ndb = @db[1,4];
while (my %tp = $sc->next()) {
  ok(($tp{docid} == $ndb[$tid]->[0] and $tp{term} eq $ndb[$tid]->[1]), "next ".$tid++);
}

ok($sc = $tb->open_index_scan(['docid', 'term']), "open_index_scan");

$etid = 1; 
while (my %tp = $sc->next()) {
  ok(($tp{_id} == $etid), "next ".$etid++);
}

ok($sc = $tb->open_index_scan(['docid', 'term'], sub {$_[0]->{term} eq 'IR'}),
        "open_index_scan IR");

@ndb = (1,4);
while (my %tp = $sc->next()) {
  ok(($tp{_id} == shift(@ndb)+1), "next");
}

ok($tb->close, "close");

# must have destroyed all handles here !
# clean up
ok($db->dispose, "dispose");
ok((!defined $db), "undef");

__END__
0.1 1 DB
0.2 1 IR
0.3 2 DB
0.4 2 KI
0.5 3 IR
0.6 3 KI
1	#!/usr/bin/perl -w
2
3	use strict;
4
5	use Test::More;
6	use File::Path qw(rmtree);
7	use blib;
8
9	BEGIN { use_ok('WAIT::Database'); }
10
11	plan tests => 31;
12
13	if (-e './test') {
14	warn "test directory exists, removing!\n";
15	rmtree('./test',0,1);
16	}
17
18	ok(my $db = WAIT::Database->create(name => 'test'), "create");
19
20	ok(my $tb = $db->create_table(name => 'sample', attr => ['docid', 'term'],
21	djk => ['docid']), "create_table");
22
23	my $etid = 1;
24	my @db;
25	while (<DATA>) {
26	chomp;
27	my($weight, $did, $term) = split;
28	my $tid = $tb->insert($weight, docid => $did, term => $term);
29	push @db, [$did, $term, $weight];
30	cmp_ok ($tid, '==', $etid++, "insert $etid");
31	}
32
33	ok(my $sc = $tb->open_scan(), "open_scan");
34
35	my $tid = 0;
36	while (my %tp = $sc->next()) {
37	ok (
38	($tp{docid} == $db[$tid]->[0] and $tp{term} eq $db[$tid]->[1]),
39	"next ".$tid++);
40	}
41
42	ok($sc = $tb->open_scan(sub {$_[0]->{term} eq 'IR'}),"open_scan IR");
43
44	$tid=0;
45	my @ndb = @db[1,4];
46	while (my %tp = $sc->next()) {
47	ok(($tp{docid} == $ndb[$tid]->[0] and $tp{term} eq $ndb[$tid]->[1]), "next ".$tid++);
48	}
49
50	ok($sc = $tb->open_index_scan(['docid', 'term']), "open_index_scan");
51
52	$etid = 1;
53	while (my %tp = $sc->next()) {
54	ok(($tp{_id} == $etid), "next ".$etid++);
55	}
56
57	ok($sc = $tb->open_index_scan(['docid', 'term'], sub {$_[0]->{term} eq 'IR'}),
58	"open_index_scan IR");
59
60	@ndb = (1,4);
61	while (my %tp = $sc->next()) {
62	ok(($tp{_id} == shift(@ndb)+1), "next");
63	}
64
65	ok($tb->close, "close");
66
67	# must have destroyed all handles here !
68	# clean up
69	ok($db->dispose, "dispose");
70	ok((!defined $db), "undef");
71
72	__END__
73	0.1 1 DB
74	0.2 1 IR
75	0.3 2 DB
76	0.4 2 KI
77	0.5 3 IR
78	0.6 3 KI