Oops, deploy only drops tables if you tell it to..
[dbsrgits/DBIx-Class.git] / t / run / 23cache.tl
CommitLineData
64acc2bc 1sub run_tests {
2my $schema = shift;
3
4eval "use DBD::SQLite";
5plan skip_all => 'needs DBD::SQLite for testing' if $@;
d2b3ea14 6plan tests => 14;
64acc2bc 7
8my $rs = $schema->resultset("Artist")->search(
9 { artistid => 1 }
10);
11
12my $artist = $rs->first;
13
14is( scalar @{ $rs->get_cache }, 0, 'cache is not populated without cache attribute' );
15
16$rs = $schema->resultset("Artist")->search(
17 { 'artistid' => 1 },
18 {
3c3c416e 19 join => [ qw/ cds /],
64acc2bc 20 prefetch => [qw/ cds /],
64acc2bc 21 }
22);
23
f9cc31dd 24use Data::Dumper; $Data::Dumper::Deparse = 1;
64acc2bc 25
26# start test for prefetch SELECT count
27unlink 't/var/dbic.trace' if -e 't/var/dbic.trace';
28DBI->trace(1, 't/var/dbic.trace');
29
30$artist = $rs->first;
31$rs->reset();
32
33# make sure artist contains a related resultset for cds
34is( ref $artist->{related_resultsets}->{cds}, 'DBIx::Class::ResultSet', 'artist has a related_resultset for cds' );
35
36# check if $artist->cds->get_cache is populated
37is( scalar @{$artist->cds->get_cache}, 3, 'cache for artist->cds contains correct number of records');
38
39# ensure that $artist->cds returns correct number of objects
40is( scalar ($artist->cds), 3, 'artist->cds returns correct number of objects' );
41
42# ensure that $artist->cds->count returns correct value
43is( $artist->cds->count, 3, 'artist->cds->count returns correct value' );
44
45# ensure that $artist->count_related('cds') returns correct value
46is( $artist->count_related('cds'), 3, 'artist->count_related returns correct value' );
47
48# count the SELECTs
49DBI->trace(0, undef);
50my $selects = 0;
51my $trace = IO::File->new('t/var/dbic.trace', '<')
52 or die "Unable to read trace file";
53while (<$trace>) {
54 $selects++ if /SELECT/;
55}
56$trace->close;
57unlink 't/var/dbic.trace';
5a5bec6c 58is($selects, 1, 'only one SQL statement executed');
64acc2bc 59
60# make sure related_resultset is deleted after object is updated
61$artist->set_column('name', 'New Name');
62$artist->update();
63
64is( scalar keys %{$artist->{related_resultsets}}, 0, 'related resultsets deleted after update' );
65
66# todo: make sure caching works with nested prefetch e.g. $artist->cds->tracks
67$rs = $schema->resultset("Artist")->search(
68 { artistid => 1 },
69 {
3c3c416e 70 join => { cds => 'tags' },
64acc2bc 71 prefetch => {
72 cds => 'tags'
73 },
64acc2bc 74 }
75);
76
f9cc31dd 77# SELECT count for nested has_many prefetch
78unlink 't/var/dbic.trace' if -e 't/var/dbic.trace';
79DBI->trace(1, 't/var/dbic.trace');
80
5a5bec6c 81$artist = ($rs->all)[0];
f9cc31dd 82
83# count the SELECTs
84DBI->trace(0, undef);
6e3b590d 85$selects = 0;
86$trace = IO::File->new('t/var/dbic.trace', '<')
f9cc31dd 87 or die "Unable to read trace file";
88while (<$trace>) {
89 $selects++ if /SELECT/;
90}
91$trace->close;
92unlink 't/var/dbic.trace';
5a5bec6c 93is($selects, 1, 'only one SQL statement executed');
f9cc31dd 94
95my @objs;
5a5bec6c 96#$artist = $rs->find(1);
f9cc31dd 97
98unlink 't/var/dbic.trace' if -e 't/var/dbic.trace';
99DBI->trace(1, 't/var/dbic.trace');
100
101my $cds = $artist->cds;
102my $tags = $cds->next->tags;
103while( my $tag = $tags->next ) {
5a5bec6c 104 push @objs, $tag->tagid; #warn "tag:", $tag->ID, " => ", $tag->tag;
f9cc31dd 105}
106
5a5bec6c 107is_deeply( \@objs, [ 3 ], 'first cd has correct tags' );
f9cc31dd 108
109$tags = $cds->next->tags;
110@objs = ();
111while( my $tag = $tags->next ) {
112 push @objs, $tag->id; #warn "tag: ", $tag->ID;
113}
114
115is_deeply( \@objs, [ 2, 5, 8 ], 'second cd has correct tags' );
116
117# count the SELECTs
118DBI->trace(0, undef);
6e3b590d 119$selects = 0;
120$trace = IO::File->new('t/var/dbic.trace', '<')
f9cc31dd 121 or die "Unable to read trace file";
122while (<$trace>) {
123 $selects++ if /SELECT/;
124}
125$trace->close;
126unlink 't/var/dbic.trace';
127
128is( $selects, 0, 'no additional SQL statements while checking nested data' );
129
d2b3ea14 130# start test for prefetch SELECT count
131unlink 't/var/dbic.trace' if -e 't/var/dbic.trace';
132DBI->trace(1, 't/var/dbic.trace');
133
134$artist = $schema->resultset('Artist')->find(1, { prefetch => [qw/cds/] });
135
136# count the SELECTs
137DBI->trace(0, undef);
138$selects = 0;
139$trace = IO::File->new('t/var/dbic.trace', '<')
140 or die "Unable to read trace file";
141while (<$trace>) {
142 $selects++ if /SELECT/;
143}
144$trace->close;
145unlink 't/var/dbic.trace';
146
147is( $selects, 1, 'only one select statement on find with inline has_many prefetch' );
148
149# start test for prefetch SELECT count
150unlink 't/var/dbic.trace' if -e 't/var/dbic.trace';
151DBI->trace(1, 't/var/dbic.trace');
152
153$rs = $schema->resultset('Artist')->search(undef, { prefetch => [qw/cds/] });
154$artist = $rs->find(1);
155
156# count the SELECTs
157DBI->trace(0, undef);
158$selects = 0;
159$trace = IO::File->new('t/var/dbic.trace', '<')
160 or die "Unable to read trace file";
161while (<$trace>) {
162 $selects++ if /SELECT/;
163}
164$trace->close;
165unlink 't/var/dbic.trace';
166
167is( $selects, 1, 'only one select statement on find with has_many prefetch on resultset' );
168
64acc2bc 169}
170
1711;