use Test::More;
use Test::Exception;
use DBIx::Class::Schema::Loader 'make_schema_at';
-use DBIx::Class::Schema::Loader::Utils 'slurp_file';
+use DBIx::Class::Schema::Loader::Utils qw/slurp_file split_name/;
use Try::Tiny;
use File::Path 'rmtree';
+use String::ToIdentifier::EN::Unicode 'to_identifier';
use namespace::clean;
use lib qw(t/lib);
my ($schema, $extra_schema); # for cleanup in END for extra tests
+my $auto_inc_cb = sub {
+ my ($table, $col) = @_;
+ return (
+ qq{ CREATE SEQUENCE ${table}_${col}_seq START WITH 1 INCREMENT BY 1},
+ qq{
+ CREATE OR REPLACE TRIGGER ${table}_${col}_trigger
+ BEFORE INSERT ON ${table}
+ FOR EACH ROW
+ BEGIN
+ SELECT ${table}_${col}_seq.nextval INTO :NEW.${col} FROM dual;
+ END;
+ }
+ );
+};
+
+my $auto_inc_drop_cb = sub {
+ my ($table, $col) = @_;
+ return qq{ DROP SEQUENCE ${table}_${col}_seq };
+};
+
my $tester = dbixcsl_common_tests->new(
vendor => 'Oracle',
auto_inc_pk => 'INTEGER NOT NULL PRIMARY KEY',
- auto_inc_cb => sub {
- my ($table, $col) = @_;
- return (
- qq{ CREATE SEQUENCE ${table}_${col}_seq START WITH 1 INCREMENT BY 1},
- qq{
- CREATE OR REPLACE TRIGGER ${table}_${col}_trigger
- BEFORE INSERT ON ${table}
- FOR EACH ROW
- BEGIN
- SELECT ${table}_${col}_seq.nextval INTO :NEW.${col} FROM dual;
- END;
- }
- );
- },
- auto_inc_drop_cb => sub {
- my ($table, $col) = @_;
- return qq{ DROP SEQUENCE ${table}_${col}_seq };
- },
+ auto_inc_cb => $auto_inc_cb,
+ auto_inc_drop_cb => $auto_inc_drop_cb,
preserve_case_mode_is_exclusive => 1,
quote_char => '"',
dsn => $dsn,
q{ COMMENT ON COLUMN oracle_loader_test1.value IS 'oracle_loader_test1.value column comment' },
],
drop => [qw/oracle_loader_test1/],
- count => 3 + 6 * 2,
+ count => 3 + 30 * 2,
run => sub {
my ($monikers, $classes);
($schema, $monikers, $classes) = @_;
value VARCHAR(100)
)
EOF
+
+ $dbh1->do($_) for $auto_inc_cb->('oracle_loader_test4', 'id');
+
$dbh1->do("GRANT ALL ON oracle_loader_test4 TO $schema2");
+ $dbh1->do("GRANT ALL ON oracle_loader_test4_id_seq TO $schema2");
+
+ $dbh1->do(<<"EOF");
+ CREATE TABLE oracle_loader_test5 (
+ id INT NOT NULL PRIMARY KEY,
+ value VARCHAR(100),
+ four_id INT REFERENCES ${schema1}.oracle_loader_test4 (id),
+ CONSTRAINT ora_loader5_uniq UNIQUE (four_id)
+ )
+EOF
+ $dbh1->do($_) for $auto_inc_cb->('oracle_loader_test5', 'id');
+ $dbh1->do("GRANT ALL ON oracle_loader_test5 TO $schema2");
+ $dbh1->do("GRANT ALL ON oracle_loader_test5_id_seq TO $schema2");
+
+ $dbh2->do(<<"EOF");
+ CREATE TABLE oracle_loader_test5 (
+ pk INT NOT NULL PRIMARY KEY,
+ value VARCHAR(100),
+ four_id INT REFERENCES ${schema1}.oracle_loader_test4 (id),
+ CONSTRAINT ora_loader5_uniq UNIQUE (four_id)
+ )
+EOF
+ $dbh2->do($_) for $auto_inc_cb->('oracle_loader_test5', 'pk');
+ $dbh2->do("GRANT ALL ON oracle_loader_test5 TO $schema1");
+ $dbh2->do("GRANT ALL ON oracle_loader_test5_pk_seq TO $schema1");
+
$dbh2->do(<<"EOF");
CREATE TABLE oracle_loader_test6 (
id INT NOT NULL PRIMARY KEY,
oracle_loader_test4_id INT REFERENCES ${schema1}.oracle_loader_test4 (id)
)
EOF
+ $dbh2->do($_) for $auto_inc_cb->('oracle_loader_test6', 'id');
$dbh2->do("GRANT ALL ON oracle_loader_test6 to $schema1");
+ $dbh2->do("GRANT ALL ON oracle_loader_test6_id_seq TO $schema1");
+
$dbh2->do(<<"EOF");
CREATE TABLE oracle_loader_test7 (
id INT NOT NULL PRIMARY KEY,
- value VARCHAR(100)
+ value VARCHAR(100),
+ six_id INT UNIQUE REFERENCES ${schema2}.oracle_loader_test6 (id)
)
EOF
+ $dbh2->do($_) for $auto_inc_cb->('oracle_loader_test7', 'id');
$dbh2->do("GRANT ALL ON oracle_loader_test7 to $schema1");
+ $dbh2->do("GRANT ALL ON oracle_loader_test7_id_seq TO $schema1");
+
$dbh1->do(<<"EOF");
CREATE TABLE oracle_loader_test8 (
id INT NOT NULL PRIMARY KEY,
oracle_loader_test7_id INT REFERENCES ${schema2}.oracle_loader_test7 (id)
)
EOF
+ $dbh1->do($_) for $auto_inc_cb->('oracle_loader_test8', 'id');
+ $dbh1->do("GRANT ALL ON oracle_loader_test8 to $schema2");
+ $dbh1->do("GRANT ALL ON oracle_loader_test8_id_seq TO $schema2");
+
+ # We add schema to moniker_parts, so make a monikers hash for
+ # the tests, of the form schemanum.tablenum
+ my $schema1_moniker = join '', map ucfirst lc, split_name to_identifier $schema1;
+ my $schema2_moniker = join '', map ucfirst lc, split_name to_identifier $schema2;
+
+ my %monikers;
+ $monikers{'1.4'} = $schema1_moniker . 'OracleLoaderTest4';
+ $monikers{'1.5'} = $schema1_moniker . 'OracleLoaderTest5';
+ $monikers{'2.5'} = $schema2_moniker . 'OracleLoaderTest5';
+ $monikers{'2.6'} = $schema2_moniker . 'OracleLoaderTest6';
+ $monikers{'2.7'} = $schema2_moniker . 'OracleLoaderTest7';
+ $monikers{'1.8'} = $schema1_moniker . 'OracleLoaderTest8';
foreach my $db_schema ([$schema1, $schema2], '%') {
lives_and {
{
naming => 'current',
db_schema => $db_schema,
- preserve_case => 1,
+ moniker_parts => [qw/schema name/],
dump_directory => EXTRA_DUMP_DIR,
quiet => 1,
},
is @warns, 0;
} qq{dumped schema for "$schema1" and "$schema2" schemas with no warnings};
- my $test_schema;
+ my ($test_schema, $rsrc, $rs, $row, %uniqs, $rel_info);
lives_and {
ok $test_schema = OracleMultiSchema->connect($dsn, $user, $password);
} 'connected test schema';
lives_and {
- ok $test_schema->source('OracleLoaderTest6')
+ ok $rsrc = $test_schema->source($monikers{'1.4'});
+ } 'got source for table in schema1';
+
+ is try { $rsrc->column_info('id')->{is_auto_increment} }, 1,
+ 'column in schema1';
+
+ is try { $rsrc->column_info('value')->{data_type} }, 'varchar2',
+ 'column in schema1';
+
+ is try { $rsrc->column_info('value')->{size} }, 100,
+ 'column in schema1';
+
+ lives_and {
+ ok $rs = $test_schema->resultset($monikers{'1.4'});
+ } 'got resultset for table in schema1';
+
+ lives_and {
+ ok $row = $rs->create({ value => 'foo' });
+ } 'executed SQL on table in schema1';
+
+ my $schema1_identifier = join '_', map lc, split_name to_identifier $schema1;
+
+ $rel_info = try { $rsrc->relationship_info(
+ $schema1_identifier . '_oracle_loader_test5'
+ ) };
+
+ is_deeply $rel_info->{cond}, {
+ 'foreign.four_id' => 'self.id'
+ }, 'relationship in schema1';
+
+ is $rel_info->{attrs}{accessor}, 'single',
+ 'relationship in schema1';
+
+ is $rel_info->{attrs}{join_type}, 'LEFT',
+ 'relationship in schema1';
+
+ lives_and {
+ ok $rsrc = $test_schema->source($monikers{'1.5'});
+ } 'got source for table in schema1';
+
+ %uniqs = try { $rsrc->unique_constraints };
+
+ is keys %uniqs, 2,
+ 'got unique and primary constraint in schema1';
+
+ delete $uniqs{primary};
+
+ is_deeply ((values %uniqs)[0], ['four_id'],
+ 'correct unique constraint in schema1');
+
+ lives_and {
+ ok $rsrc = $test_schema->source($monikers{'2.6'});
+ } 'got source for table in schema2';
+
+ is try { $rsrc->column_info('id')->{is_auto_increment} }, 1,
+ 'column in schema2 introspected correctly';
+
+ is try { $rsrc->column_info('value')->{data_type} }, 'varchar2',
+ 'column in schema2 introspected correctly';
+
+ is try { $rsrc->column_info('value')->{size} }, 100,
+ 'column in schema2 introspected correctly';
+
+ lives_and {
+ ok $rs = $test_schema->resultset($monikers{'2.6'});
+ } 'got resultset for table in schema2';
+
+ lives_and {
+ ok $row = $rs->create({ value => 'foo' });
+ } 'executed SQL on table in schema2';
+
+ $rel_info = try { $rsrc->relationship_info('oracle_loader_test7') };
+
+ is_deeply $rel_info->{cond}, {
+ 'foreign.six_id' => 'self.id'
+ }, 'relationship in schema2';
+
+ is $rel_info->{attrs}{accessor}, 'single',
+ 'relationship in schema2';
+
+ is $rel_info->{attrs}{join_type}, 'LEFT',
+ 'relationship in schema2';
+
+ lives_and {
+ ok $rsrc = $test_schema->source($monikers{'2.7'});
+ } 'got source for table in schema2';
+
+ %uniqs = try { $rsrc->unique_constraints };
+
+ is keys %uniqs, 2,
+ 'got unique and primary constraint in schema2';
+
+ delete $uniqs{primary};
+
+ is_deeply ((values %uniqs)[0], ['six_id'],
+ 'correct unique constraint in schema2');
+
+ lives_and {
+ ok $test_schema->source($monikers{'2.6'})
->has_relationship('oracle_loader_test4');
} 'cross-schema relationship in multi-db_schema';
lives_and {
- ok $test_schema->source('OracleLoaderTest4')
+ ok $test_schema->source($monikers{'1.4'})
->has_relationship('oracle_loader_test6s');
} 'cross-schema relationship in multi-db_schema';
lives_and {
- ok $test_schema->source('OracleLoaderTest8')
+ ok $test_schema->source($monikers{'1.8'})
->has_relationship('oracle_loader_test7');
} 'cross-schema relationship in multi-db_schema';
lives_and {
- ok $test_schema->source('OracleLoaderTest7')
+ ok $test_schema->source($monikers{'2.7'})
->has_relationship('oracle_loader_test8s');
} 'cross-schema relationship in multi-db_schema';
}
my $dbh1 = $schema->storage->dbh;
try {
- $dbh2->do('DROP TABLE oracle_loader_test6');
- $dbh1->do('DROP TABLE oracle_loader_test4');
+ $dbh1->do($_) for $auto_inc_drop_cb->('oracle_loader_test8', 'id');
+ $dbh2->do($_) for $auto_inc_drop_cb->('oracle_loader_test7', 'id');
+ $dbh2->do($_) for $auto_inc_drop_cb->('oracle_loader_test6', 'id');
+ $dbh2->do($_) for $auto_inc_drop_cb->('oracle_loader_test5', 'pk');
+ $dbh1->do($_) for $auto_inc_drop_cb->('oracle_loader_test5', 'id');
+ $dbh1->do($_) for $auto_inc_drop_cb->('oracle_loader_test4', 'id');
+ }
+ catch {
+ die "Error dropping sequences for cross-schema test tables: $_";
+ };
+
+ try {
$dbh1->do('DROP TABLE oracle_loader_test8');
$dbh2->do('DROP TABLE oracle_loader_test7');
+ $dbh2->do('DROP TABLE oracle_loader_test6');
+ $dbh2->do('DROP TABLE oracle_loader_test5');
+ $dbh1->do('DROP TABLE oracle_loader_test5');
+ $dbh1->do('DROP TABLE oracle_loader_test4');
}
catch {
die "Error dropping cross-schema test tables: $_";
projects / dbsrgits/DBIx-Class-Schema-Loader.git / blobdiff