Switch as_query testing to direct specification in is_same_sql_bind
[dbsrgits/DBIx-Class-Historic.git] / t / 76joins.t
1 use strict;
2 use warnings;  
3
4 use Test::More;
5 use lib qw(t/lib);
6 use DBICTest;
7 use Data::Dumper;
8 use DBIC::SqlMakerTest;
9
10 my $schema = DBICTest->init_schema();
11
12 my $orig_debug = $schema->storage->debug;
13
14 use IO::File;
15
16 BEGIN {
17     eval "use DBD::SQLite";
18     plan $@
19         ? ( skip_all => 'needs DBD::SQLite for testing' )
20         : ( tests => 33 );
21 }
22
23 # test the abstract join => SQL generator
24 my $sa = new DBIx::Class::SQLAHacks;
25
26 my @j = (
27     { child => 'person' },
28     [ { father => 'person' }, { 'father.person_id' => 'child.father_id' }, ],
29     [ { mother => 'person' }, { 'mother.person_id' => 'child.mother_id' } ],
30 );
31 my $match = 'person child JOIN person father ON ( father.person_id = '
32           . 'child.father_id ) JOIN person mother ON ( mother.person_id '
33           . '= child.mother_id )'
34           ;
35 is_same_sql(
36   $sa->_recurse_from(@j),
37   $match,
38   'join 1 ok'
39 );
40
41 my @j2 = (
42     { mother => 'person' },
43     [   [   { child => 'person' },
44             [   { father             => 'person' },
45                 { 'father.person_id' => 'child.father_id' }
46             ]
47         ],
48         { 'mother.person_id' => 'child.mother_id' }
49     ],
50 );
51 $match = 'person mother JOIN (person child JOIN person father ON ('
52        . ' father.person_id = child.father_id )) ON ( mother.person_id = '
53        . 'child.mother_id )'
54        ;
55 is_same_sql(
56   $sa->_recurse_from(@j2),
57   $match,
58   'join 2 ok'
59 );
60
61
62 my @j3 = (
63     { child => 'person' },
64     [ { father => 'person', -join_type => 'inner' }, { 'father.person_id' => 'child.father_id' }, ],
65     [ { mother => 'person', -join_type => 'inner'  }, { 'mother.person_id' => 'child.mother_id' } ],
66 );
67 $match = 'person child INNER JOIN person father ON ( father.person_id = '
68           . 'child.father_id ) INNER JOIN person mother ON ( mother.person_id '
69           . '= child.mother_id )'
70           ;
71
72 is_same_sql(
73   $sa->_recurse_from(@j3),
74   $match,
75   'join 3 (inner join) ok'
76 );
77
78 my @j4 = (
79     { mother => 'person' },
80     [   [   { child => 'person', -join_type => 'left' },
81             [   { father             => 'person', -join_type => 'right' },
82                 { 'father.person_id' => 'child.father_id' }
83             ]
84         ],
85         { 'mother.person_id' => 'child.mother_id' }
86     ],
87 );
88 $match = 'person mother LEFT JOIN (person child RIGHT JOIN person father ON ('
89        . ' father.person_id = child.father_id )) ON ( mother.person_id = '
90        . 'child.mother_id )'
91        ;
92 is_same_sql(
93   $sa->_recurse_from(@j4),
94   $match,
95   'join 4 (nested joins + join types) ok'
96 );
97
98 my @j5 = (
99     { child => 'person' },
100     [ { father => 'person' }, { 'father.person_id' => \'!= child.father_id' }, ],
101     [ { mother => 'person' }, { 'mother.person_id' => 'child.mother_id' } ],
102 );
103 $match = 'person child JOIN person father ON ( father.person_id != '
104           . 'child.father_id ) JOIN person mother ON ( mother.person_id '
105           . '= child.mother_id )'
106           ;
107 is_same_sql(
108   $sa->_recurse_from(@j5),
109   $match,
110   'join 5 (SCALAR reference for ON statement) ok'
111 );
112
113 my @j6 = (
114     { child => 'person' },
115     [ { father => 'person' }, { 'father.person_id' => { '!=', '42' } }, ],
116     [ { mother => 'person' }, { 'mother.person_id' => 'child.mother_id' } ],
117 );
118 $match = qr/HASH reference arguments are not supported in JOINS/;
119 eval { $sa->_recurse_from(@j6) };
120 like( $@, $match, 'join 6 (HASH reference for ON statement dies) ok' );
121
122 my $rs = $schema->resultset("CD")->search(
123            { 'year' => 2001, 'artist.name' => 'Caterwauler McCrae' },
124            { from => [ { 'me' => 'cd' },
125                          [
126                            { artist => 'artist' },
127                            { 'me.artist' => 'artist.artistid' }
128                          ] ] }
129          );
130
131 is( $rs + 0, 1, "Single record in resultset");
132
133 is($rs->first->title, 'Forkful of bees', 'Correct record returned');
134
135 $rs = $schema->resultset("CD")->search(
136            { 'year' => 2001, 'artist.name' => 'Caterwauler McCrae' },
137            { join => 'artist' });
138
139 is( $rs + 0, 1, "Single record in resultset");
140
141 is($rs->first->title, 'Forkful of bees', 'Correct record returned');
142
143 $rs = $schema->resultset("CD")->search(
144            { 'artist.name' => 'We Are Goth',
145              'liner_notes.notes' => 'Kill Yourself!' },
146            { join => [ qw/artist liner_notes/ ] });
147
148 is( $rs + 0, 1, "Single record in resultset");
149
150 is($rs->first->title, 'Come Be Depressed With Us', 'Correct record returned');
151
152 # when using join attribute, make sure slice()ing all objects has same count as all()
153 $rs = $schema->resultset("CD")->search(
154     { 'artist' => 1 },
155     { join => [qw/artist/], order_by => 'artist.name' }
156 );
157 is( scalar $rs->all, scalar $rs->slice(0, $rs->count - 1), 'slice() with join has same count as all()' );
158
159 ok(!$rs->slice($rs->count+1000, $rs->count+1002)->count,
160   'Slicing beyond end of rs returns a zero count');
161
162 $rs = $schema->resultset("Artist")->search(
163         { 'liner_notes.notes' => 'Kill Yourself!' },
164         { join => { 'cds' => 'liner_notes' } });
165
166 is( $rs->count, 1, "Single record in resultset");
167
168 is($rs->first->name, 'We Are Goth', 'Correct record returned');
169
170
171 {
172     $schema->populate('Artist', [
173         [ qw/artistid name/ ],
174         [ 4, 'Another Boy Band' ],
175     ]);
176     $schema->populate('CD', [
177         [ qw/cdid artist title year/ ],
178         [ 6, 2, "Greatest Hits", 2001 ],
179         [ 7, 4, "Greatest Hits", 2005 ],
180         [ 8, 4, "BoyBandBlues", 2008 ],
181     ]);
182     $schema->populate('TwoKeys', [
183         [ qw/artist cd/ ],
184         [ 2, 4 ],
185         [ 2, 6 ],
186         [ 4, 7 ],
187         [ 4, 8 ],
188     ]);
189     
190     sub cd_count {
191         return $schema->resultset("CD")->count;
192     }
193     sub tk_count {
194         return $schema->resultset("TwoKeys")->count;
195     }
196
197     is(cd_count(), 8, '8 rows in table cd');
198     is(tk_count(), 7, '7 rows in table twokeys');
199  
200     sub artist1 {
201         return $schema->resultset("CD")->search(
202             { 'artist.name' => 'Caterwauler McCrae' },
203             { join => [qw/artist/]}
204         );
205     }
206     sub artist2 {
207         return $schema->resultset("CD")->search(
208             { 'artist.name' => 'Random Boy Band' },
209             { join => [qw/artist/]}
210         );
211     }
212
213     is( artist1()->count, 3, '3 Caterwauler McCrae CDs' );
214     ok( artist1()->delete, 'Successfully deleted 3 CDs' );
215     is( artist1()->count, 0, '0 Caterwauler McCrae CDs' );
216     is( artist2()->count, 2, '3 Random Boy Band CDs' );
217     ok( artist2()->update( { 'artist' => 1 } ) );
218     is( artist2()->count, 0, '0 Random Boy Band CDs' );
219     is( artist1()->count, 2, '2 Caterwauler McCrae CDs' );
220
221     # test update on multi-column-pk
222     sub tk1 {
223         return $schema->resultset("TwoKeys")->search(
224             {
225                 'artist.name' => { like => '%Boy Band' },
226                 'cd.title'    => 'Greatest Hits',
227             },
228             { join => [qw/artist cd/] }
229         );
230     }
231     sub tk2 {
232         return $schema->resultset("TwoKeys")->search(
233             { 'artist.name' => 'Caterwauler McCrae' },
234             { join => [qw/artist/]}
235         );
236     }
237     is( tk2()->count, 2, 'TwoKeys count == 2' );
238     is( tk1()->count, 2, 'TwoKeys count == 2' );
239     ok( tk1()->update( { artist => 1 } ) );
240     is( tk1()->count, 0, 'TwoKeys count == 0' );
241     is( tk2()->count, 4, '2 Caterwauler McCrae CDs' );
242     ok( tk2()->delete, 'Successfully deleted 4 CDs' );
243     is(cd_count(), 5, '5 rows in table cd');
244     is(tk_count(), 3, '3 rows in table twokeys');
245 }