trunk/t/pgest.t

#!/usr/bin/perl -w

use strict;

use Test::More tests => 33;

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 $attr = shift;

        my $cmd = "estcmd search ";
        $cmd .= " -attr '$attr' " if ($attr);
        $q ||= '';
        $cmd .= "$index '$q'";
        diag $cmd;

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

# test simple query
foreach my $q (qw(blade runner Philip k. dick)) {

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

        diag "$hits hits";

        cmp_ok(scalar pgest($q, '', 0, 0), '==', $hits, 'blade runner');
}

# test attr query
foreach my $q (('@title STRINC Blade Runner', '@title ISTRBW blade runner')) {

        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	dpavlin	9	use Test::More tests => 33;
6	dpavlin	8
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	dpavlin	9	my $attr = shift;
50	dpavlin	8
51	dpavlin	9	my $cmd = "estcmd search ";
52			$cmd .= " -attr '$attr' " if ($attr);
53			$q \|\|= '';
54			$cmd .= "$index '$q'";
55	dpavlin	8	diag $cmd;
56
57			open(my $fh, "$cmd \|") \|\| die "cmd: $!";
58			while(<$fh>) {
59			if (/^HIT=(\d+)/) {
60			return $1;
61			}
62			}
63			return undef;
64			}
65
66	dpavlin	9	# test simple query
67			foreach my $q (qw(blade runner Philip k. dick)) {
68	dpavlin	8
69			ok(my $hits = estcmd($q), "estcmd: $q");
70
71			diag "$hits hits";
72
73			cmp_ok(scalar pgest($q, '', 0, 0), '==', $hits, 'blade runner');
74			}
75	dpavlin	9
76			# test attr query
77			foreach my $q (('@title STRINC Blade Runner', '@title ISTRBW blade runner')) {
78
79			ok(my $hits = estcmd('',$q), "estcmd: $q");
80
81			diag "$hits hits";
82
83			cmp_ok(scalar pgest('', $q, 0, 0), '==', $hits, 'blade runner');
84			}
85