use DBI;
use Digest::MD5;
use File::Find 'find';
+use Class::Unload ();
my $DUMP_DIR = './t/_common_dump';
rmtree $DUMP_DIR;
# Only MySQL uses this
$self->{innodb} ||= '';
- # DB2 doesn't support this
+ # DB2 and Firebird don't support 'field type NULL'
$self->{null} = 'NULL' unless defined $self->{null};
$self->{verbose} = $ENV{TEST_VERBOSE} || 0;
return undef;
}
-sub _custom_column_info {
- my ( $table_name, $column_name, $column_info ) = @_;
+sub run_tests {
+ my $self = shift;
- $table_name = lc ( $table_name );
- $column_name = lc ( $column_name );
+ my @connect_info;
- if ( $table_name eq 'loader_test35'
- and $column_name eq 'an_int'
- ){
- return { is_numeric => 1 }
+ if ($self->{dsn}) {
+ push @connect_info, [ @{$self}{qw/dsn user password connect_info_opts/ } ];
}
- # Set inflate_datetime or inflate_date to check
- # datetime_timezone and datetime_locale
- if ( $table_name eq 'loader_test36' ){
- return { inflate_datetime => 1 } if
- ( $column_name eq 'b_char_as_data' );
- return { inflate_date => 1 } if
- ( $column_name eq 'c_char_as_data' );
+ else {
+ foreach my $info (@{ $self->{connect_info} || [] }) {
+ push @connect_info, [ @{$info}{qw/dsn user password connect_info_opts/ } ];
+ }
}
- return;
-}
+ plan tests => @connect_info * (171 + ($self->{extra}->{count} || 0));
-sub run_tests {
- my $self = shift;
+ foreach my $info_idx (0..$#connect_info) {
+ my $info = $connect_info[$info_idx];
- plan tests => 157 + ($self->{extra}->{count} || 0);
+ @{$self}{qw/dsn user password connect_info_opts/} = @$info;
- $self->create();
+ $self->create();
- my @connect_info = (
- $self->{dsn},
- $self->{user},
- $self->{password},
- $self->{connect_info_opts},
- );
+ my $schema_class = $self->setup_schema(@$info);
+ $self->test_schema($schema_class);
- # First, with in-memory classes
- my $schema_class = $self->setup_schema(@connect_info);
- $self->test_schema($schema_class);
- $self->drop_tables;
+ rmtree $DUMP_DIR
+ unless $ENV{SCHEMA_LOADER_TESTS_NOCLEANUP} && $info_idx == $#connect_info;
+ }
}
# defined in sub create
use_namespaces => 0,
dump_directory => $DUMP_DIR,
datetime_timezone => 'Europe/Berlin',
- datetime_locale => 'de_DE'
+ datetime_locale => 'de_DE',
+ %{ $self->{loader_options} || {} },
);
$loader_opts{db_schema} = $self->{db_schema} if $self->{db_schema};
+ Class::Unload->unload($schema_class);
+
+ my $file_count;
+ my $expected_count = 36;
{
my @loader_warnings;
local $SIG{__WARN__} = sub { push(@loader_warnings, $_[0]); };
ok(!$@, "Loader initialization") or diag $@;
- my $file_count;
find sub { return if -d; $file_count++ }, $DUMP_DIR;
- my $expected_count = 36;
-
$expected_count += grep /CREATE (?:TABLE|VIEW)/i,
@{ $self->{extra}{create} || [] };
is $file_count, $expected_count, 'correct number of files generated';
- exit if $file_count != $expected_count;
-
my $warn_count = 2;
$warn_count++ if grep /ResultSetManager/, @loader_warnings;
$warn_count++ for grep /^Bad table or view/, @loader_warnings;
- $warn_count++ for grep /stripping trailing _id/, @loader_warnings;
+ $warn_count++ for grep /renaming \S+ relation/, @loader_warnings;
my $vendor = $self->{vendor};
$warn_count++ for grep /${vendor}_\S+ has no primary key/,
"Missing PK warning");
}
}
-
+
+ exit if $file_count != $expected_count;
+
return $schema_class;
}
my $schema_class = shift;
my $conn = $schema_class->clone;
+
+ ($self->{before_tests_run} || sub {})->($conn);
+
my $monikers = {};
my $classes = {};
foreach my $source_name ($schema_class->sources) {
my $table_name = $schema_class->source($source_name)->from;
+ $table_name = $$table_name if ref $table_name;
+
$monikers->{$table_name} = $source_name;
$classes->{$table_name} = $schema_class . q{::} . $source_name;
is( $rsobj1->loader_test1_rsmeth, 'all is still well', 'Result set method' );
}
- ok( $class1->column_info('id')->{is_auto_increment}, 'is_auto_incrment detection' );
+ ok( $class1->column_info('id')->{is_auto_increment}, 'is_auto_increment detection' );
my $obj = $rsobj1->find(1);
is( $obj->id, 1, "Find got the right row" );
);
SKIP: {
- skip $self->{skip_rels}, 99 if $self->{skip_rels};
+ skip $self->{skip_rels}, 113 if $self->{skip_rels};
my $moniker3 = $monikers->{loader_test3};
my $class3 = $classes->{loader_test3};
my $rs_rel4 = $obj3->search_related('loader_test4zes');
isa_ok( $rs_rel4->first, $class4);
+ # check rel naming with prepositions
+ ok ($rsobj4->result_source->has_relationship('loader_test5s_to'),
+ "rel with preposition 'to' pluralized correctly");
+
+ ok ($rsobj4->result_source->has_relationship('loader_test5s_from'),
+ "rel with preposition 'from' pluralized correctly");
+
+ # check default relationship attributes
+ is $rsobj3->result_source->relationship_info('loader_test4zes')->{attrs}{cascade_delete}, 0,
+ 'cascade_delete => 0 on has_many by default';
+
+ is $rsobj3->result_source->relationship_info('loader_test4zes')->{attrs}{cascade_copy}, 0,
+ 'cascade_copy => 0 on has_many by default';
+
+ ok ((not exists $rsobj3->result_source->relationship_info('loader_test4zes')->{attrs}{on_delete}),
+ 'has_many does not have on_delete');
+
+ ok ((not exists $rsobj3->result_source->relationship_info('loader_test4zes')->{attrs}{on_update}),
+ 'has_many does not have on_update');
+
+ is $rsobj4->result_source->relationship_info('fkid_singular')->{attrs}{on_delete}, 'CASCADE',
+ "on_delete => 'CASCADE' on belongs_to by default";
+
+ is $rsobj4->result_source->relationship_info('fkid_singular')->{attrs}{on_update}, 'CASCADE',
+ "on_update => 'CASCADE' on belongs_to by default";
+
+ ok ((not exists $rsobj4->result_source->relationship_info('fkid_singular')->{attrs}{cascade_delete}),
+ 'belongs_to does not have cascade_delete');
+
+ ok ((not exists $rsobj4->result_source->relationship_info('fkid_singular')->{attrs}{cascade_copy}),
+ 'belongs_to does not have cascade_copy');
+
+ is $rsobj27->result_source->relationship_info('loader_test28')->{attrs}{cascade_delete}, 0,
+ 'cascade_delete => 0 on might_have by default';
+
+ is $rsobj27->result_source->relationship_info('loader_test28')->{attrs}{cascade_copy}, 0,
+ 'cascade_copy => 0 on might_have by default';
+
+ ok ((not exists $rsobj27->result_source->relationship_info('loader_test28')->{attrs}{on_delete}),
+ 'might_have does not have on_delete');
+
+ ok ((not exists $rsobj27->result_source->relationship_info('loader_test28')->{attrs}{on_update}),
+ 'might_have does not have on_update');
+
# find on multi-col pk
my $obj5 =
eval { $rsobj5->find({id1 => 1, iD2 => 1}) } ||
eval {
my $obj10_2 = $obj11->loader_test10;
- $obj10_2->loader_test11( $obj11->id11() );
- $obj10_2->update();
+ $obj10_2->update({ loader_test11 => $obj11->id11 });
};
+ diag $@ if $@;
ok(!$@, "Setting up circular relationship");
SKIP: {
$self->{extra}->{run}->($conn, $monikers, $classes) if $self->{extra}->{run};
+ $self->drop_tables unless $ENV{SCHEMA_LOADER_TESTS_NOCLEANUP};
+
$conn->storage->disconnect;
}
sub dbconnect {
my ($self, $complain) = @_;
- my $dbh = DBI->connect(
- $self->{dsn}, $self->{user},
- $self->{password},
- {
- RaiseError => $complain,
- PrintError => $complain,
- AutoCommit => 1,
- }
- );
+ require DBIx::Class::Storage::DBI;
+ my $storage = DBIx::Class::Storage::DBI->new;
+
+ $complain = defined $complain ? $complain : 1;
- die "Failed to connect to database: $DBI::errstr" if !$dbh;
+ $storage->connect_info([
+ @{ $self }{qw/dsn user password/},
+ {
+ unsafe => 1,
+ RaiseError => $complain,
+ ShowErrorStatement => $complain,
+ PrintError => 0,
+ %{ $self->{connect_info_opts} || {} },
+ },
+ ]);
+
+ my $dbh = eval { $storage->dbh };
+ die "Failed to connect to database: $@" if !$dbh;
+
+ $self->{storage} = $storage; # storage DESTROY disconnects
return $dbh;
}
id1 INTEGER NOT NULL,
iD2 INTEGER NOT NULL,
dat VARCHAR(8),
- PRIMARY KEY (id1,iD2)
+ from_id INTEGER $self->{null},
+ to_id INTEGER $self->{null},
+ PRIMARY KEY (id1,iD2),
+ FOREIGN KEY (from_id) REFERENCES loader_test4 (id),
+ FOREIGN KEY (to_id) REFERENCES loader_test4 (id)
) $self->{innodb}
},
my $dbh = $self->dbconnect(0);
- $dbh->do("DROP TABLE $_") for @{ $self->{extra}->{drop} || [] };
+ $dbh->do($_) for @{ $self->{extra}{pre_drop_ddl} || [] };
+ $dbh->do("DROP TABLE $_") for @{ $self->{extra}{drop} || [] };
my $drop_auto_inc = $self->{auto_inc_drop_cb} || sub {};
else {
$dbh->do($drop_fk);
}
- $dbh->do("DROP TABLE $_") for (@tables_advanced);
$dbh->do($_) for map { $drop_auto_inc->(@$_) } @tables_advanced_auto_inc;
+ $dbh->do("DROP TABLE $_") for (@tables_advanced);
unless($self->{no_inline_rels}) {
$dbh->do("DROP TABLE $_") for (@tables_inline_rels);
$dbh->do("DROP TABLE $_") for (@tables_implicit_rels);
}
}
- $dbh->do("DROP TABLE $_") for (@tables, @tables_rescan);
$dbh->do($_) for map { $drop_auto_inc->(@$_) } @tables_auto_inc;
+ $dbh->do("DROP TABLE $_") for (@tables, @tables_rescan);
+ $dbh->disconnect;
+
+# fixup for Firebird
+ $dbh = $self->dbconnect(0);
+ $dbh->do('DROP TABLE loader_test2');
$dbh->disconnect;
}
+sub _custom_column_info {
+ my ( $table_name, $column_name, $column_info ) = @_;
+
+ $table_name = lc ( $table_name );
+ $column_name = lc ( $column_name );
+
+ if ( $table_name eq 'loader_test35'
+ and $column_name eq 'an_int'
+ ){
+ return { is_numeric => 1 }
+ }
+ # Set inflate_datetime or inflate_date to check
+ # datetime_timezone and datetime_locale
+ if ( $table_name eq 'loader_test36' ){
+ return { inflate_datetime => 1 } if
+ ( $column_name eq 'b_char_as_data' );
+ return { inflate_date => 1 } if
+ ( $column_name eq 'c_char_as_data' );
+ }
+
+ return;
+}
+
sub DESTROY {
my $self = shift;
unless ($ENV{SCHEMA_LOADER_TESTS_NOCLEANUP}) {
projects / dbsrgits/DBIx-Class-Schema-Loader.git / blobdiff