[CC'd to dbi-users so others can test the attached]

On Tue, Feb 20, 2007 at 08:55:28PM +1100, Ron Savage wrote:
> Hi Tim
> 
> Different Perl this time, now that I'm at home. It's 9 pm so tomorrow I'll try
> it at work with Strawberry Perl.

Thanks Ron. I imagine Strawberry Perl will be the same.

> Failed Test       Stat Wstat Total Fail  Failed  List of Failed
> -------------------------------------------------------------------------------
> t/85gofer.t         14  3584    72   14  19.44%  1-4 7-13 16-18
> t/zvg_85gofer.t     14  3584    72   14  19.44%  1-4 7-13 16-18
> t/zvp_10examp.t      2   512   206    2   0.97%  5-6
> t/zvp_85gofer.t     14  3584    72   14  19.44%  1-4 7-13 16-18
> t/zvxgp_10examp.t   22  5632   206   22  10.68%  5-6 24-26 28 32 47 50-52 142-
>                                                  143 146-148 167-170 172 174
> 24 tests and 268 subtests skipped.

> Errors:

> DBI
> connect('transport=pipeone;policy=pedantic;dsn=dbi:DBM:dbm_type=SDBM_File;lockfi
> le=0','',...) failed: DBD::Gofer::Transport::pipeone command
> (C:\Perl\bin\perl.exe -MDBI::Gofer::Transport::pipeone -e run_one_stdio) 
> failed:
> Can't locate DBI/Gofer/Transport/pipeone.pm in @INC (@INC contains:
> C:\perl-modules\DBI-1.54\blib\lib:C:\perl-modules\DBI-1.54\blib\arch:C:/Perl/lib
> :C:/Perl/site/lib:. C:/Perl/lib C:/Perl/site/lib .).
> BEGIN failed--compilation aborted.
>  at t/85gofer.t line 111

Fixed, I think, in the attached.

> #   Failed test 'pipeone: Testing pipeone transport with rush policy aborted
> # '
> #   in ./t/85gofer.t at line 72.
> DBI
> connect('transport=null;policy=pedantic;dsn=dbi:Gofer:transport=stream;policy=pe
> dantic;dsn=dbi:DBM:dbm_type=SDBM_File;lockfile=0','',...) failed: Your vendor
> has not defined Fcntl macro F_GETFL, used at
> C:\perl-modules\DBI-1.54\blib\lib/DBD/Gofer/Transport/stream.pm line 213.
> ; DBI
> connect('transport=stream;policy=pedantic;dsn=dbi:DBM:dbm_type=SDBM_File;lockfil
> e=0','',...) failed: Your vendor has not defined Fcntl macro F_GETFL, used at
> C:\perl-modules\DBI-1.54\blib\lib/DBD/Gofer/Transport/stream.pm line 213.
>  at C:\perl-modules\DBI-1.54\blib\lib/DBI/Gofer/Execute.pm line 141 at
> ./t/85gofer.t line 111

That's more tricky. For now I've just disabled stream testing on Win32.

> #   Failed test 'Remove trace file dbitrace.log (Permission denied)'
> #   in ./t/10examp.t at line 50.

I'd be grateful if you could look into that one for me.
The file should have been closed by the previous call to DBI->trace(0,undef);

Tim.
#!perl -w                                         # -*- perl -*-
# vim:sw=4:ts=8
$|=1;

use strict;
use warnings;

use Cwd;
use Time::HiRes qw(time);
use Data::Dumper;
use Test::More;

use DBI;

if (my $ap = $ENV{DBI_AUTOPROXY}) { # limit the insanity
    plan skip_all => "transport+policy tests skipped with non-gofer 
DBI_AUTOPROXY"
        if $ap !~ /^dbi:Gofer/i;
    plan skip_all => "transport+policy tests skipped with non-pedantic policy 
in DBI_AUTOPROXY"
        if $ap !~ /policy=pedantic\b/i;
}
plan 'no_plan';

# 0=SQL::Statement if avail, 1=DBI::SQL::Nano
# next line forces use of Nano rather than default behaviour
$ENV{DBI_SQL_NANO}=1;

my $perf_count = (@ARGV && $ARGV[0] =~ s/^-c=//) ? shift : (-t STDOUT) ? 100 : 
0;
my %durations;

# so users can try others from the command line
my $dbm = $ARGV[0] || "SDBM_File";
my $remote_driver_dsn = "dbm_type=$dbm;lockfile=0";
my $remote_dsn = "dbi:DBM:$remote_driver_dsn";

if ($ENV{DBI_AUTOPROXY}) {
    # this means we have DBD::Gofer => DBD::Gofer => DBD::DBM!
    # rather than disable it we let it run because we're twisted
    # and because it helps find more bugs (though debugging can be painful)
    warn "\n$0 is running with DBI_AUTOPROXY enabled ($ENV{DBI_AUTOPROXY})\n"
        unless $0 =~ /\bzv/; # don't warn for t/zvg_85gofer.t
}

# ensure subprocess (for pipeone and stream transport) will use the same 
modules as us, ie ./blib
local $ENV{PERL5LIB} = join ":", @INC;


my $getcwd = getcwd();
my $username = eval { getpwuid($>) } || ''; # fails on windows
my $can_ssh = ($username && $username eq 'timbo' && -d '.svn');
my $perl = "SAMEPERL  -Mblib=$getcwd/blib"; # ensure sameperl and our blib 
(note two spaces)

my %trials = (
    null       => {},
    pipeone    => { perl=>$perl },
    stream     => { perl=>$perl },
    stream_ssh => ($can_ssh)
                ? { perl=>$perl, url => "ssh:[EMAIL PROTECTED]" }
                : undef,
    http       => { url => "http://localhost:8001/gofer"; },
);

# too dependant on local config to make a standard test
delete $trials{http} unless $username eq 'timbo' && -d '.svn';

for my $trial (keys %trials) {
    (my $transport = $trial) =~ s/_.*//;
    my $trans_attr = $trials{$trial}
        or next;

    # XXX temporary restriction, hopefully
    next if $transport eq 'stream' and $^O eq 'MSWin32'; # need Fcntl macro 
F_GETFL for non-blocking

    for my $policy_name (qw(pedantic classic rush)) {

        eval { run_tests($transport, $trans_attr, $policy_name) };
        ($@) ? fail("$trial: $@") : pass();

    }
}

# to get baseline for comparisons if doing performance testing
run_tests('no', {}, 'pedantic') if $perf_count;

while ( my ($activity, $stats_hash) = each %durations ) {
    print "\n";
    $stats_hash->{'~baseline~'} = delete $stats_hash->{"no+pedantic"};
    for my $perf_tag (reverse sort keys %$stats_hash) {
        my $dur = $stats_hash->{$perf_tag};
        printf "  %6s %-13s: %.6fsec (%5d/sec)",
            $activity, $perf_tag, $dur/$perf_count, $perf_count/$dur;
        my $baseline_dur = $stats_hash->{'~baseline~'};
        printf " %+5.1fms", (($dur-$baseline_dur)/$perf_count)*1000
            unless $perf_tag eq '~baseline~';
        print "\n";
    }
}


sub run_tests {
    my ($transport, $trans_attr, $policy_name) = @_;

    my $policy = get_policy($policy_name);

    my $test_run_tag = "Testing $transport transport with $policy_name policy";
    print "\n$test_run_tag\n";

    my $driver_dsn = "transport=$transport;policy=$policy_name";
    $driver_dsn .= join ";", '', map { "$_=$trans_attr->{$_}" } keys 
%$trans_attr
        if %$trans_attr;

    my $dsn = "dbi:Gofer:$driver_dsn;dsn=$remote_dsn";
    $dsn = $remote_dsn if $transport eq 'no';
    print " $dsn\n";

    my $dbh = DBI->connect($dsn, undef, undef, { } );
    ok $dbh, 'should connect';
    die "$test_run_tag aborted\n" unless $dbh;

    is $dbh->{Name}, ($policy->skip_connect_check or 
$policy->dbh_attribute_update eq 'none')
        ? $driver_dsn
        : $remote_driver_dsn;

    ok $dbh->do("DROP TABLE IF EXISTS fruit");
    ok $dbh->do("CREATE TABLE fruit (dKey INT, dVal VARCHAR(10))");
    die "$test_run_tag aborted\n" if $DBI::err;

    my $sth = do {
        local $dbh->{PrintError} = 0;
        $dbh->prepare("complete non-sql gibberish");
    };
    ($policy->skip_prepare_check)
        ? isa_ok $sth, 'DBI::st'
        : is $sth, undef, 'should detect prepare failure';

    ok my $ins_sth = $dbh->prepare("INSERT INTO fruit VALUES (?,?)");
    ok $ins_sth->execute(1, 'oranges');
    ok $ins_sth->execute(2, 'oranges');

    my $rowset;
    ok $rowset = $dbh->selectall_arrayref("SELECT dKey, dVal FROM fruit");
    is_deeply($rowset, [ [ '1', 'oranges' ], [ '2', 'oranges' ] ]);

    ok $dbh->do("UPDATE fruit SET dVal='apples' WHERE dVal='oranges'");

    ok $sth = $dbh->prepare("SELECT dKey, dVal FROM fruit");
    ok $sth->execute;
    ok $rowset = $sth->fetchall_hashref('dKey');
    is_deeply($rowset, { '1' => { dKey=>1, dVal=>'apples' }, 2 => { dKey=>2, 
dVal=>'apples' } });

    if ($perf_count and $transport ne 'pipeone') {
        my $start = time();
        $dbh->selectall_arrayref("SELECT dKey, dVal FROM fruit")
            for (1000..1000+$perf_count);
        $durations{select}{"$transport+$policy_name"} = time() - $start;

        # some rows in to get a (*very* rough) idea of overheads
        $start = time();
        $ins_sth->execute($_, 'speed')
            for (1000..1000+$perf_count);
        $durations{insert}{"$transport+$policy_name"} = time() - $start;
    }

    ok $dbh->do("DROP TABLE fruit");
    ok $dbh->disconnect;
}

sub get_policy {
    my ($policy_class) = @_;
    $policy_class = "DBD::Gofer::Policy::$policy_class" unless $policy_class =~ 
/::/;
    _load_class($policy_class) or die $@;
    return $policy_class->new();
}

sub _load_class { # return true or false+$@
    my $class = shift;
    (my $pm = $class) =~ s{::}{/}g;
    $pm .= ".pm"; 
    return 1 if eval { require $pm };
    delete $INC{$pm}; # shouldn't be needed (perl bug?) and assigning undef 
isn't enough
    undef; # error in $@
}   


1;

Reply via email to