8 use DBIC::SqlMakerTest;
10 $ENV{NLS_SORT} = "BINARY";
11 $ENV{NLS_COMP} = "BINARY";
12 $ENV{NLS_LANG} = "AMERICAN";
14 plan skip_all => 'Test needs ' . DBIx::Class::Optional::Dependencies->req_missing_for ('test_rdbms_oracle')
15 unless DBIx::Class::Optional::Dependencies->req_ok_for ('test_rdbms_oracle');
17 my ($dsn, $user, $pass) = @ENV{map { "DBICTEST_ORA_${_}" } qw/DSN USER PASS/};
19 plan skip_all => 'Set $ENV{DBICTEST_ORA_DSN}, _USER and _PASS to run this test.'
20 unless ($dsn && $user && $pass);
22 use DBICTest::Schema::Artist;
24 DBICTest::Schema::Artist->add_column('parentid');
26 DBICTest::Schema::Artist->has_many(
27 children => 'DBICTest::Schema::Artist',
28 { 'foreign.parentid' => 'self.artistid' }
31 DBICTest::Schema::Artist->belongs_to(
32 parent => 'DBICTest::Schema::Artist',
33 { 'foreign.artistid' => 'self.parentid' }
39 my $schema = DBICTest::Schema->connect($dsn, $user, $pass);
41 note "Oracle Version: " . $schema->storage->_server_info->{dbms_version};
43 my $dbh = $schema->storage->dbh;
46 ### test hierarchical queries
48 $schema->resultset('Artist')->create ({
62 title => "grandchilds's cd" ,
67 title => 'Track 1 grandchild',
74 name => 'greatgrandchild',
88 $schema->resultset('Artist')->create({
92 name => 'cycle-child1',
93 children => [ { name => 'cycle-grandchild' } ],
96 name => 'cycle-child2'
101 $schema->resultset('Artist')->find({ name => 'cycle-root' })
102 ->update({ parentid => { -ident => 'artistid' } });
104 # select the whole tree
106 my $rs = $schema->resultset('Artist')->search({}, {
107 start_with => { name => 'root' },
108 connect_by => { parentid => { -prior => { -ident => 'artistid' } } },
114 SELECT me.artistid, me.name, me.rank, me.charfield, me.parentid
117 CONNECT BY parentid = PRIOR artistid
119 [ [ { 'sqlt_datatype' => 'varchar', 'dbic_colname' => 'name', 'sqlt_size' => 100 }
123 [ $rs->get_column ('name')->all ],
124 [ qw/root child1 grandchild greatgrandchild child2/ ],
129 $rs->count_rs->as_query,
134 CONNECT BY parentid = PRIOR artistid
136 [ [ { 'sqlt_datatype' => 'varchar', 'dbic_colname' => 'name', 'sqlt_size' => 100 }
140 is( $rs->count, 5, 'Connect By count ok' );
143 # use order siblings by statement
145 # http://download.oracle.com/docs/cd/A87860_01/doc/server.817/a85397/state21b.htm#2066123
146 skip q{Oracle8i doesn't support ORDER SIBLINGS BY}, 1
147 if $schema->storage->_server_info->{normalized_dbms_version} < 9;
149 my $rs = $schema->resultset('Artist')->search({}, {
150 start_with => { name => 'root' },
151 connect_by => { parentid => { -prior => { -ident => 'artistid' } } },
152 order_siblings_by => { -desc => 'name' },
158 SELECT me.artistid, me.name, me.rank, me.charfield, me.parentid
161 CONNECT BY parentid = PRIOR artistid
162 ORDER SIBLINGS BY name DESC
164 [ [ { 'sqlt_datatype' => 'varchar', 'dbic_colname' => 'name', 'sqlt_size' => 100 }
169 [ $rs->get_column ('name')->all ],
170 [ qw/root child2 child1 grandchild greatgrandchild/ ],
171 'Order Siblings By ok',
177 my $rs = $schema->resultset('Artist')->search({ parentid => undef }, {
178 start_with => { name => 'root' },
179 connect_by => { parentid => { -prior => { -ident => 'artistid' } } },
185 SELECT me.artistid, me.name, me.rank, me.charfield, me.parentid
187 WHERE ( parentid IS NULL )
189 CONNECT BY parentid = PRIOR artistid
191 [ [ { 'sqlt_datatype' => 'varchar', 'dbic_colname' => 'name', 'sqlt_size' => 100 }
196 [ $rs->get_column('name')->all ],
202 # combine a connect by with a join
204 # http://download.oracle.com/docs/cd/A87860_01/doc/server.817/a85397/state21b.htm#2066123
205 skip q{Oracle8i doesn't support connect by with join}, 1
206 if $schema->storage->_server_info->{normalized_dbms_version} < 9;
208 my $rs = $schema->resultset('Artist')->search(
209 {'cds.title' => { -like => '%cd'} },
212 start_with => { 'me.name' => 'root' },
213 connect_by => { parentid => { -prior => { -ident => 'artistid' } } },
220 SELECT me.artistid, me.name, me.rank, me.charfield, me.parentid
222 LEFT JOIN cd cds ON cds.artist = me.artistid
223 WHERE ( cds.title LIKE ? )
224 START WITH me.name = ?
225 CONNECT BY parentid = PRIOR artistid
228 [ { 'sqlt_datatype' => 'varchar', 'dbic_colname' => 'cds.title', 'sqlt_size' => 100 }
230 [ { 'sqlt_datatype' => 'varchar', 'dbic_colname' => 'me.name', 'sqlt_size' => 100 }
236 [ $rs->get_column('name')->all ],
238 'Connect By with a join result name ok'
242 $rs->count_rs->as_query,
246 LEFT JOIN cd cds ON cds.artist = me.artistid
247 WHERE ( cds.title LIKE ? )
248 START WITH me.name = ?
249 CONNECT BY parentid = PRIOR artistid
252 [ { 'sqlt_datatype' => 'varchar', 'dbic_colname' => 'cds.title', 'sqlt_size' => 100 }
254 [ { 'sqlt_datatype' => 'varchar', 'dbic_colname' => 'me.name', 'sqlt_size' => 100 }
259 is( $rs->count, 1, 'Connect By with a join; count ok' );
262 # combine a connect by with order_by
264 my $rs = $schema->resultset('Artist')->search({}, {
265 start_with => { name => 'root' },
266 connect_by => { parentid => { -prior => { -ident => 'artistid' } } },
267 order_by => { -asc => [ 'LEVEL', 'name' ] },
273 SELECT me.artistid, me.name, me.rank, me.charfield, me.parentid
276 CONNECT BY parentid = PRIOR artistid
277 ORDER BY LEVEL ASC, name ASC
280 [ { 'sqlt_datatype' => 'varchar', 'dbic_colname' => 'name', 'sqlt_size' => 100 }
286 # Don't use "$rs->get_column ('name')->all" they build a query arround the $rs.
287 # If $rs has a order by, the order by is in the subquery and this doesn't work with Oracle 8i.
288 # TODO: write extra test and fix order by handling on Oracle 8i
290 [ map { $_->[1] } $rs->cursor->all ],
291 [ qw/root child1 child2 grandchild greatgrandchild/ ],
292 'Connect By with a order_by - result name ok (without get_column)'
296 skip q{Connect By with a order_by - result name ok (with get_column), Oracle8i doesn't support order by in a subquery},1
297 if $schema->storage->_server_info->{normalized_dbms_version} < 9;
299 [ $rs->get_column ('name')->all ],
300 [ qw/root child1 child2 grandchild greatgrandchild/ ],
301 'Connect By with a order_by - result name ok (with get_column)'
309 skip q{Oracle8i doesn't support order by in a subquery}, 1
310 if $schema->storage->_server_info->{normalized_dbms_version} < 9;
312 my $rs = $schema->resultset('Artist')->search({}, {
313 start_with => { name => 'root' },
314 connect_by => { parentid => { -prior => { -ident => 'artistid' } } },
315 order_by => { -asc => 'name' },
322 SELECT artistid, name, rank, charfield, parentid
324 SELECT me.artistid, me.name, me.rank, me.charfield, me.parentid
327 CONNECT BY parentid = PRIOR artistid
333 [ { 'sqlt_datatype' => 'varchar', 'dbic_colname' => 'name', 'sqlt_size' => 100 }
339 [ $rs->get_column ('name')->all ],
341 'LIMIT a Connect By query - correct names'
345 $rs->count_rs->as_query,
354 CONNECT BY parentid = PRIOR artistid
360 [ { 'sqlt_datatype' => 'varchar', 'dbic_colname' => 'name', 'sqlt_size' => 100 }
365 is( $rs->count, 2, 'Connect By; LIMIT count ok' );
368 # combine a connect_by with group_by and having
369 # add some bindvals to make sure things still work
371 my $rs = $schema->resultset('Artist')->search({}, {
372 select => \[ 'COUNT(rank) + ?', [ __cbind => 3 ] ],
374 start_with => { name => 'root' },
375 connect_by => { parentid => { -prior => { -ident => 'artistid' } } },
376 group_by => \[ 'rank + ? ', [ __gbind => 1] ],
377 having => \[ 'count(rank) < ?', [ cnt => 2 ] ],
383 SELECT COUNT(rank) + ?
386 CONNECT BY parentid = PRIOR artistid
387 GROUP BY( rank + ? ) HAVING count(rank) < ?
390 [ { dbic_colname => '__cbind' }
392 [ { 'sqlt_datatype' => 'varchar', 'dbic_colname' => 'name', 'sqlt_size' => 100 }
394 [ { dbic_colname => '__gbind' }
396 [ { dbic_colname => 'cnt' }
402 [ $rs->get_column ('cnt')->all ],
404 'Group By a Connect By query - correct values'
408 # select the whole cycle tree without nocylce
410 my $rs = $schema->resultset('Artist')->search({}, {
411 start_with => { name => 'cycle-root' },
412 connect_by => { parentid => { -prior => { -ident => 'artistid' } } },
415 # ORA-01436: CONNECT BY loop in user data
416 throws_ok { $rs->get_column ('name')->all } qr/ORA-01436/,
417 "connect by initify loop detection without nocycle";
420 # select the whole cycle tree with nocylce
422 # http://download.oracle.com/docs/cd/A87860_01/doc/server.817/a85397/expressi.htm#1023748
423 skip q{Oracle8i doesn't support connect by nocycle}, 1
424 if $schema->storage->_server_info->{normalized_dbms_version} < 9;
426 my $rs = $schema->resultset('Artist')->search({}, {
427 start_with => { name => 'cycle-root' },
428 '+select' => \ 'CONNECT_BY_ISCYCLE',
429 '+as' => [ 'connector' ],
430 connect_by_nocycle => { parentid => { -prior => { -ident => 'artistid' } } },
436 SELECT me.artistid, me.name, me.rank, me.charfield, me.parentid, CONNECT_BY_ISCYCLE
439 CONNECT BY NOCYCLE parentid = PRIOR artistid
442 [ { 'sqlt_datatype' => 'varchar', 'dbic_colname' => 'name', 'sqlt_size' => 100 }
447 [ $rs->get_column ('name')->all ],
448 [ qw/cycle-root cycle-child1 cycle-grandchild cycle-child2/ ],
449 'got artist tree with nocycle (name)',
452 [ $rs->get_column ('connector')->all ],
454 'got artist tree with nocycle (CONNECT_BY_ISCYCLE)',
458 $rs->count_rs->as_query,
463 CONNECT BY NOCYCLE parentid = PRIOR artistid
466 [ { 'sqlt_datatype' => 'varchar', 'dbic_colname' => 'name', 'sqlt_size' => 100 }
471 is( $rs->count, 4, 'Connect By Nocycle count ok' );
481 $dbh->do("DROP SEQUENCE artist_autoinc_seq");
482 $dbh->do("DROP SEQUENCE artist_pk_seq");
483 $dbh->do("DROP SEQUENCE cd_seq");
484 $dbh->do("DROP SEQUENCE track_seq");
485 $dbh->do("DROP TABLE artist");
486 $dbh->do("DROP TABLE track");
487 $dbh->do("DROP TABLE cd");
490 $dbh->do("CREATE SEQUENCE artist_pk_seq START WITH 1 MAXVALUE 999999 MINVALUE 0");
491 $dbh->do("CREATE SEQUENCE cd_seq START WITH 1 MAXVALUE 999999 MINVALUE 0");
492 $dbh->do("CREATE SEQUENCE track_seq START WITH 1 MAXVALUE 999999 MINVALUE 0");
494 $dbh->do("CREATE TABLE artist (artistid NUMBER(12), parentid NUMBER(12), name VARCHAR(255), autoinc_col NUMBER(12), rank NUMBER(38), charfield VARCHAR2(10))");
495 $dbh->do("ALTER TABLE artist ADD (CONSTRAINT artist_pk PRIMARY KEY (artistid))");
497 $dbh->do("CREATE TABLE cd (cdid NUMBER(12), artist NUMBER(12), title VARCHAR(255), year VARCHAR(4), genreid NUMBER(12), single_track NUMBER(12))");
498 $dbh->do("ALTER TABLE cd ADD (CONSTRAINT cd_pk PRIMARY KEY (cdid))");
500 $dbh->do("CREATE TABLE track (trackid NUMBER(12), cd NUMBER(12) REFERENCES cd(cdid) DEFERRABLE, position NUMBER(12), title VARCHAR(255), last_updated_on DATE, last_updated_at DATE, small_dt DATE)");
501 $dbh->do("ALTER TABLE track ADD (CONSTRAINT track_pk PRIMARY KEY (trackid))");
504 CREATE OR REPLACE TRIGGER artist_insert_trg_pk
505 BEFORE INSERT ON artist
508 IF :new.artistid IS NULL THEN
509 SELECT artist_pk_seq.nextval
516 CREATE OR REPLACE TRIGGER cd_insert_trg
517 BEFORE INSERT OR UPDATE ON cd
526 IF :new.cdid IS NULL THEN
527 SELECT cd_seq.nextval
536 CREATE OR REPLACE TRIGGER track_insert_trg
537 BEFORE INSERT ON track
540 IF :new.trackid IS NULL THEN
541 SELECT track_seq.nextval
552 my $dbh = $schema->storage->dbh;
553 $dbh->do("DROP SEQUENCE artist_pk_seq");
554 $dbh->do("DROP SEQUENCE cd_seq");
555 $dbh->do("DROP SEQUENCE track_seq");
556 $dbh->do("DROP TABLE artist");
557 $dbh->do("DROP TABLE track");
558 $dbh->do("DROP TABLE cd");