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	#!/usr/bin/perl -w
2
3	use strict;
4
5	use Test::More tests => 33;
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	my $attr = shift;
50
51	my $cmd = "estcmd search ";
52	$cmd .= " -attr '$attr' " if ($attr);
53	$q \|\|= '';
54	$cmd .= "$index '$q'";
55	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	# test simple query
67	foreach my $q (qw(blade runner Philip k. dick)) {
68
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
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