X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=t%2Fprefetch%2Fcorrelated.t;h=e941b12a99fcbae0113fa1157c08400f46df3a08;hb=86a432d4cc096062e2374f118ce38aa131799d6a;hp=98bc031102c71551010aa761f42fa74d9fa10bcb;hpb=0dadd60d51482230dca8d235d4d1fbd71235904a;p=dbsrgits%2FDBIx-Class.git diff --git a/t/prefetch/correlated.t b/t/prefetch/correlated.t index 98bc031..e941b12 100644 --- a/t/prefetch/correlated.t +++ b/t/prefetch/correlated.t @@ -1,21 +1,21 @@ +BEGIN { do "./t/lib/ANFANG.pm" or die ( $@ || $! ) } + use strict; use warnings; use Test::More; use Test::Deep; -use lib qw(t/lib); -use DBICTest; -use DBIC::SqlMakerTest; + +use DBICTest ':DiffSQL'; my $schema = DBICTest->init_schema(); -my $orig_debug = $schema->storage->debug; my $cdrs = $schema->resultset('CD')->search({ 'me.artist' => { '!=', 2 }}); my $cd_data = { map { $_->cdid => { siblings => $cdrs->search ({ artist => $_->get_column('artist') })->count - 1, - track_titles => [ map { $_->title } ($_->tracks->all) ], + track_titles => [ sort $_->tracks->get_column('title')->all ], }, } ( $cdrs->all ) }; @@ -36,10 +36,10 @@ is_same_sql_bind( SELECT me.cdid, me.artist, me.title, me.year, me.genreid, me.single_track, (SELECT COUNT( * ) FROM cd siblings - WHERE siblings.artist = me.artist + WHERE me.artist != ? + AND siblings.artist = me.artist AND siblings.cdid != me.cdid AND siblings.cdid != ? - AND me.artist != ? ), tracks.trackid, tracks.cd, tracks.position, tracks.title, tracks.last_updated_on, tracks.last_updated_at FROM cd me @@ -50,12 +50,12 @@ is_same_sql_bind( [ # subselect - [ { sqlt_datatype => 'integer', dbic_colname => 'siblings.cdid' } - => 23414 ], - [ { sqlt_datatype => 'integer', dbic_colname => 'me.artist' } => 2 ], + [ { sqlt_datatype => 'integer', dbic_colname => 'siblings.cdid' } + => 23414 ], + # outher WHERE [ { sqlt_datatype => 'integer', dbic_colname => 'me.artist' } => 2 ], @@ -63,26 +63,19 @@ is_same_sql_bind( 'Expected SQL on correlated realiased subquery' ); -my $queries = 0; -$schema->storage->debugcb(sub { $queries++; }); -$schema->storage->debug(1); - -cmp_deeply ( - { map - { $_->cdid => { - track_titles => [ map { $_->title } ($_->tracks->all) ], - siblings => $_->get_column ('sibling_count'), - } } - $c_rs->all - }, - $cd_data, - 'Proper information retrieved from correlated subquery' -); - -is ($queries, 1, 'Only 1 query fired to retrieve everything'); - -$schema->storage->debug($orig_debug); -$schema->storage->debugcb(undef); +$schema->is_executed_querycount( sub { + cmp_deeply ( + { map + { $_->cdid => { + track_titles => [ sort map { $_->title } ($_->tracks->all) ], + siblings => $_->get_column ('sibling_count'), + } } + $c_rs->all + }, + $cd_data, + 'Proper information retrieved from correlated subquery' + ); +}, 1, 'Only 1 query fired to retrieve everything'); # now add an unbalanced select/as pair $c_rs = $c_rs->search ({}, { @@ -102,15 +95,15 @@ is_same_sql_bind( SELECT me.cdid, me.artist, me.title, me.year, me.genreid, me.single_track, (SELECT COUNT( * ) FROM cd siblings - WHERE siblings.artist = me.artist + WHERE me.artist != ? + AND siblings.artist = me.artist AND siblings.cdid != me.cdid AND siblings.cdid != ? - AND me.artist != ? ), (SELECT MIN( year ), MAX( year ) FROM cd siblings - WHERE siblings.artist = me.artist - AND me.artist != ? + WHERE me.artist != ? + AND siblings.artist = me.artist ), tracks.trackid, tracks.cd, tracks.position, tracks.title, tracks.last_updated_on, tracks.last_updated_at FROM cd me @@ -121,12 +114,12 @@ is_same_sql_bind( [ # first subselect - [ { sqlt_datatype => 'integer', dbic_colname => 'siblings.cdid' } - => 23414 ], - [ { sqlt_datatype => 'integer', dbic_colname => 'me.artist' } => 2 ], + [ { sqlt_datatype => 'integer', dbic_colname => 'siblings.cdid' } + => 23414 ], + # second subselect [ { sqlt_datatype => 'integer', dbic_colname => 'me.artist' } => 2 ], @@ -138,6 +131,8 @@ is_same_sql_bind( 'Expected SQL on correlated realiased subquery' ); +$schema->storage->disconnect; + # test for subselect identifier leakage # NOTE - the hodge-podge mix of literal and regular identifuers is *deliberate* for my $quote_names (0,1) { @@ -168,13 +163,17 @@ for my $quote_names (0,1) { ]}, }); + # we are using cds_unordered explicitly above - do the sorting manually + my @results = sort { $a->{artistid} <=> $b->{artistid} } @{$final_query->all_hri}; + @$_ = sort { $a->{cdid} <=> $b->{cdid} } @$_ for map { $_->{cds} } @results; + is_deeply ( - $final_query->all_hri, + \@results, [ { artistid => 1, charfield => undef, max_competition_release => 1998, name => "Caterwauler McCrae", rank => 13, cds => [ - { artist => 1, cdid => 3, genreid => undef, single_track => undef, title => "Caterwaulin' Blues", year => 1997 }, - { artist => 1, cdid => 2, genreid => undef, single_track => undef, title => "Forkful of bees", year => 2001 }, { artist => 1, cdid => 1, genreid => 1, single_track => undef, title => "Spoonful of bees", year => 1999 }, + { artist => 1, cdid => 2, genreid => undef, single_track => undef, title => "Forkful of bees", year => 2001 }, + { artist => 1, cdid => 3, genreid => undef, single_track => undef, title => "Caterwaulin' Blues", year => 1997 }, ] }, { artistid => 2, charfield => undef, max_competition_release => 1997, name => "Random Boy Band", rank => 13, cds => [ { artist => 2, cdid => 4, genreid => undef, single_track => undef, title => "Generic Manufactured Singles", year => 2001 },