| Commit | Line | Data |
|---|
| 908aa1bb |
1 | use strict; |
| 2 | use warnings; |
| 79adc44f |
3 | no warnings 'exiting'; |
| 908aa1bb |
4 | |
| 5 | use Test::More; |
| 52864fbd |
6 | use Test::Deep; |
| 908aa1bb |
7 | use lib qw(t/lib); |
| 0844bb39 |
8 | use Test::Exception; |
| 9 | |
| 908aa1bb |
10 | use DBICTest; |
| 11 | |
| 12 | my $schema = DBICTest->init_schema(no_populate => 1); |
| 13 | |
| 742280c7 |
14 | $schema->resultset('Artist')->create({ name => 'JMJ', cds => [{ |
| 15 | title => 'Magnetic Fields', |
| 16 | year => 1981, |
| 17 | genre => { name => 'electro' }, |
| 18 | tracks => [ |
| 19 | { title => 'm1' }, |
| 20 | { title => 'm2' }, |
| 21 | { title => 'm3' }, |
| 22 | { title => 'm4' }, |
| 23 | ], |
| 24 | } ] }); |
| 25 | |
| 908aa1bb |
26 | $schema->resultset('CD')->create({ |
| 27 | title => 'Equinoxe', |
| 28 | year => 1978, |
| 29 | artist => { name => 'JMJ' }, |
| 30 | genre => { name => 'electro' }, |
| 31 | tracks => [ |
| 32 | { title => 'e1' }, |
| 33 | { title => 'e2' }, |
| 34 | { title => 'e3' }, |
| 35 | ], |
| 36 | single_track => { |
| 37 | title => 'o1', |
| 38 | cd => { |
| 39 | title => 'Oxygene', |
| 40 | year => 1976, |
| 742280c7 |
41 | artist => { name => 'JMJ' }, |
| 908aa1bb |
42 | tracks => [ |
| 43 | { title => 'o2', position => 2}, # the position should not be needed here, bug in MC |
| 44 | ], |
| 45 | }, |
| 46 | }, |
| 47 | }); |
| 48 | |
| ce556881 |
49 | $schema->resultset('CD')->create({ artist => 1, year => 1977, title => "fuzzy_1" }); |
| 50 | |
| 79adc44f |
51 | $schema->resultset('Artist')->create({ name => "${_}_cdless" }) |
| 52 | for (qw( Z A )); |
| 908aa1bb |
53 | |
| 79adc44f |
54 | # subs at the end of the test refer to this |
| 55 | my $native_inflator; |
| 56 | |
| 57 | ### TESTS START |
| 58 | # run entire test twice - with and without "native inflator" |
| 59 | INFTYPE: for ('', '(native inflator)') { |
| 60 | |
| 61 | $native_inflator = $_; |
| 62 | |
| 63 | cmp_structures( |
| 64 | rs_contents( $schema->resultset ('CD')->search_rs ({}, { |
| 65 | prefetch => { single_track => { cd => 'artist' } }, |
| 66 | order_by => 'me.cdid', |
| 67 | }) ), |
| 908aa1bb |
68 | [ |
| 79adc44f |
69 | [ |
| 70 | { cdid => 1, single_track => undef, artist => 1, genreid => 1, year => 1981, title => "Magnetic Fields" }, |
| 71 | { single_track => code(sub { null_branch ( \@_, [ |
| 72 | { trackid => undef, title => undef, position => undef, cd => undef, last_updated_at => undef, last_updated_on => undef }, |
| 73 | { cd => code(sub { null_branch ( \@_, [ |
| 74 | { cdid => undef, single_track => undef, artist => undef, genreid => undef, year => undef, title => undef }, |
| 75 | { |
| 76 | artist => code(sub { null_branch ( \@_, [ |
| 77 | { artistid => undef, name => undef, charfield => undef, rank => undef } |
| 78 | ] ) } ) |
| 79 | } |
| 80 | ] ) } ) } |
| 81 | ] ) } ) } |
| 82 | ], |
| 83 | [ |
| 84 | { cdid => 2, single_track => undef, artist => 1, genreid => undef, year => 1976, title => "Oxygene" }, |
| 85 | { single_track => code(sub { null_branch ( \@_, [ |
| 86 | { trackid => undef, title => undef, position => undef, cd => undef, last_updated_at => undef, last_updated_on => undef }, |
| 87 | { cd => code(sub { null_branch ( \@_, [ |
| 88 | { cdid => undef, single_track => undef, artist => undef, genreid => undef, year => undef, title => undef }, |
| 89 | { |
| 90 | artist => code(sub { null_branch ( \@_, [ |
| 91 | { artistid => undef, name => undef, charfield => undef, rank => undef } |
| 92 | ] ) } ) |
| 93 | } |
| 94 | ] ) } ) } |
| 95 | ] ) } ) } |
| 96 | ], |
| 97 | [ |
| 98 | { cdid => 3, single_track => 6, artist => 1, genreid => 1, year => 1978, title => "Equinoxe" }, |
| 99 | { single_track => [ |
| 100 | { trackid => 6, title => 'o1', position => 1, cd => 2, last_updated_at => undef, last_updated_on => undef }, |
| 101 | { cd => [ |
| 102 | { cdid => 2, single_track => undef, artist => 1, genreid => undef, year => 1976, title => "Oxygene" }, |
| 103 | { |
| 104 | artist => [ |
| 105 | { artistid => 1, name => 'JMJ', charfield => undef, rank => 13 } |
| 106 | ] |
| 107 | } |
| 108 | ] } |
| 908aa1bb |
109 | ] } |
| 79adc44f |
110 | ], |
| 111 | [ |
| 112 | { cdid => 4, single_track => undef, artist => 1, genreid => undef, year => 1977, title => "fuzzy_1" }, |
| 113 | { single_track => code(sub { null_branch ( \@_, [ |
| 114 | { trackid => undef, title => undef, position => undef, cd => undef, last_updated_at => undef, last_updated_on => undef }, |
| 115 | { cd => code(sub { null_branch ( \@_, [ |
| 116 | { cdid => undef, single_track => undef, artist => undef, genreid => undef, year => undef, title => undef }, |
| 117 | { |
| 118 | artist => code(sub { null_branch ( \@_, [ |
| 119 | { artistid => undef, name => undef, charfield => undef, rank => undef } |
| 120 | ] ) } ) |
| 121 | } |
| 122 | ] ) } ) } |
| 123 | ] ) } ) } |
| 124 | ], |
| ce556881 |
125 | ], |
| 79adc44f |
126 | "Simple 1:1 descend with classic prefetch $native_inflator" |
| 127 | ); |
| ce556881 |
128 | |
| 79adc44f |
129 | cmp_structures( |
| 130 | rs_contents( $schema->resultset ('CD')->search_rs ({}, { |
| 131 | join => { single_track => { cd => 'artist' } }, |
| 132 | columns => [ |
| 133 | { 'year' => 'me.year' }, |
| 134 | { 'genreid' => 'me.genreid' }, |
| 135 | { 'single_track.cd.artist.artistid' => 'artist.artistid' }, |
| 136 | { 'title' => 'me.title' }, |
| 137 | { 'artist' => 'me.artist' }, |
| 138 | ], |
| 139 | order_by => 'me.cdid', |
| 140 | }) ), |
| 908aa1bb |
141 | [ |
| 79adc44f |
142 | [ |
| 143 | { artist => 1, genreid => 1, year => 1981, title => "Magnetic Fields" }, |
| 144 | { single_track => code(sub { null_branch ( \@_, [ |
| 908aa1bb |
145 | undef, |
| 79adc44f |
146 | { cd => [ |
| 147 | undef, |
| 148 | { |
| 149 | artist => [ |
| 150 | { artistid => undef } |
| 151 | ] |
| 152 | } |
| 153 | ] } |
| 154 | ] ) } ) } |
| 155 | ], |
| 156 | [ |
| 157 | { artist => 1, genreid => undef, year => 1976, title => "Oxygene" }, |
| 158 | { single_track => code(sub { null_branch ( \@_, [ |
| 908aa1bb |
159 | undef, |
| 79adc44f |
160 | { cd => [ |
| 161 | undef, |
| 162 | { |
| 163 | artist => [ |
| 164 | { artistid => undef } |
| 165 | ] |
| 166 | } |
| 167 | ] } |
| 168 | ] ) } ) } |
| 169 | ], |
| 170 | [ |
| 171 | { artist => 1, genreid => 1, year => 1978, title => "Equinoxe" }, |
| 172 | { single_track => [ |
| 908aa1bb |
173 | undef, |
| 79adc44f |
174 | { cd => [ |
| 175 | undef, |
| 176 | { |
| 177 | artist => [ |
| 178 | { artistid => 1 } |
| 179 | ] |
| 180 | } |
| 181 | ] } |
| 908aa1bb |
182 | ] } |
| 79adc44f |
183 | ], |
| 184 | [ |
| 185 | { artist => 1, genreid => undef, year => 1977, title => "fuzzy_1" }, |
| 186 | { single_track => code(sub { null_branch ( \@_, [ |
| ce556881 |
187 | undef, |
| 79adc44f |
188 | { cd => [ |
| 189 | undef, |
| 190 | { |
| 191 | artist => [ |
| 192 | { artistid => undef } |
| 193 | ] |
| 194 | } |
| 195 | ] } |
| 196 | ] ) } ) } |
| 197 | ], |
| ce556881 |
198 | ], |
| 79adc44f |
199 | "Simple 1:1 descend with missing selectors $native_inflator", |
| 200 | ); |
| ce556881 |
201 | |
| 79adc44f |
202 | cmp_structures( |
| 203 | rs_contents( $schema->resultset ('CD')->search_rs ({}, { |
| 204 | prefetch => [ { single_track => { cd => { artist => { cds => 'tracks' } } } } ], |
| 205 | order_by => [qw/me.cdid tracks.trackid/], |
| 206 | }) ), |
| 908aa1bb |
207 | [ |
| 79adc44f |
208 | [ |
| 209 | { cdid => 1, single_track => undef, artist => 1, genreid => 1, year => 1981, title => "Magnetic Fields" }, |
| 210 | { single_track => code(sub { null_collapsed_branch ( \@_, [ |
| 211 | { trackid => undef, title => undef, position => undef, cd => undef, last_updated_at => undef, last_updated_on => undef }, |
| 212 | { cd => [ |
| 213 | { cdid => undef, single_track => undef, artist => undef, genreid => undef, year => undef, title => undef }, |
| 214 | { |
| 215 | artist => [ |
| 216 | { artistid => undef, name => undef, charfield => undef, rank => undef }, |
| 217 | { cds => code(sub { null_collapsed_branch ( \@_, [ [ |
| 218 | { cdid => undef, single_track => undef, artist => undef, genreid => undef, year => undef, title => undef }, |
| 219 | { tracks => code(sub { null_collapsed_branch ( \@_, [ [ |
| 220 | { trackid => undef, title => undef, position => undef, cd => undef, last_updated_at => undef, last_updated_on => undef }, |
| 221 | ] ] ) } ) }, |
| 222 | ] ] ) } ) }, |
| 223 | ], |
| 224 | }, |
| 225 | ] }, |
| 226 | ] ) } ) }, |
| 227 | ], |
| 228 | [ |
| 229 | { cdid => 2, single_track => undef, artist => 1, genreid => undef, year => 1976, title => "Oxygene" }, |
| 230 | { single_track => code(sub { null_collapsed_branch ( \@_, [ |
| 231 | { trackid => undef, title => undef, position => undef, cd => undef, last_updated_at => undef, last_updated_on => undef }, |
| 232 | { cd => [ |
| 233 | { cdid => undef, single_track => undef, artist => undef, genreid => undef, year => undef, title => undef }, |
| 234 | { |
| 235 | artist => [ |
| 236 | { artistid => undef, name => undef, charfield => undef, rank => undef }, |
| 237 | { cds => code(sub { null_collapsed_branch ( \@_, [ [ |
| 238 | { cdid => undef, single_track => undef, artist => undef, genreid => undef, year => undef, title => undef }, |
| 239 | { tracks => code(sub { null_collapsed_branch ( \@_, [ [ |
| 240 | { trackid => undef, title => undef, position => undef, cd => undef, last_updated_at => undef, last_updated_on => undef }, |
| 241 | ] ] ) } ) }, |
| 242 | ] ] ) } ) }, |
| 243 | ], |
| 244 | }, |
| 245 | ] }, |
| 246 | ] ) } ) }, |
| 247 | ], |
| 248 | [ |
| 249 | { cdid => 3, single_track => 6, artist => 1, genreid => 1, year => 1978, title => "Equinoxe" }, |
| 250 | { single_track => [ |
| 251 | { trackid => 6, title => 'o1', position => 1, cd => 2, last_updated_at => undef, last_updated_on => undef }, |
| 252 | { cd => [ |
| 253 | { cdid => 2, single_track => undef, artist => 1, genreid => undef, year => 1976, title => "Oxygene" }, |
| 254 | { |
| 255 | artist => [ |
| 256 | { artistid => 1, name => 'JMJ', charfield => undef, rank => 13 }, |
| 257 | { cds => [ |
| 258 | [ |
| 259 | { cdid => 4, single_track => undef, artist => 1, genreid => undef, year => 1977, title => "fuzzy_1" }, |
| 260 | { tracks => code(sub { null_collapsed_branch ( \@_, [ |
| 261 | [ { trackid => undef, title => undef, position => undef, cd => undef, last_updated_at => undef, last_updated_on => undef } ], |
| 262 | ] ) } ) }, |
| 263 | ], |
| 264 | [ |
| 265 | { cdid => 1, single_track => undef, artist => 1, genreid => 1, year => 1981, title => "Magnetic Fields" }, |
| 266 | { tracks => [ |
| 267 | [ { trackid => 1, title => 'm1', position => 1, cd => 1, last_updated_at => undef, last_updated_on => undef } ], |
| 268 | [ { trackid => 2, title => 'm2', position => 2, cd => 1, last_updated_at => undef, last_updated_on => undef } ], |
| 269 | [ { trackid => 3, title => 'm3', position => 3, cd => 1, last_updated_at => undef, last_updated_on => undef } ], |
| 270 | [ { trackid => 4, title => 'm4', position => 4, cd => 1, last_updated_at => undef, last_updated_on => undef } ], |
| 271 | ]}, |
| 272 | ], |
| 273 | [ |
| 274 | { cdid => 2, single_track => undef, artist => 1, genreid => undef, year => 1976, title => "Oxygene" }, |
| 275 | { tracks => [ |
| 276 | [ { trackid => 5, title => 'o2', position => 2, cd => 2, last_updated_at => undef, last_updated_on => undef } ], |
| 277 | [ { trackid => 6, title => 'o1', position => 1, cd => 2, last_updated_at => undef, last_updated_on => undef } ], |
| 278 | ]}, |
| 279 | ], |
| 280 | [ |
| 281 | { cdid => 3, single_track => 6, artist => 1, genreid => 1, year => 1978, title => "Equinoxe" }, |
| 282 | { tracks => [ |
| 283 | [ { trackid => 7, title => 'e1', position => 1, cd => 3, last_updated_at => undef, last_updated_on => undef } ], |
| 284 | [ { trackid => 8, title => 'e2', position => 2, cd => 3, last_updated_at => undef, last_updated_on => undef } ], |
| 285 | [ { trackid => 9, title => 'e3', position => 3, cd => 3, last_updated_at => undef, last_updated_on => undef } ], |
| 286 | ]}, |
| 287 | ], |
| 288 | ]}, |
| 289 | ] |
| 290 | } |
| 291 | ] } |
| ce556881 |
292 | ] } |
| 79adc44f |
293 | ], |
| 294 | [ |
| 295 | { cdid => 4, single_track => undef, artist => 1, genreid => undef, year => 1977, title => "fuzzy_1" }, |
| 296 | { single_track => code(sub { null_collapsed_branch ( \@_, [ |
| 297 | { trackid => undef, title => undef, position => undef, cd => undef, last_updated_at => undef, last_updated_on => undef }, |
| 298 | { cd => [ |
| 299 | { cdid => undef, single_track => undef, artist => undef, genreid => undef, year => undef, title => undef }, |
| 300 | { |
| 301 | artist => [ |
| 302 | { artistid => undef, name => undef, charfield => undef, rank => undef }, |
| 303 | { cds => code(sub { null_collapsed_branch ( \@_, [ [ |
| 304 | { cdid => undef, single_track => undef, artist => undef, genreid => undef, year => undef, title => undef }, |
| 305 | { tracks => code(sub { null_collapsed_branch ( \@_, [ [ |
| 306 | { trackid => undef, title => undef, position => undef, cd => undef, last_updated_at => undef, last_updated_on => undef }, |
| 307 | ] ] ) } ) }, |
| 308 | ] ] ) } ) }, |
| 309 | ], |
| 310 | }, |
| 311 | ] }, |
| 312 | ] ) } ) }, |
| 313 | ], |
| ce556881 |
314 | ], |
| 79adc44f |
315 | "Collapsing 1:1 ending in chained has_many with classic prefetch $native_inflator", |
| 316 | ); |
| 908aa1bb |
317 | |
| 79adc44f |
318 | cmp_structures ( |
| 319 | rs_contents( $schema->resultset ('Artist')->search_rs ({}, { |
| 320 | join => { cds => 'tracks' }, |
| 321 | '+columns' => [ |
| 322 | (map { "cds.$_" } $schema->source('CD')->columns), |
| 323 | (map { +{ "cds.tracks.$_" => "tracks.$_" } } $schema->source('Track')->columns), |
| 324 | ], |
| 325 | order_by => [qw/cds.cdid tracks.trackid me.name/], |
| 326 | }) ), |
| 908aa1bb |
327 | [ |
| 79adc44f |
328 | [ |
| 329 | { artistid => 3, name => 'A_cdless', charfield => undef, rank => 13 }, |
| 330 | { cds => code(sub { null_branch ( \@_, [ |
| 331 | { cdid => undef, single_track => undef, artist => undef, genreid => undef, year => undef, title => undef }, |
| 332 | { tracks => code(sub { null_branch ( \@_, [ |
| 333 | { trackid => undef, title => undef, position => undef, cd => undef, last_updated_at => undef, last_updated_on => undef }, |
| 334 | ] ) } ) }, |
| 335 | ] ) } ) }, |
| 336 | ], |
| 337 | [ |
| 338 | { artistid => 2, name => 'Z_cdless', charfield => undef, rank => 13 }, |
| 339 | { cds => code(sub { null_branch ( \@_, [ |
| 340 | { cdid => undef, single_track => undef, artist => undef, genreid => undef, year => undef, title => undef }, |
| 341 | { tracks => code(sub { null_branch ( \@_, [ |
| 342 | { trackid => undef, title => undef, position => undef, cd => undef, last_updated_at => undef, last_updated_on => undef }, |
| 343 | ] ) } ) }, |
| 344 | ] ) } ) }, |
| 345 | ], |
| 346 | [ |
| 347 | { artistid => 1, name => 'JMJ', charfield => undef, rank => 13 }, |
| 348 | { cds => [ |
| 349 | { cdid => 1, single_track => undef, artist => 1, genreid => 1, year => 1981, title => "Magnetic Fields" }, |
| 350 | { tracks => [ |
| 351 | { trackid => 1, title => 'm1', position => 1, cd => 1, last_updated_at => undef, last_updated_on => undef }, |
| 352 | ]}, |
| 908aa1bb |
353 | ]}, |
| 79adc44f |
354 | ], |
| 355 | [ |
| 356 | { artistid => 1, name => 'JMJ', charfield => undef, rank => 13 }, |
| 357 | { cds => [ |
| 358 | { cdid => 1, single_track => undef, artist => 1, genreid => 1, year => 1981, title => "Magnetic Fields" }, |
| 359 | { tracks => [ |
| 360 | { trackid => 2, title => 'm2', position => 2, cd => 1, last_updated_at => undef, last_updated_on => undef }, |
| 361 | ]}, |
| 908aa1bb |
362 | ]}, |
| 79adc44f |
363 | ], |
| 364 | [ |
| 365 | { artistid => 1, name => 'JMJ', charfield => undef, rank => 13 }, |
| 366 | { cds => [ |
| 367 | { cdid => 1, single_track => undef, artist => 1, genreid => 1, year => 1981, title => "Magnetic Fields" }, |
| 368 | { tracks => [ |
| 369 | { trackid => 3, title => 'm3', position => 3, cd => 1, last_updated_at => undef, last_updated_on => undef }, |
| 370 | ]}, |
| 908aa1bb |
371 | ]}, |
| 79adc44f |
372 | ], |
| 373 | [ |
| 374 | { artistid => 1, name => 'JMJ', charfield => undef, rank => 13 }, |
| 375 | { cds => [ |
| 376 | { cdid => 1, single_track => undef, artist => 1, genreid => 1, year => 1981, title => "Magnetic Fields" }, |
| 377 | { tracks => [ |
| 378 | { trackid => 4, title => 'm4', position => 4, cd => 1, last_updated_at => undef, last_updated_on => undef }, |
| 379 | ]}, |
| 908aa1bb |
380 | ]}, |
| 79adc44f |
381 | ], |
| 382 | [ |
| 383 | { artistid => 1, name => 'JMJ', charfield => undef, rank => 13 }, |
| 384 | { cds => [ |
| 385 | { cdid => 2, single_track => undef, artist => 1, genreid => undef, year => 1976, title => "Oxygene" }, |
| 386 | { tracks => [ |
| 387 | { trackid => 5, title => 'o2', position => 2, cd => 2, last_updated_at => undef, last_updated_on => undef }, |
| 388 | ]}, |
| 908aa1bb |
389 | ]}, |
| 79adc44f |
390 | ], |
| 391 | [ |
| 392 | { artistid => 1, name => 'JMJ', charfield => undef, rank => 13 }, |
| 393 | { cds => [ |
| 394 | { cdid => 2, single_track => undef, artist => 1, genreid => undef, year => 1976, title => "Oxygene" }, |
| 395 | { tracks => [ |
| 396 | { trackid => 6, title => 'o1', position => 1, cd => 2, last_updated_at => undef, last_updated_on => undef }, |
| 397 | ]}, |
| 908aa1bb |
398 | ]}, |
| 79adc44f |
399 | ], |
| 400 | [ |
| 401 | { artistid => 1, name => 'JMJ', charfield => undef, rank => 13 }, |
| 402 | { cds => [ |
| 403 | { cdid => 3, single_track => 6, artist => 1, genreid => 1, year => 1978, title => "Equinoxe" }, |
| 404 | { tracks => [ |
| 405 | { trackid => 7, title => 'e1', position => 1, cd => 3, last_updated_at => undef, last_updated_on => undef }, |
| 406 | ]}, |
| 908aa1bb |
407 | ]}, |
| 79adc44f |
408 | ], |
| 409 | [ |
| 410 | { artistid => 1, name => 'JMJ', charfield => undef, rank => 13 }, |
| 411 | { cds => [ |
| 412 | { cdid => 3, single_track => 6, artist => 1, genreid => 1, year => 1978, title => "Equinoxe" }, |
| 413 | { tracks => [ |
| 414 | { trackid => 8, title => 'e2', position => 2, cd => 3, last_updated_at => undef, last_updated_on => undef }, |
| 415 | ]}, |
| 908aa1bb |
416 | ]}, |
| 79adc44f |
417 | ], |
| 418 | [ |
| 419 | { artistid => 1, name => 'JMJ', charfield => undef, rank => 13 }, |
| 420 | { cds => [ |
| 421 | { cdid => 3, single_track => 6, artist => 1, genreid => 1, year => 1978, title => "Equinoxe" }, |
| 422 | { tracks => [ |
| 423 | { trackid => 9, title => 'e3', position => 3, cd => 3, last_updated_at => undef, last_updated_on => undef }, |
| 424 | ]}, |
| 908aa1bb |
425 | ]}, |
| 79adc44f |
426 | ], |
| 427 | [ |
| 428 | { artistid => 1, name => 'JMJ', charfield => undef, rank => 13 }, |
| 429 | { cds => [ |
| 430 | { cdid => 4, single_track => undef, artist => 1, genreid => undef, year => 1977, title => "fuzzy_1" }, |
| 431 | { tracks => code(sub { null_branch ( \@_, [ |
| 432 | { trackid => undef, title => undef, position => undef, cd => undef, last_updated_at => undef, last_updated_on => undef }, |
| 433 | ] ) } ) }, |
| 434 | ]}, |
| 435 | ], |
| 908aa1bb |
436 | ], |
| 79adc44f |
437 | "Non-Collapsing chained has_many $native_inflator", |
| 438 | ); |
| 439 | |
| 440 | cmp_structures ( |
| 441 | rs_contents( $schema->resultset ('Artist')->search_rs ({}, { |
| 442 | collapse => 1, |
| 443 | join => 'cds', |
| 444 | columns => [qw( cds.title cds.artist )], |
| 445 | order_by => [qw( me.name cds.title )], |
| 446 | }) ), |
| ce556881 |
447 | [ |
| 79adc44f |
448 | [ |
| 449 | undef, |
| 450 | { cds => code(sub { null_collapsed_branch ( \@_, [ |
| 451 | [ { artist => undef, title => undef } ] |
| 452 | ] ) } ) }, |
| 453 | ], |
| 454 | [ |
| 455 | undef, |
| 456 | { cds => [ |
| 457 | [ { artist => 1, title => "Equinoxe" } ], |
| 458 | [ { artist => 1, title => "Magnetic Fields" } ], |
| 459 | [ { artist => 1, title => "Oxygene" } ], |
| 460 | [ { artist => 1, title => "fuzzy_1" } ], |
| 461 | ] } |
| 462 | ], |
| 463 | [ |
| 464 | undef, |
| 465 | { cds => code(sub { null_collapsed_branch ( \@_, [ |
| 466 | [ { artist => undef, title => undef } ] |
| 467 | ] ) } ) }, |
| 468 | ], |
| ce556881 |
469 | ], |
| 79adc44f |
470 | "Expected output of collapsing 1:M with empty root selection $native_inflator", |
| 471 | ); |
| 472 | } |
| ce556881 |
473 | |
| 79adc44f |
474 | sub null_branch { |
| 475 | cmp_deeply( |
| 476 | $_[0][0], |
| 477 | $native_inflator ? undef : bless( $_[1], $DBIx::Class::ResultSource::RowParser::Util::null_branch_class ), |
| 478 | ); |
| 479 | } |
| 480 | sub null_collapsed_branch { |
| 481 | cmp_deeply( |
| 482 | $_[0][0], |
| 483 | $native_inflator ? [] : bless( $_[1], $DBIx::Class::ResultSource::RowParser::Util::null_branch_class ), |
| 484 | ); |
| 485 | } |
| aa1d8a87 |
486 | |
| 79adc44f |
487 | { |
| 488 | package DBICTest::_IRCapture; |
| 489 | sub inflate_result { [@_[2,3]] }; |
| 490 | } |
| 491 | |
| 492 | sub rs_contents { |
| 493 | my $rs = shift; |
| 494 | $rs->result_class('DBICTest::_IRCapture'); |
| 495 | die 'eeeeek - preprocessed $rs' if defined $rs->{_result_inflator}{is_core_row}; |
| 496 | $rs->{_result_inflator}{is_core_row} = 1 if $native_inflator; |
| 497 | [$rs->all], |
| 498 | } |
| aa1d8a87 |
499 | |
| ce556881 |
500 | sub cmp_structures { |
| 501 | my ($left, $right, $msg) = @_; |
| 502 | |
| ce556881 |
503 | local $Test::Builder::Level = $Test::Builder::Level + 1; |
| 79adc44f |
504 | cmp_deeply($left, $right, $msg||()) or next INFTYPE; |
| ce556881 |
505 | } |
| 506 | |
| 0844bb39 |
507 | |
| 30681c23 |
508 | { |
| 509 | package DBICTest::_DoubleResult; |
| 510 | |
| 511 | sub inflate_result { |
| 512 | my $class = shift; |
| 513 | return map { DBIx::Class::ResultClass::HashRefInflator->inflate_result(@_) } (1,2); |
| 514 | } |
| 515 | } |
| 516 | |
| 517 | my $oxygene_rs = $schema->resultset('CD')->search({ 'me.title' => 'Oxygene' }); |
| 518 | |
| 519 | is_deeply( |
| 520 | [ $oxygene_rs->search({}, { result_class => 'DBICTest::_DoubleResult' })->all ], |
| 521 | [ ({ $oxygene_rs->single->get_columns }) x 2 ], |
| 522 | ); |
| 523 | |
| 524 | is_deeply( |
| 525 | [ $oxygene_rs->search({}, { |
| 526 | result_class => 'DBICTest::_DoubleResult', prefetch => [qw(artist tracks)], |
| 527 | order_by => [qw(me.cdid tracks.title)], |
| 528 | })->all ], |
| 529 | [ (@{$oxygene_rs->search({}, { |
| 530 | prefetch=> [qw(artist tracks)], |
| 531 | order_by => [qw(me.cdid tracks.title)], |
| 532 | })->all_hri}) x 2 ], |
| 533 | ); |
| 534 | |
| 0844bb39 |
535 | |
| 536 | { |
| 537 | package DBICTest::_DieTrying; |
| 538 | |
| 539 | sub inflate_result { |
| 540 | die "nyah nyah nyah"; |
| 541 | } |
| 542 | } |
| 543 | |
| 544 | throws_ok { |
| 545 | $schema->resultset('CD')->search({}, { result_class => 'DBICTest::_DieTrying' })->all |
| 546 | } qr/nyah nyah nyah/, 'Exception in custom inflate_result propagated correctly'; |
| 547 | |
| 548 | |
| 908aa1bb |
549 | done_testing; |
projects / dbsrgits/DBIx-Class.git / blame