trunk/t/pgest.t

#!/usr/bin/perl -w

use strict;

use Test::More tests => 25;

BEGIN {
        use_ok('DBI');
        use_ok('DBD::Pg');
};

# hum?
my $connect = "DBI:Pg:dbname=test";

my $dbh = DBI->connect($connect,"","") || die $DBI::errstr;
ok($dbh, "dbh");

my $pwd = $0;
$pwd =~ s#/[^/]*$##;
if ($pwd !~ m#^/#) {
        my $cwd = `pwd`;
        chomp($cwd);
        $pwd = $cwd . '/' . $pwd;
}
ok($pwd, "pwd: $pwd");
my $index = "$pwd/../data/casket/";

my $sql = "select * from pgest('$index',?,?,?,?)";
diag "$sql";

my $sth = $dbh->prepare($sql) || die $dbh->errstr();
ok($sth, "sth");

sub pgest {
        $sth->execute(@_) || die $sth->errstr();
        ok($sth, "execute(".join(",",@_).")");

        my @arr;
        while (my $row = $sth->fetchrow_hashref() ) {
                push @arr, $row;
        }
        ok(@arr, "results ".($#arr + 1));

        return @arr;
}

sub estcmd {
        my $q = shift;

        my $cmd = "estcmd search $index '$q'";
        diag $cmd;

        open(my $fh, "$cmd |") || die "cmd: $!";
        while(<$fh>) {
                if (/^HIT=(\d+)/) {
                        return $1;
                }
        }
        return undef;
}

foreach my $q (qw(blade runner Philip filip dick)) {

        ok(my $hits = estcmd($q), "estcmd: $q");

        diag "$hits hits";

        cmp_ok(scalar pgest($q, '', 0, 0), '==', $hits, 'blade runner');
}
1	#!/usr/bin/perl -w
2
3	use strict;
4
5	use Test::More tests => 25;
6
7	BEGIN {
8	use_ok('DBI');
9	use_ok('DBD::Pg');
10	};
11
12	# hum?
13	my $connect = "DBI:Pg:dbname=test";
14
15	my $dbh = DBI->connect($connect,"","") \|\| die $DBI::errstr;
16	ok($dbh, "dbh");
17
18	my $pwd = $0;
19	$pwd =~ s#/[^/]*$##;
20	if ($pwd !~ m#^/#) {
21	my $cwd = `pwd`;
22	chomp($cwd);
23	$pwd = $cwd . '/' . $pwd;
24	}
25	ok($pwd, "pwd: $pwd");
26	my $index = "$pwd/../data/casket/";
27
28	my $sql = "select * from pgest('$index',?,?,?,?)";
29	diag "$sql";
30
31	my $sth = $dbh->prepare($sql) \|\| die $dbh->errstr();
32	ok($sth, "sth");
33
34	sub pgest {
35	$sth->execute(@_) \|\| die $sth->errstr();
36	ok($sth, "execute(".join(",",@_).")");
37
38	my @arr;
39	while (my $row = $sth->fetchrow_hashref() ) {
40	push @arr, $row;
41	}
42	ok(@arr, "results ".($#arr + 1));
43
44	return @arr;
45	}
46
47	sub estcmd {
48	my $q = shift;
49
50	my $cmd = "estcmd search $index '$q'";
51	diag $cmd;
52
53	open(my $fh, "$cmd \|") \|\| die "cmd: $!";
54	while(<$fh>) {
55	if (/^HIT=(\d+)/) {
56	return $1;
57	}
58	}
59	return undef;
60	}
61
62	foreach my $q (qw(blade runner Philip filip dick)) {
63
64	ok(my $hits = estcmd($q), "estcmd: $q");
65
66	diag "$hits hits";
67
68	cmp_ok(scalar pgest($q, '', 0, 0), '==', $hits, 'blade runner');
69	}