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	dpavlin	8	#!/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			}