From: Peter Rabbitson Date: Sun, 28 Jun 2009 12:39:54 +0000 (+0000) Subject: Proper prefetch+group test X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=commitdiff_plain;h=0c5ea4491942a7dc747192128dad3da7c0daf34b;p=dbsrgits%2FDBIx-Class-Historic.git Proper prefetch+group test --- diff --git a/t/prefetch/grouped.t b/t/prefetch/grouped.t new file mode 100644 index 0000000..526fc45 --- /dev/null +++ b/t/prefetch/grouped.t @@ -0,0 +1,201 @@ +use strict; +use warnings; +use Test::More; + +use lib qw(t/lib); +use DBICTest; +use DBIC::SqlMakerTest; + +#plan tests => 6; +plan 'no_plan'; + +my $schema = DBICTest->init_schema(); + +my $cd_rs = $schema->resultset('CD')->search ( + { 'tracks.cd' => { '!=', undef } }, + { prefetch => 'tracks' }, +); + +# Database sanity check +is($cd_rs->count, 5, 'CDs with tracks count'); +for ($cd_rs->all) { + is ($_->tracks->count, 3, '3 tracks for CD' . $_->id ); +} + +# Test a belongs_to prefetch of a has_many +{ + my $track_rs = $schema->resultset ('Track')->search ( + { 'me.cd' => { -in => [ $cd_rs->get_column ('cdid')->all ] } }, + { + # the select/as is deliberately silly to test both funcs and refs below + select => [ + 'me.cd', + \ 'COUNT (me.trackid) AS track_count', + { count => 'me.trackid' }, + ], + as => [qw/ + cd + track_count + track_count_2 + /], + group_by => [qw/me.cd/], + prefetch => 'cd', + }, + ); + + is($track_rs->count, 5, 'Prefetched count with groupby'); + is($track_rs->all, 5, 'Prefetched objects with groupby'); + + { + my $query_cnt = 0; + $schema->storage->debugcb ( sub { $query_cnt++ } ); + + $track_rs->reset; + while (my $collapsed_track = $track_rs->next) { + + my $cdid = $collapsed_track->get_column('cd'); + is($collapsed_track->get_column('track_count'), 3, "Correct count of tracks for CD $cdid" ); + ok($collapsed_track->cd->title, "Prefetched title for CD $cdid" ); + } + + is ($query_cnt, 0, 'No queries on prefetched titles'); + $schema->storage->debugcb (undef); + } + + # Test sql by hand, as the sqlite db will simply paper over + # improper group/select combinations + # + # the exploded IN needs fixing below, coming in another branch + # + is_same_sql_bind ( + $track_rs->count_rs->as_query, + '( + SELECT COUNT( * ) + FROM ( + SELECT me.cd + FROM track me + JOIN cd cd ON cd.cdid = me.cd + WHERE ( me.cd IN ( ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? ) ) + GROUP BY me.cd + ) + count_subq + )', + [ map { [ 'me.cd' => $_] } ($cd_rs->get_column ('cdid')->all) ], + 'count() query generated expected SQL', + ); + + # the double-count is deliberate + is_same_sql_bind ( + $track_rs->as_query, + '( + SELECT me.cd, me.track_count, me.track_count_2, cd.cdid, cd.artist, cd.title, cd.year, cd.genreid, cd.single_track + FROM ( + SELECT me.cd, COUNT (me.trackid) AS track_count, COUNT (me.trackid) AS track_count_2 + FROM track me + WHERE ( cd IN ( ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? ) ) + GROUP BY me.cd + ) as me + JOIN cd cd ON cd.cdid = me.cd + WHERE ( me.cd IN ( ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? ) ) + )', + [ map { [ 'me.cd' => $_] } ($cd_rs->get_column ('cdid')->all) ], + 'next() query generated expected SQL', + ); + + + # add an extra track to one of the cds, and then make sure we can get it on top + # (check if limit works) + my $top_cd = $cd_rs->slice (1,1)->next; + $top_cd->create_related ('tracks', { + title => 'over the top', + }); + + my $top_cd_collapsed_track = $track_rs->search ({}, { + rows => 2, + order_by => [ + { -desc => 'track_count' }, + ], + }); + + is ($top_cd_collapsed_track->count, 2); + + is ( + $top_cd->title, + $top_cd_collapsed_track->first->cd->title, + 'Correct collapsed track with prefetched CD returned on top' + ); +} + +# test a has_many/might_have prefetch at the same level +# double-count for now, until we figure out how to do this cleanly +# with a function +# Note that one of the CDs now has 4 tracks instead of 3 +{ + my $most_tracks_rs = $cd_rs->search ({}, { + prefetch => 'liner_notes', # tracks are alredy prefetched + select => ['me.cdid', { count => 'tracks.trackid' } ], + as => [qw/cdid track_count/], + group_by => 'me.cdid', + order_by => { -desc => \ 'COUNT (tracks.trackid)' }, + rows => 2, + }); + + is_same_sql_bind ( + $most_tracks_rs->count_rs->as_query, + '( + SELECT COUNT( * ) + FROM ( + SELECT me.cdid + FROM cd me + LEFT JOIN track tracks ON tracks.cd = me.cdid + LEFT JOIN liner_notes liner_notes ON liner_notes.liner_id = me.cdid + WHERE ( tracks.cd IS NOT NULL ) + GROUP BY me.cdid + LIMIT 2 + ) count_subq + )', + [], + 'count() query generated expected SQL', + ); + + is_same_sql_bind ( + $most_tracks_rs->as_query, + '( + SELECT me.cdid, COUNT( tracks.trackid ), tracks.trackid, tracks.cd, tracks.position, tracks.title, tracks.last_updated_on, tracks.last_updated_at, liner_notes.liner_id, liner_notes.notes + FROM ( + SELECT me.cdid, COUNT( tracks.trackid ) + FROM cd me + LEFT JOIN track tracks ON tracks.cd = me.cdid + WHERE ( tracks.cd IS NOT NULL ) + GROUP BY me.cdid + ORDER BY COUNT (tracks.trackid) DESC, + LIMIT 2 + ) me + LEFT JOIN track tracks ON tracks.cd = me.cdid + LEFT JOIN liner_notes liner_notes ON liner_notes.liner_id = me.cdid + WHERE ( tracks.cd IS NOT NULL ) + ORDER BY COUNT (tracks.trackid) DESC, tracks.cd + )', + [], + 'next() query generated expected SQL', + ); + + is ($most_tracks_rs->count, 2, 'Limit works'); + my $top_cd = $most_tracks_rs->first; + is ($top_cd->id, 2, 'Correct cd fetched on top'); # 2 because of the slice(1,1) above + + my $query_cnt = 0; + $schema->storage->debugcb ( sub { $query_cnt++ } ); + + is ($top_cd->get_column ('track_count'), 4, 'Track count fetched correctly'); + is ($top_cd->tracks->count, 4, 'Count of prefetched tracks rs still correct'); + is ($top_cd->tracks->all, 4, 'Number of prefetched track objects still correct'); + is ( + $top_cd->liner_notes->notes, + 'Buy Whiskey!', + 'Correct liner pre-fetched with top cd', + ); + + is ($query_cnt, 0, 'No queries executed during prefetched data access'); + $schema->storage->debugcb (undef); +}