X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=t%2Frun%2F16joins.tl;h=15603aa9f8f4f3aa113e400a197914dabc3f8e40;hb=0823196cc624de941880cecd19588c3bac024e73;hp=3ea71f1898e1b0005242f565ec993e6b3c1326f7;hpb=c5b7d79941cd6942aeec1e81e1d4f7f9ad7eb62f;p=dbsrgits%2FDBIx-Class.git diff --git a/t/run/16joins.tl b/t/run/16joins.tl index 3ea71f1..15603aa 100644 --- a/t/run/16joins.tl +++ b/t/run/16joins.tl @@ -7,7 +7,19 @@ BEGIN { eval "use DBD::SQLite"; plan $@ ? ( skip_all => 'needs DBD::SQLite for testing' ) - : ( tests => 33 ); + : ( tests => 44 ); +} + +# 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 @@ -61,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'); @@ -69,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'); @@ -78,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'); @@ -89,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' } }); @@ -102,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; @@ -120,21 +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 columns attr +my $cd = $schema->resultset('CD')->find(1, + { + 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( {}, @@ -150,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; -my $cd = $schema->resultset('CD')->find(1, { prefetch => 'artist' }); +$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( {}, @@ -213,7 +214,11 @@ $rs = $schema->resultset("CD")->search( { group_by => [qw/ title me.cdid /] } ); -cmp_ok( $rs->count, '==', 5, "count() ok after group_by on main pk" ); +SKIP: { + skip "SQLite < 3.2.6 doesn't understand COUNT(DISTINCT())", 1 + if $is_broken_sqlite; + cmp_ok( $rs->count, '==', 5, "count() ok after group_by on main pk" ); +} cmp_ok( scalar $rs->all, '==', 5, "all() returns same count as count() after group_by on main pk" ); @@ -222,9 +227,75 @@ $rs = $schema->resultset("CD")->search( { join => [qw/ artist /], group_by => [qw/ artist.name /] } ); -cmp_ok( $rs->count, '==', 3, "count() ok after group_by on related column" ); +SKIP: { + skip "SQLite < 3.2.6 doesn't understand COUNT(DISTINCT())", 1 + if $is_broken_sqlite; + 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', + 'cds_2.title' => 'Forkful of bees' }, + { join => [ 'cds', 'cds' ] }); + +SKIP: { + skip "SQLite < 3.2.6 doesn't understand COUNT(DISTINCT())", 1 + if $is_broken_sqlite; + cmp_ok($rs->count, '==', 1, "single artist returned from multi-join"); } +is($rs->next->name, 'Caterwauler McCrae', "Correct artist returned"); + +$queries = 0; +$schema->storage->debug(1); + +my $tree_like = + $schema->resultset('TreeLike')->find(4, + { join => { parent => { parent => 'parent' } }, + prefetch => { parent => { parent => 'parent' } } }); + +is($tree_like->name, 'quux', 'Bottom of tree ok'); +$tree_like = $tree_like->parent; +is($tree_like->name, 'baz', 'First level up ok'); +$tree_like = $tree_like->parent; +is($tree_like->name, 'bar', 'Second level up ok'); +$tree_like = $tree_like->parent; +is($tree_like->name, 'foo', 'Third level up ok'); + +$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;