X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=t%2Frun%2F16joins.tl;h=15603aa9f8f4f3aa113e400a197914dabc3f8e40;hb=0823196cc624de941880cecd19588c3bac024e73;hp=962ee48f239a00155f5219cddfe4e0d2e0509759;hpb=485f6e107dda47fa75315f180f7a7e2345a2cbfc;p=dbsrgits%2FDBIx-Class.git diff --git a/t/run/16joins.tl b/t/run/16joins.tl index 962ee48..15603aa 100644 --- a/t/run/16joins.tl +++ b/t/run/16joins.tl @@ -2,17 +2,25 @@ sub run_tests { my $schema = shift; use IO::File; -use version; BEGIN { eval "use DBD::SQLite"; plan $@ ? ( skip_all => 'needs DBD::SQLite for testing' ) - : ( tests => 41 ); + : ( tests => 44 ); } -my $is_broken_sqlite = version->new($schema->storage->dbh->get_info(18)) lt '3.2.6' && - $schema->storage->dbh->get_info(17) eq 'SQLite'; +# figure out if we've got a version of sqlite that is older than 3.2.6, in +# which case COUNT(DISTINCT()) doesn't work +my $is_broken_sqlite = 0; +my ($sqlite_major_ver,$sqlite_minor_ver,$sqlite_patch_ver) = + split /\./, $schema->storage->dbh->get_info(18); +if( $schema->storage->dbh->get_info(17) eq 'SQLite' && + ( ($sqlite_major_ver < 3) || + ($sqlite_major_ver == 3 && $sqlite_minor_ver < 2) || + ($sqlite_major_ver == 3 && $sqlite_minor_ver == 2 && $sqlite_patch_ver < 6) ) ) { + $is_broken_sqlite = 1; +} # test the abstract join => SQL generator my $sa = new DBIC::SQL::Abstract; @@ -65,7 +73,7 @@ my $rs = $schema->resultset("CD")->search( ] ] } ); -cmp_ok( $rs->count, '==', 1, "Single record in resultset"); +cmp_ok( $rs + 0, '==', 1, "Single record in resultset"); is($rs->first->title, 'Forkful of bees', 'Correct record returned'); @@ -73,7 +81,7 @@ $rs = $schema->resultset("CD")->search( { 'year' => 2001, 'artist.name' => 'Caterwauler McCrae' }, { join => 'artist' }); -cmp_ok( $rs->count, '==', 1, "Single record in resultset"); +cmp_ok( $rs + 0, '==', 1, "Single record in resultset"); is($rs->first->title, 'Forkful of bees', 'Correct record returned'); @@ -82,7 +90,7 @@ $rs = $schema->resultset("CD")->search( 'liner_notes.notes' => 'Kill Yourself!' }, { join => [ qw/artist liner_notes/ ] }); -cmp_ok( $rs->count, '==', 1, "Single record in resultset"); +cmp_ok( $rs + 0, '==', 1, "Single record in resultset"); is($rs->first->title, 'Come Be Depressed With Us', 'Correct record returned'); @@ -93,6 +101,10 @@ $rs = $schema->resultset("CD")->search( ); cmp_ok( scalar $rs->all, '==', scalar $rs->slice(0, $rs->count - 1), 'slice() with join has same count as all()' ); +eval { $rs->search(undef, { rows => 0, offset => 3 })->all; }; + +ok($@, "rows => 0 errors: $@"); + $rs = $schema->resultset("Artist")->search( { 'liner_notes.notes' => 'Kill Yourself!' }, { join => { 'cds' => 'liner_notes' } }); @@ -106,11 +118,13 @@ $rs = $schema->resultset("CD")->search( { prefetch => [ qw/artist liner_notes/ ], order_by => 'me.cdid' }); -cmp_ok($rs->count, '==', 3, 'Correct number of records returned'); +cmp_ok($rs + 0, '==', 3, 'Correct number of records returned'); + +my $queries = 0; +$schema->storage->debugcb(sub { $queries++ }); -# start test for prefetch SELECT count -unlink 't/var/dbic.trace' if -e 't/var/dbic.trace'; -DBI->trace(1, 't/var/dbic.trace'); +$queries = 0; +$schema->storage->debug(1); my @cd = $rs->all; @@ -124,30 +138,22 @@ is(ref $cd[1]->liner_notes, 'DBICTest::LinerNotes', 'Prefetch returns correct cl is($cd[2]->{_inflated_column}{artist}->name, 'Caterwauler McCrae', 'Prefetch on parent object ok'); -# count the SELECTs -DBI->trace(0, undef); -my $selects = 0; -my $trace = IO::File->new('t/var/dbic.trace', '<') - or die "Unable to read trace file"; -while (<$trace>) { - $selects++ if /SELECT/; -} -$trace->close; -unlink 't/var/dbic.trace'; -is($selects, 1, 'prefetch ran only 1 select statement'); +is($queries, 1, 'prefetch ran only 1 select statement'); + +$schema->storage->debug(0); -# test for partial prefetch via cols attr +# test for partial prefetch via columns attr my $cd = $schema->resultset('CD')->find(1, { - cols => [qw/title artist.name/], - join => 'artist' + columns => [qw/title artist.name/], + join => { 'artist' => {} } } ); ok(eval { $cd->artist->name eq 'Caterwauler McCrae' }, 'single related column prefetched'); # start test for nested prefetch SELECT count -unlink 't/var/dbic.trace' if -e 't/var/dbic.trace'; -DBI->trace(1, 't/var/dbic.trace'); +$queries = 0; +$schema->storage->debug(1); $rs = $schema->resultset('Tag')->search( {}, @@ -163,36 +169,18 @@ is( $tag->cd->title, 'Spoonful of bees', 'step 1 ok for nested prefetch' ); is( $tag->cd->artist->name, 'Caterwauler McCrae', 'step 2 ok for nested prefetch'); # count the SELECTs -DBI->trace(0, undef); -$selects = 0; -$trace = IO::File->new('t/var/dbic.trace', '<') - or die "Unable to read trace file"; -while (<$trace>) { - $selects++ if /SELECT(?!.*WHERE 1=0.*)/; -} -$trace->close; -unlink 't/var/dbic.trace'; -is($selects, 1, 'nested prefetch ran exactly 1 select statement (excluding column_info)'); +#$selects++ if /SELECT(?!.*WHERE 1=0.*)/; +is($queries, 1, 'nested prefetch ran exactly 1 select statement (excluding column_info)'); -# start test for prefetch on find SELECT count -unlink 't/var/dbic.trace' if -e 't/var/dbic.trace'; -DBI->trace(1, 't/var/dbic.trace'); +$queries = 0; $cd = $schema->resultset('CD')->find(1, { prefetch => 'artist' }); is($cd->{_inflated_column}{artist}->name, 'Caterwauler McCrae', 'artist prefetched correctly on find'); -# count the SELECTs -DBI->trace(0, undef); -$selects = 0; -$trace = IO::File->new('t/var/dbic.trace', '<') - or die "Unable to read trace file"; -while (<$trace>) { - $selects++ if /SELECT(?!.*WHERE 1=0.*)/; -} -$trace->close; -unlink 't/var/dbic.trace'; -is($selects, 1, 'find with prefetch ran exactly 1 select statement (excluding column_info)'); +is($queries, 1, 'find with prefetch ran exactly 1 select statement (excluding column_info)'); + +$schema->storage->debug(0); $rs = $schema->resultset('Tag')->search( {}, @@ -245,7 +233,16 @@ SKIP: { cmp_ok( $rs->count, '==', 3, "count() ok after group_by on related column" ); } -cmp_ok( scalar $rs->all, '==', 3, "all() returns same count as count() after group_by on related column" ); +$rs = $schema->resultset("Artist")->search( + {}, + { join => [qw/ cds /], group_by => [qw/ me.name /], having =>{ 'MAX(cds.cdid)'=> \'< 5' } } +); + +cmp_ok( $rs->all, '==', 2, "results ok after group_by on related column with a having" ); + +$rs = $rs->search( undef, { having =>{ 'count(*)'=> \'> 2' }}); + +cmp_ok( $rs->all, '==', 1, "count() ok after group_by on related column with a having" ); $rs = $schema->resultset("Artist")->search( { 'cds.title' => 'Spoonful of bees', @@ -260,8 +257,7 @@ SKIP: { is($rs->next->name, 'Caterwauler McCrae', "Correct artist returned"); -my $queries; -$schema->storage->debugcb(sub { $queries++ }); +$queries = 0; $schema->storage->debug(1); my $tree_like = @@ -281,6 +277,25 @@ $schema->storage->debug(0); cmp_ok($queries, '==', 1, 'Only one query run'); +# has_many resulting in an additional select if no records available despite prefetch +my $track = $schema->resultset("Artist")->create( { + artistid => 4, + name => 'Artist without CDs', +} ); + +$queries = 0; +$schema->storage->debug(1); + +my $artist_without_cds = $schema->resultset("Artist")->find(4, { + join => [qw/ cds /], + prefetch => [qw/ cds /], +}); +my @no_cds = $artist_without_cds->cds; + +is($queries, 1, 'prefetch ran only 1 sql statement'); + +$schema->storage->debug(0); + } # end run_tests 1;