Commit | Line | Data |
70350518 |
1 | use strict; |
34a9e8a0 |
2 | use warnings; |
70350518 |
3 | |
4 | use Test::More; |
74de7c2c |
5 | use Test::Exception; |
70350518 |
6 | use lib qw(t/lib); |
7 | use DBICTest; |
5db49b9a |
8 | use DBI::Const::GetInfoType; |
aa82ce29 |
9 | use DBIC::SqlMakerTest; |
0567538f |
10 | |
11 | my ($dsn, $user, $pass) = @ENV{map { "DBICTEST_MYSQL_${_}" } qw/DSN USER PASS/}; |
12 | |
13 | #warn "$dsn $user $pass"; |
14 | |
70350518 |
15 | plan skip_all => 'Set $ENV{DBICTEST_MYSQL_DSN}, _USER and _PASS to run this test' |
0567538f |
16 | unless ($dsn && $user); |
17 | |
3ff5b740 |
18 | my $schema = DBICTest::Schema->connect($dsn, $user, $pass); |
0567538f |
19 | |
3ff5b740 |
20 | my $dbh = $schema->storage->dbh; |
0567538f |
21 | |
22 | $dbh->do("DROP TABLE IF EXISTS artist;"); |
23 | |
a0dd8679 |
24 | $dbh->do("CREATE TABLE artist (artistid INTEGER NOT NULL AUTO_INCREMENT PRIMARY KEY, name VARCHAR(100), rank INTEGER NOT NULL DEFAULT '13', charfield CHAR(10));"); |
0567538f |
25 | |
74de7c2c |
26 | $dbh->do("DROP TABLE IF EXISTS cd;"); |
27 | |
28 | $dbh->do("CREATE TABLE cd (cdid INTEGER NOT NULL AUTO_INCREMENT PRIMARY KEY, artist INTEGER, title TEXT, year INTEGER, genreid INTEGER, single_track INTEGER);"); |
29 | |
30 | $dbh->do("DROP TABLE IF EXISTS producer;"); |
31 | |
32 | $dbh->do("CREATE TABLE producer (producerid INTEGER NOT NULL AUTO_INCREMENT PRIMARY KEY, name TEXT);"); |
33 | |
34 | $dbh->do("DROP TABLE IF EXISTS cd_to_producer;"); |
35 | |
36 | $dbh->do("CREATE TABLE cd_to_producer (cd INTEGER,producer INTEGER);"); |
37 | |
bed3a173 |
38 | $dbh->do("DROP TABLE IF EXISTS owners;"); |
39 | |
40 | $dbh->do("CREATE TABLE owners (id INTEGER NOT NULL AUTO_INCREMENT PRIMARY KEY, name VARCHAR(100) NOT NULL);"); |
41 | |
42 | $dbh->do("DROP TABLE IF EXISTS books;"); |
43 | |
44 | $dbh->do("CREATE TABLE books (id INTEGER NOT NULL AUTO_INCREMENT PRIMARY KEY, source VARCHAR(100) NOT NULL, owner integer NOT NULL, title varchar(100) NOT NULL, price integer);"); |
45 | |
0567538f |
46 | #'dbi:mysql:host=localhost;database=dbic_test', 'dbic_test', ''); |
47 | |
adbf0c89 |
48 | # make sure sqlt_type overrides work (::Storage::DBI::mysql does this) |
49 | { |
50 | my $schema = DBICTest::Schema->connect($dsn, $user, $pass); |
51 | |
52 | ok (!$schema->storage->_dbh, 'definitely not connected'); |
53 | is ($schema->storage->sqlt_type, 'MySQL', 'sqlt_type correct pre-connection'); |
54 | } |
55 | |
3ff5b740 |
56 | # This is in Core now, but it's here just to test that it doesn't break |
57 | $schema->class('Artist')->load_components('PK::Auto'); |
0567538f |
58 | |
59 | # test primary key handling |
3ff5b740 |
60 | my $new = $schema->resultset('Artist')->create({ name => 'foo' }); |
0567538f |
61 | ok($new->artistid, "Auto-PK worked"); |
62 | |
63 | # test LIMIT support |
64 | for (1..6) { |
3ff5b740 |
65 | $schema->resultset('Artist')->create({ name => 'Artist ' . $_ }); |
0567538f |
66 | } |
3ff5b740 |
67 | my $it = $schema->resultset('Artist')->search( {}, |
0567538f |
68 | { rows => 3, |
69 | offset => 2, |
70 | order_by => 'artistid' } |
71 | ); |
fb4b58e8 |
72 | is( $it->count, 3, "LIMIT count ok" ); # ask for 3 rows out of 7 artists |
0567538f |
73 | is( $it->next->name, "Artist 2", "iterator->next ok" ); |
74 | $it->next; |
75 | $it->next; |
76 | is( $it->next, undef, "next past end of resultset ok" ); |
77 | |
a953d8d9 |
78 | my $test_type_info = { |
79 | 'artistid' => { |
103e3e03 |
80 | 'data_type' => 'INT', |
81 | 'is_nullable' => 0, |
fc22fbac |
82 | 'size' => 11, |
83 | 'default_value' => undef, |
a953d8d9 |
84 | }, |
85 | 'name' => { |
103e3e03 |
86 | 'data_type' => 'VARCHAR', |
a953d8d9 |
87 | 'is_nullable' => 1, |
a0dd8679 |
88 | 'size' => 100, |
fc22fbac |
89 | 'default_value' => undef, |
103e3e03 |
90 | }, |
39da2a2b |
91 | 'rank' => { |
92 | 'data_type' => 'INT', |
93 | 'is_nullable' => 0, |
94 | 'size' => 11, |
95 | 'default_value' => 13, |
96 | }, |
103e3e03 |
97 | 'charfield' => { |
637219ab |
98 | 'data_type' => 'CHAR', |
103e3e03 |
99 | 'is_nullable' => 1, |
fc22fbac |
100 | 'size' => 10, |
101 | 'default_value' => undef, |
103e3e03 |
102 | }, |
a953d8d9 |
103 | }; |
104 | |
bed3a173 |
105 | $schema->populate ('Owners', [ |
106 | [qw/id name /], |
107 | [qw/1 wiggle/], |
108 | [qw/2 woggle/], |
109 | [qw/3 boggle/], |
110 | ]); |
111 | |
112 | $schema->populate ('BooksInLibrary', [ |
113 | [qw/source owner title /], |
13a2f031 |
114 | [qw/Library 1 secrets1/], |
115 | [qw/Eatery 1 secrets2/], |
116 | [qw/Library 2 secrets3/], |
bed3a173 |
117 | ]); |
118 | |
13a2f031 |
119 | # |
120 | # try a distinct + prefetch on tables with identically named columns |
121 | # (mysql doesn't seem to like subqueries with equally named columns) |
122 | # |
bed3a173 |
123 | |
d758ec36 |
124 | { |
13a2f031 |
125 | # try a ->has_many direction (due to a 'multi' accessor the select/group_by group is collapsed) |
126 | my $owners = $schema->resultset ('Owners')->search ( |
127 | { 'books.id' => { '!=', undef }}, |
128 | { prefetch => 'books', distinct => 1 } |
129 | ); |
130 | my $owners2 = $schema->resultset ('Owners')->search ({ id => { -in => $owners->get_column ('me.id')->as_query }}); |
131 | for ($owners, $owners2) { |
b5963465 |
132 | is ($_->all, 2, 'Prefetched grouped search returns correct number of rows'); |
133 | is ($_->count, 2, 'Prefetched grouped search returns correct count'); |
13a2f031 |
134 | } |
135 | |
d758ec36 |
136 | # try a ->belongs_to direction (no select collapse) |
b5963465 |
137 | my $books = $schema->resultset ('BooksInLibrary')->search ( |
138 | { 'owner.name' => 'wiggle' }, |
139 | { prefetch => 'owner', distinct => 1 } |
140 | ); |
141 | my $books2 = $schema->resultset ('BooksInLibrary')->search ({ id => { -in => $books->get_column ('me.id')->as_query }}); |
142 | for ($books, $books2) { |
143 | is ($_->all, 1, 'Prefetched grouped search returns correct number of rows'); |
144 | is ($_->count, 1, 'Prefetched grouped search returns correct count'); |
13a2f031 |
145 | } |
146 | } |
bed3a173 |
147 | |
5db49b9a |
148 | SKIP: { |
149 | my $mysql_version = $dbh->get_info( $GetInfoType{SQL_DBMS_VER} ); |
5db49b9a |
150 | skip "Cannot determine MySQL server version", 1 if !$mysql_version; |
a953d8d9 |
151 | |
f750163c |
152 | my ($v1, $v2, $v3) = $mysql_version =~ /^(\d+)\.(\d+)(?:\.(\d+))?/; |
153 | skip "Cannot determine MySQL server version", 1 if !$v1 || !defined($v2); |
154 | |
155 | $v3 ||= 0; |
156 | |
5db49b9a |
157 | if( ($v1 < 5) || ($v1 == 5 && $v2 == 0 && $v3 <= 3) ) { |
158 | $test_type_info->{charfield}->{data_type} = 'VARCHAR'; |
159 | } |
a953d8d9 |
160 | |
3ff5b740 |
161 | my $type_info = $schema->storage->columns_info_for('artist'); |
5db49b9a |
162 | is_deeply($type_info, $test_type_info, 'columns_info_for - column data types'); |
aa82ce29 |
163 | |
164 | |
5db49b9a |
165 | } |
a953d8d9 |
166 | |
6a999241 |
167 | my $cd = $schema->resultset ('CD')->create ({}); |
168 | my $producer = $schema->resultset ('Producer')->create ({}); |
169 | lives_ok { $cd->set_producers ([ $producer ]) } 'set_relationship doesnt die'; |
170 | |
aa82ce29 |
171 | { |
172 | my $artist = $schema->resultset('Artist')->next; |
173 | my $cd = $schema->resultset('CD')->next; |
174 | $cd->set_from_related ('artist', $artist); |
175 | $cd->update; |
176 | |
177 | my $rs = $schema->resultset('CD')->search ({}, { prefetch => 'artist' }); |
178 | |
179 | lives_ok sub { |
180 | my $cd = $rs->next; |
181 | is ($cd->artist->name, $artist->name, 'Prefetched artist'); |
182 | }, 'join does not throw (mysql 3 test)'; |
183 | |
184 | # induce a jointype override, make sure it works even if we don't have mysql3 |
de5f71ef |
185 | local $schema->storage->sql_maker->{_default_jointype} = 'inner'; |
aa82ce29 |
186 | is_same_sql_bind ( |
187 | $rs->as_query, |
188 | '( |
189 | SELECT me.cdid, me.artist, me.title, me.year, me.genreid, me.single_track, |
190 | artist.artistid, artist.name, artist.rank, artist.charfield |
191 | FROM cd me |
192 | INNER JOIN artist artist ON artist.artistid = me.artist |
193 | )', |
194 | [], |
195 | 'overriden default join type works', |
196 | ); |
197 | } |
6a999241 |
198 | |
55cfbb70 |
199 | ## Can we properly deal with the null search problem? |
a7e65bb5 |
200 | ## |
201 | ## Only way is to do a SET SQL_AUTO_IS_NULL = 0; on connect |
202 | ## But I'm not sure if we should do this or not (Ash, 2008/06/03) |
0fde80d9 |
203 | # |
204 | # There is now a built-in function to do this, test that everything works |
205 | # with it (ribasushi, 2009/07/03) |
55cfbb70 |
206 | |
207 | NULLINSEARCH: { |
97a0a148 |
208 | my $ansi_schema = DBICTest::Schema->connect ($dsn, $user, $pass, { on_connect_call => 'set_strict_mode' }); |
8de9298c |
209 | |
210 | $ansi_schema->resultset('Artist')->create ({ name => 'last created artist' }); |
6a999241 |
211 | |
212 | ok my $artist1_rs = $ansi_schema->resultset('Artist')->search({artistid=>6666}) |
213 | => 'Created an artist resultset of 6666'; |
214 | |
55cfbb70 |
215 | is $artist1_rs->count, 0 |
6a999241 |
216 | => 'Got no returned rows'; |
374dd926 |
217 | |
6a999241 |
218 | ok my $artist2_rs = $ansi_schema->resultset('Artist')->search({artistid=>undef}) |
219 | => 'Created an artist resultset of undef'; |
74de7c2c |
220 | |
6a999241 |
221 | is $artist2_rs->count, 0 |
222 | => 'got no rows'; |
74de7c2c |
223 | |
6a999241 |
224 | my $artist = $artist2_rs->single; |
55cfbb70 |
225 | |
6a999241 |
226 | is $artist => undef |
227 | => 'Nothing Found!'; |
74de7c2c |
228 | } |
aa82ce29 |
229 | |
10176e1f |
230 | |
231 | ## If find() is the first query after connect() |
232 | ## DBI::Storage::sql_maker() will be called before |
233 | ## _determine_driver() and so the ::SQLHacks class for MySQL |
234 | ## will not be used |
235 | |
236 | my $schema2 = DBICTest::Schema->connect($dsn, $user, $pass); |
237 | $schema2->resultset("Artist")->find(4); |
238 | isa_ok($schema2->storage->sql_maker, 'DBIx::Class::SQLAHacks::MySQL'); |
239 | |
aa82ce29 |
240 | done_testing; |