[dbsrgits/DBIx-Class-Schema-Loader.git] / t / 10_02mysql_common.t

use strict;
use warnings;
use Test::More;
use Test::Exception;
use Try::Tiny;
use File::Path 'rmtree';
use DBIx::Class::Schema::Loader::Utils 'slurp_file';
use DBIx::Class::Schema::Loader 'make_schema_at';

use lib qw(t/lib);

use dbixcsl_common_tests;
use dbixcsl_test_dir '$tdir';

use constant EXTRA_DUMP_DIR => "$tdir/mysql_extra_dump";

my $dsn         = $ENV{DBICTEST_MYSQL_DSN} || '';
my $user        = $ENV{DBICTEST_MYSQL_USER} || '';
my $password    = $ENV{DBICTEST_MYSQL_PASS} || '';
my $test_innodb = $ENV{DBICTEST_MYSQL_INNODB} || 0;

my $skip_rels_msg = 'You need to set the environment variable DBICTEST_MYSQL_INNODB=1 to test relationships.';

my $innodb = $test_innodb ? q{Engine=InnoDB} : '';

my ($schema, $databases_created); # for cleanup in END for extra tests

my $tester = dbixcsl_common_tests->new(
    vendor           => 'Mysql',
    auto_inc_pk      => 'INTEGER NOT NULL PRIMARY KEY AUTO_INCREMENT',
    innodb           => $innodb,
    dsn              => $dsn,
    user             => $user,
    password         => $password,
    connect_info_opts=> { on_connect_call => 'set_strict_mode' },
    loader_options   => { preserve_case => 1 },
    skip_rels        => $test_innodb ? 0 : $skip_rels_msg,
    quote_char       => '`',
    no_inline_rels   => 1,
    no_implicit_rels => 1,
    data_types  => {
        # http://dev.mysql.com/doc/refman/5.5/en/data-type-overview.html
        # Numeric Types
        'bit'         => { data_type => 'bit', size => 1 },
        'bit(11)'     => { data_type => 'bit', size => 11 },

        'bool'        => { data_type => 'tinyint' },
        'boolean'     => { data_type => 'tinyint' },
        'tinyint'     => { data_type => 'tinyint' },
        'tinyint unsigned'
                      => { data_type => 'tinyint',   extra => { unsigned => 1 } },
        'smallint'    => { data_type => 'smallint' },
        'smallint unsigned'
                      => { data_type => 'smallint',  extra => { unsigned => 1 } },
        'mediumint'   => { data_type => 'mediumint' },
        'mediumint unsigned'
                      => { data_type => 'mediumint', extra => { unsigned => 1 } },
        'int'         => { data_type => 'integer' },
        'int unsigned'
                      => { data_type => 'integer',   extra => { unsigned => 1 } },
        'integer'     => { data_type => 'integer' },
        'integer unsigned'
                      => { data_type => 'integer',   extra => { unsigned => 1 } },
        'integer not null'
                      => { data_type => 'integer' },
        'bigint'      => { data_type => 'bigint' },
        'bigint unsigned'
                      => { data_type => 'bigint',    extra => { unsigned => 1 } },

        'serial'      => { data_type => 'bigint', is_auto_increment => 1, extra => { unsigned => 1 } },

        'float'       => { data_type => 'float' },
        'float unsigned'
                      => { data_type => 'float',     extra => { unsigned => 1 } },
        'double'      => { data_type => 'double precision' },
        'double unsigned'
                      => { data_type => 'double precision', extra => { unsigned => 1 } },
        'double precision' =>
                         { data_type => 'double precision' },
        'double precision unsigned'
                      => { data_type => 'double precision', extra => { unsigned => 1 } },

        # we skip 'real' because its alias depends on the 'REAL AS FLOAT' setting

        'float(2)'    => { data_type => 'float' },
        'float(24)'   => { data_type => 'float' },
        'float(25)'   => { data_type => 'double precision' },

        'float(3,3)'  => { data_type => 'float', size => [3,3] },
        'double(3,3)' => { data_type => 'double precision', size => [3,3] },
        'double precision(3,3)'
                      => { data_type => 'double precision', size => [3,3] },

        'decimal'     => { data_type => 'decimal' },
        'decimal unsigned'
                      => { data_type => 'decimal', extra => { unsigned => 1 } },
        'dec'         => { data_type => 'decimal' },
        'numeric'     => { data_type => 'decimal' },
        'fixed'       => { data_type => 'decimal' },

        'decimal(3)'   => { data_type => 'decimal', size => [3,0] },

        'decimal(3,3)' => { data_type => 'decimal', size => [3,3] },
        'dec(3,3)'     => { data_type => 'decimal', size => [3,3] },
        'numeric(3,3)' => { data_type => 'decimal', size => [3,3] },
        'fixed(3,3)'   => { data_type => 'decimal', size => [3,3] },

        # Date and Time Types
        'date'        => { data_type => 'date', datetime_undef_if_invalid => 1 },
        'datetime'    => { data_type => 'datetime', datetime_undef_if_invalid => 1 },
        'timestamp default current_timestamp'
                      => { data_type => 'timestamp', default_value => \'current_timestamp', datetime_undef_if_invalid => 1 },
        'time'        => { data_type => 'time' },
        'year'        => { data_type => 'year' },
        'year(4)'     => { data_type => 'year' },
        'year(2)'     => { data_type => 'year', size => 2 },

        # String Types
        'char'         => { data_type => 'char',      size => 1  },
        'char(11)'     => { data_type => 'char',      size => 11 },
        'varchar(20)'  => { data_type => 'varchar',   size => 20 },
        'binary'       => { data_type => 'binary',    size => 1  },
        'binary(11)'   => { data_type => 'binary',    size => 11 },
        'varbinary(20)'=> { data_type => 'varbinary', size => 20 },

        'tinyblob'    => { data_type => 'tinyblob' },
        'tinytext'    => { data_type => 'tinytext' },
        'blob'        => { data_type => 'blob' },

        # text(M) types will map to the appropriate type, length is not stored
        'text'        => { data_type => 'text' },

        'mediumblob'  => { data_type => 'mediumblob' },
        'mediumtext'  => { data_type => 'mediumtext' },
        'longblob'    => { data_type => 'longblob' },
        'longtext'    => { data_type => 'longtext' },

        "enum('foo','bar','baz')"
                      => { data_type => 'enum', extra => { list => [qw/foo bar baz/] } },
        "enum('foo \\'bar\\' baz', 'foo ''bar'' quux')"
                      => { data_type => 'enum', extra => { list => [q{foo 'bar' baz}, q{foo 'bar' quux}] } },
        "set('foo \\'bar\\' baz', 'foo ''bar'' quux')"
                      => { data_type => 'set', extra => { list => [q{foo 'bar' baz}, q{foo 'bar' quux}] } },
        "set('foo','bar','baz')"
                      => { data_type => 'set',  extra => { list => [qw/foo bar baz/] } },

        # RT#68717
        "enum('11,10 (<500)/0 DUN','4,90 (<120)/0 EUR') NOT NULL default '11,10 (<500)/0 DUN'"
                      => { data_type => 'enum', extra => { list => ['11,10 (<500)/0 DUN', '4,90 (<120)/0 EUR'] }, default_value => '11,10 (<500)/0 DUN' },
        "set('11_10 (<500)/0 DUN','4_90 (<120)/0 EUR') NOT NULL default '11_10 (<500)/0 DUN'"
                      => { data_type => 'set', extra => { list => ['11_10 (<500)/0 DUN', '4_90 (<120)/0 EUR'] }, default_value => '11_10 (<500)/0 DUN' },
        "enum('19,90 (<500)/0 EUR','4,90 (<120)/0 EUR','7,90 (<200)/0 CHF','300 (<6000)/0 CZK','4,90 (<100)/0 EUR','39 (<900)/0 DKK','299 (<5000)/0 EEK','9,90 (<250)/0 EUR','3,90 (<100)/0 GBP','3000 (<70000)/0 HUF','4000 (<70000)/0 JPY','13,90 (<200)/0 LVL','99 (<2500)/0 NOK','39 (<1000)/0 PLN','1000 (<20000)/0 RUB','49 (<2500)/0 SEK','29 (<600)/0 USD','19,90 (<600)/0 EUR','0 EUR','0 CHF') NOT NULL default '19,90 (<500)/0 EUR'"
                      => { data_type => 'enum', extra => { list => ['19,90 (<500)/0 EUR','4,90 (<120)/0 EUR','7,90 (<200)/0 CHF','300 (<6000)/0 CZK','4,90 (<100)/0 EUR','39 (<900)/0 DKK','299 (<5000)/0 EEK','9,90 (<250)/0 EUR','3,90 (<100)/0 GBP','3000 (<70000)/0 HUF','4000 (<70000)/0 JPY','13,90 (<200)/0 LVL','99 (<2500)/0 NOK','39 (<1000)/0 PLN','1000 (<20000)/0 RUB','49 (<2500)/0 SEK','29 (<600)/0 USD','19,90 (<600)/0 EUR','0 EUR','0 CHF'] }, default_value => '19,90 (<500)/0 EUR' },
    },
    extra => {
        create => [
            qq{
                CREATE TABLE `mysql_loader-test1` (
                    id INT AUTO_INCREMENT PRIMARY KEY COMMENT 'The\15\12Column',
                    value varchar(100)
                ) $innodb COMMENT 'The\15\12Table'
            },
            q{
                CREATE VIEW mysql_loader_test2 AS SELECT * FROM `mysql_loader-test1`
            },
            # RT#68717
            qq{
                CREATE TABLE `mysql_loader_test3` (
                  `ISO3_code` char(3) NOT NULL default '',
                  `lang_pref` enum('de','en','fr','nl','dk','es','se') NOT NULL,
                  `vat` decimal(4,2) default '16.00',
                  `price_group` enum('EUR_DEFAULT','GBP_GBR','EUR_AUT_BEL_FRA_IRL_NLD','EUR_DNK_SWE','EUR_AUT','EUR_BEL','EUR_FIN','EUR_FRA','EUR_IRL','EUR_NLD','EUR_DNK','EUR_POL','EUR_PRT','EUR_SWE','CHF_CHE','DKK_DNK','SEK_SWE','NOK_NOR','USD_USA','CZK_CZE','PLN_POL','RUB_RUS','HUF_HUN','SKK_SVK','JPY_JPN','LVL_LVA','ROL_ROU','EEK_EST') NOT NULL default 'EUR_DEFAULT',
                  `del_group` enum('19,90 (<500)/0 EUR','4,90 (<120)/0 EUR','7,90 (<200)/0 CHF','300 (<6000)/0 CZK','4,90 (<100)/0 EUR','39 (<900)/0 DKK','299 (<5000)/0 EEK','9,90 (<250)/0 EUR','3,90 (<100)/0 GBP','3000 (<70000)/0 HUF','4000 (<70000)/0 JPY','13,90 (<200)/0 LVL','99 (<2500)/0 NOK','39 (<1000)/0 PLN','1000 (<20000)/0 RUB','49 (<2500)/0 SEK','29 (<600)/0 USD','19,90 (<600)/0 EUR','0 EUR','0 CHF') NOT NULL default '19,90 (<500)/0 EUR',
                  `express_del_group` enum('NO','39 EUR (EXPRESS)','59 EUR (EXPRESS)','79 CHF (EXPRESS)','49 EUR (EXPRESS)','990 CZK (EXPRESS)','19,9 EUR (EXPRESS)','290 DKK (EXPRESS)','990 EEK (EXPRESS)','39 GBP (EXPRESS)','14000 HUF (EXPRESS)','49 LVL (EXPRESS)','590 NOK (EXPRESS)','250 PLN (EXPRESS)','490 SEK (EXPRESS)') NOT NULL default 'NO',
                  `pmethod` varchar(255) NOT NULL default 'VISA,MASTER',
                  `delivery_time` varchar(5) default NULL,
                  `express_delivery_time` varchar(5) default NULL,
                  `eu` int(1) default '0',
                  `cod_costs` varchar(12) default NULL,
                  PRIMARY KEY (`ISO3_code`)
                ) $innodb
            },
        ],
        pre_drop_ddl => [ 'DROP VIEW mysql_loader_test2', ],
        drop => [ 'mysql_loader-test1', 'mysql_loader_test3' ],
        count => 5 + 30 * 2,
        run => sub {
            my ($monikers, $classes);
            ($schema, $monikers, $classes) = @_;

            is $monikers->{'mysql_loader-test1'}, 'MysqlLoaderTest1',
                'table with dash correctly monikerized';

            my $rsrc = $schema->source('MysqlLoaderTest2');

            is $rsrc->column_info('value')->{data_type}, 'varchar',
                'view introspected successfully';

            $rsrc = $schema->source('MysqlLoaderTest3');

            is_deeply $rsrc->column_info('del_group')->{extra}{list}, ['19,90 (<500)/0 EUR','4,90 (<120)/0 EUR','7,90 (<200)/0 CHF','300 (<6000)/0 CZK','4,90 (<100)/0 EUR','39 (<900)/0 DKK','299 (<5000)/0 EEK','9,90 (<250)/0 EUR','3,90 (<100)/0 GBP','3000 (<70000)/0 HUF','4000 (<70000)/0 JPY','13,90 (<200)/0 LVL','99 (<2500)/0 NOK','39 (<1000)/0 PLN','1000 (<20000)/0 RUB','49 (<2500)/0 SEK','29 (<600)/0 USD','19,90 (<600)/0 EUR','0 EUR','0 CHF'],
                'hairy enum introspected correctly';

            my $class    = $classes->{'mysql_loader-test1'};
            my $filename = $schema->loader->get_dump_filename($class);

            my $code = slurp_file $filename;

            like $code, qr/^=head1 NAME\n\n^$class - The\nTable\n\n^=cut\n/m,
                'table comment';

            like $code, qr/^=head2 id\n\n(.+:.+\n)+\nThe\nColumn\n\n/m,
                'column comment and attrs';

            SKIP: {
                my $dbh = $schema->storage->dbh;

                try {
                    $dbh->do('CREATE DATABASE `dbicsl-test`');
                }
                catch {
                    diag "CREATE DATABASE returned error: '$_'";
                    skip "no CREATE DATABASE privileges", 30 * 2;
                };

                $dbh->do(<<"EOF");
                    CREATE TABLE `dbicsl-test`.mysql_loader_test4 (
                        id INT AUTO_INCREMENT PRIMARY KEY,
                        value VARCHAR(100)
                    ) $innodb
EOF
                $dbh->do(<<"EOF");
                    CREATE TABLE `dbicsl-test`.mysql_loader_test5 (
                        id INT AUTO_INCREMENT PRIMARY KEY,
                        value VARCHAR(100),
                        four_id INTEGER,
                        CONSTRAINT loader_test5_uniq UNIQUE (four_id),
                        FOREIGN KEY (four_id) REFERENCES `dbicsl-test`.mysql_loader_test4 (id)
                    ) $innodb
EOF

                $dbh->do('CREATE DATABASE `dbicsl.test`');

                # Test that keys are correctly cached by naming the primary and
                # unique keys in this table with the same name as a table in
                # the `dbicsl-test` schema differently.
                $dbh->do(<<"EOF");
                    CREATE TABLE `dbicsl.test`.mysql_loader_test5 (
                        pk INT AUTO_INCREMENT PRIMARY KEY,
                        value VARCHAR(100),
                        four_id INTEGER,
                        CONSTRAINT loader_test5_uniq UNIQUE (four_id),
                        FOREIGN KEY (four_id) REFERENCES `dbicsl-test`.mysql_loader_test4 (id)
                    ) $innodb
EOF

                $dbh->do(<<"EOF");
                    CREATE TABLE `dbicsl.test`.mysql_loader_test6 (
                        id INT AUTO_INCREMENT PRIMARY KEY,
                        value VARCHAR(100),
                        mysql_loader_test4_id INTEGER,
                        FOREIGN KEY (mysql_loader_test4_id) REFERENCES `dbicsl-test`.mysql_loader_test4 (id)
                    ) $innodb
EOF
                $dbh->do(<<"EOF");
                    CREATE TABLE `dbicsl.test`.mysql_loader_test7 (
                        id INT AUTO_INCREMENT PRIMARY KEY,
                        value VARCHAR(100),
                        six_id INTEGER UNIQUE,
                        FOREIGN KEY (six_id) REFERENCES `dbicsl.test`.mysql_loader_test6 (id)
                    ) $innodb
EOF
                $dbh->do(<<"EOF");
                    CREATE TABLE `dbicsl-test`.mysql_loader_test8 (
                        id INT AUTO_INCREMENT PRIMARY KEY,
                        value VARCHAR(100),
                        mysql_loader_test7_id INTEGER,
                        FOREIGN KEY (mysql_loader_test7_id) REFERENCES `dbicsl.test`.mysql_loader_test7 (id)
                    ) $innodb
EOF
                # Test dumping a rel to a table that's not part of the dump.
                $dbh->do('CREATE DATABASE `dbicsl_test_ignored`');
                $dbh->do(<<"EOF");
                    CREATE TABLE `dbicsl_test_ignored`.mysql_loader_test9 (
                        id INT AUTO_INCREMENT PRIMARY KEY,
                        value VARCHAR(100)
                    ) $innodb
EOF
                $dbh->do(<<"EOF");
                    CREATE TABLE `dbicsl-test`.mysql_loader_test10 (
                        id INT AUTO_INCREMENT PRIMARY KEY,
                        value VARCHAR(100),
                        mysql_loader_test9_id INTEGER,
                        FOREIGN KEY (mysql_loader_test9_id) REFERENCES `dbicsl_test_ignored`.mysql_loader_test9 (id)
                    ) $innodb
EOF

                $databases_created = 1;

                SKIP: foreach my $db_schema (['dbicsl-test', 'dbicsl.test'], '%') {
                    if ($db_schema eq '%') {
                        try {
                            $dbh->selectall_arrayref('SHOW DATABASES');
                        }
                        catch {
                            skip 'no SHOW DATABASES privileges', 28;
                        }
                    }

                    lives_and {
                        rmtree EXTRA_DUMP_DIR;

                        my @warns;
                        local $SIG{__WARN__} = sub {
                            push @warns, $_[0] unless $_[0] =~ /\bcollides\b/;
                        };

                        make_schema_at(
                            'MySQLMultiSchema',
                            {
                                naming => 'current',
                                db_schema => $db_schema,
                                dump_directory => EXTRA_DUMP_DIR,
                                quiet => 1,
                            },
                            [ $dsn, $user, $password ],
                        );

                        diag join "\n", @warns if @warns;

                        is @warns, 0;
                    } 'dumped schema for "dbicsl-test" and "dbicsl.test" databases with no warnings';

                    my ($test_schema, $rsrc, $rs, $row, %uniqs, $rel_info);

                    lives_and {
                        ok $test_schema = MySQLMultiSchema->connect($dsn, $user, $password);
                    } 'connected test schema';

                    lives_and {
                        ok $rsrc = $test_schema->source('MysqlLoaderTest4');
                    } 'got source for table in database name with dash';

                    is try { $rsrc->column_info('id')->{is_auto_increment} }, 1,
                        'column in database name with dash';

                    is try { $rsrc->column_info('value')->{data_type} }, 'varchar',
                        'column in database name with dash';

                    is try { $rsrc->column_info('value')->{size} }, 100,
                        'column in database name with dash';

                    lives_and {
                        ok $rs = $test_schema->resultset('MysqlLoaderTest4');
                    } 'got resultset for table in database name with dash';

                    lives_and {
                        ok $row = $rs->create({ value => 'foo' });
                    } 'executed SQL on table in database name with dash';

                    SKIP: {
                        skip 'set the environment variable DBICTEST_MYSQL_INNODB=1 to test relationships', 3 unless $test_innodb;

                        $rel_info = try { $rsrc->relationship_info('dbicsl_dash_test_mysql_loader_test5') };

                        is_deeply $rel_info->{cond}, {
                            'foreign.four_id' => 'self.id'
                        }, 'relationship in database name with dash';

                        is $rel_info->{attrs}{accessor}, 'single',
                            'relationship in database name with dash';

                        is $rel_info->{attrs}{join_type}, 'LEFT',
                            'relationship in database name with dash';
                    }

                    lives_and {
                        ok $rsrc = $test_schema->source('DbicslDashTestMysqlLoaderTest5');
                    } 'got source for table in database name with dash';

                    %uniqs = try { $rsrc->unique_constraints };

                    is keys %uniqs, 2,
                        'got unique and primary constraint in database name with dash';

                    delete $uniqs{primary};

                    is_deeply ((values %uniqs)[0], ['four_id'],
                        'unique constraint is correct in database name with dash');

                    lives_and {
                        ok $rsrc = $test_schema->source('MysqlLoaderTest6');
                    } 'got source for table in database name with dot';

                    is try { $rsrc->column_info('id')->{is_auto_increment} }, 1,
                        'column in database name with dot introspected correctly';

                    is try { $rsrc->column_info('value')->{data_type} }, 'varchar',
                        'column in database name with dot introspected correctly';

                    is try { $rsrc->column_info('value')->{size} }, 100,
                        'column in database name with dot introspected correctly';

                    lives_and {
                        ok $rs = $test_schema->resultset('MysqlLoaderTest6');
                    } 'got resultset for table in database name with dot';

                    lives_and {
                        ok $row = $rs->create({ value => 'foo' });
                    } 'executed SQL on table in database name with dot';

                    SKIP: {
                        skip 'set the environment variable DBICTEST_MYSQL_INNODB=1 to test relationships', 3 unless $test_innodb;

                        $rel_info = try { $rsrc->relationship_info('mysql_loader_test7') };

                        is_deeply $rel_info->{cond}, {
                            'foreign.six_id' => 'self.id'
                        }, 'relationship in database name with dot';

                        is $rel_info->{attrs}{accessor}, 'single',
                            'relationship in database name with dot';

                        is $rel_info->{attrs}{join_type}, 'LEFT',
                            'relationship in database name with dot';
                    }

                    lives_and {
                        ok $rsrc = $test_schema->source('MysqlLoaderTest7');
                    } 'got source for table in database name with dot';

                    %uniqs = try { $rsrc->unique_constraints };

                    is keys %uniqs, 2,
                        'got unique and primary constraint in database name with dot';

                    delete $uniqs{primary};

                    is_deeply ((values %uniqs)[0], ['six_id'],
                        'unique constraint is correct in database name with dot');

                    SKIP: {
                        skip 'set the environment variable DBICTEST_MYSQL_INNODB=1 to test relationships', 4 unless $test_innodb;

                        lives_and {
                            ok $test_schema->source('MysqlLoaderTest6')
                                ->has_relationship('mysql_loader_test4');
                        } 'cross-database relationship in multi-db_schema';

                        lives_and {
                            ok $test_schema->source('MysqlLoaderTest4')
                                ->has_relationship('mysql_loader_test6s');
                        } 'cross-database relationship in multi-db_schema';

                        lives_and {
                            ok $test_schema->source('MysqlLoaderTest8')
                                ->has_relationship('mysql_loader_test7');
                        } 'cross-database relationship in multi-db_schema';

                        lives_and {
                            ok $test_schema->source('MysqlLoaderTest7')
                                ->has_relationship('mysql_loader_test8s');
                        } 'cross-database relationship in multi-db_schema';
                    }
                }
            }
        },
    },
);

if( !$dsn || !$user ) {
    $tester->skip_tests('You need to set the DBICTEST_MYSQL_DSN, DBICTEST_MYSQL_USER, and DBICTEST_MYSQL_PASS environment variables');
}
else {
    diag $skip_rels_msg if not $test_innodb;
    $tester->run_tests();
}

END {
    if (not $ENV{SCHEMA_LOADER_TESTS_NOCLEANUP}) {
        if ($databases_created && (my $dbh = try { $schema->storage->dbh })) {
            foreach my $table ('`dbicsl-test`.mysql_loader_test10',
                               'dbicsl_test_ignored.mysql_loader_test9',
                               '`dbicsl-test`.mysql_loader_test8',
                               '`dbicsl.test`.mysql_loader_test7',
                               '`dbicsl.test`.mysql_loader_test6',
                               '`dbicsl.test`.mysql_loader_test5',
                               '`dbicsl-test`.mysql_loader_test5',
                               '`dbicsl-test`.mysql_loader_test4') {
                try {
                    $dbh->do("DROP TABLE $table");
                }
                catch {
                    diag "Error dropping table: $_";
                };
            }

            foreach my $db (qw/dbicsl-test dbicsl.test dbicsl_test_ignored/) {
                try {
                    $dbh->do("DROP DATABASE `$db`");
                }
                catch {
                    diag "Error dropping test database $db: $_";
                };
            }
        }
        rmtree EXTRA_DUMP_DIR;
    }
}
# vim:et sts=4 sw=4 tw=0:
Commit	Line	Data
a78e3fed	1	use strict;
c4a69b87	2	use warnings;
26334ec1	3	use Test::More;
c4a69b87	4	use Test::Exception;
	5	use Try::Tiny;
	6	use File::Path 'rmtree';
	7	use DBIx::Class::Schema::Loader::Utils 'slurp_file';
	8	use DBIx::Class::Schema::Loader 'make_schema_at';
	9
c2849787	10	use lib qw(t/lib);
c4a69b87	11
fbd83464	12	use dbixcsl_common_tests;
c4a69b87	13	use dbixcsl_test_dir '$tdir';
	14
	15	use constant EXTRA_DUMP_DIR => "$tdir/mysql_extra_dump";
a78e3fed	16
9e978a19	17	my $dsn = $ENV{DBICTEST_MYSQL_DSN} \|\| '';
	18	my $user = $ENV{DBICTEST_MYSQL_USER} \|\| '';
	19	my $password = $ENV{DBICTEST_MYSQL_PASS} \|\| '';
	20	my $test_innodb = $ENV{DBICTEST_MYSQL_INNODB} \|\| 0;
a78e3fed	21
c4a69b87	22	my $skip_rels_msg = 'You need to set the environment variable DBICTEST_MYSQL_INNODB=1 to test relationships.';
a78e3fed	23
e00d61ac	24	my $innodb = $test_innodb ? q{Engine=InnoDB} : '';
e00d61ac	25
c4a69b87	26	my ($schema, $databases_created); # for cleanup in END for extra tests
c4a69b87	27
fbd83464	28	my $tester = dbixcsl_common_tests->new(
52bf3f26	29	vendor => 'Mysql',
52bf3f26	30	auto_inc_pk => 'INTEGER NOT NULL PRIMARY KEY AUTO_INCREMENT',
e00d61ac	31	innodb => $innodb,
52bf3f26	32	dsn => $dsn,
	33	user => $user,
	34	password => $password,
309e2aa1	35	connect_info_opts=> { on_connect_call => 'set_strict_mode' },
eb040f78	36	loader_options => { preserve_case => 1 },
8ff3a23a	37	skip_rels => $test_innodb ? 0 : $skip_rels_msg,
6ebd0f33	38	quote_char => '`',
52bf3f26	39	no_inline_rels => 1,
52bf3f26	40	no_implicit_rels => 1,
98857177	41	data_types => {
	42	# http://dev.mysql.com/doc/refman/5.5/en/data-type-overview.html
	43	# Numeric Types
26334ec1	44	'bit' => { data_type => 'bit', size => 1 },
	45	'bit(11)' => { data_type => 'bit', size => 11 },
	46
	47	'bool' => { data_type => 'tinyint' },
	48	'boolean' => { data_type => 'tinyint' },
	49	'tinyint' => { data_type => 'tinyint' },
	50	'tinyint unsigned'
	51	=> { data_type => 'tinyint', extra => { unsigned => 1 } },
	52	'smallint' => { data_type => 'smallint' },
	53	'smallint unsigned'
	54	=> { data_type => 'smallint', extra => { unsigned => 1 } },
	55	'mediumint' => { data_type => 'mediumint' },
	56	'mediumint unsigned'
	57	=> { data_type => 'mediumint', extra => { unsigned => 1 } },
	58	'int' => { data_type => 'integer' },
	59	'int unsigned'
	60	=> { data_type => 'integer', extra => { unsigned => 1 } },
	61	'integer' => { data_type => 'integer' },
	62	'integer unsigned'
	63	=> { data_type => 'integer', extra => { unsigned => 1 } },
33aa3462	64	'integer not null'
33aa3462	65	=> { data_type => 'integer' },
26334ec1	66	'bigint' => { data_type => 'bigint' },
	67	'bigint unsigned'
	68	=> { data_type => 'bigint', extra => { unsigned => 1 } },
	69
	70	'serial' => { data_type => 'bigint', is_auto_increment => 1, extra => { unsigned => 1 } },
	71
	72	'float' => { data_type => 'float' },
	73	'float unsigned'
	74	=> { data_type => 'float', extra => { unsigned => 1 } },
	75	'double' => { data_type => 'double precision' },
	76	'double unsigned'
	77	=> { data_type => 'double precision', extra => { unsigned => 1 } },
98857177	78	'double precision' =>
26334ec1	79	{ data_type => 'double precision' },
	80	'double precision unsigned'
	81	=> { data_type => 'double precision', extra => { unsigned => 1 } },
	82
	83	# we skip 'real' because its alias depends on the 'REAL AS FLOAT' setting
	84
	85	'float(2)' => { data_type => 'float' },
	86	'float(24)' => { data_type => 'float' },
	87	'float(25)' => { data_type => 'double precision' },
	88
	89	'float(3,3)' => { data_type => 'float', size => [3,3] },
	90	'double(3,3)' => { data_type => 'double precision', size => [3,3] },
	91	'double precision(3,3)'
	92	=> { data_type => 'double precision', size => [3,3] },
	93
	94	'decimal' => { data_type => 'decimal' },
	95	'decimal unsigned'
	96	=> { data_type => 'decimal', extra => { unsigned => 1 } },
	97	'dec' => { data_type => 'decimal' },
	98	'numeric' => { data_type => 'decimal' },
	99	'fixed' => { data_type => 'decimal' },
	100
	101	'decimal(3)' => { data_type => 'decimal', size => [3,0] },
	102
	103	'decimal(3,3)' => { data_type => 'decimal', size => [3,3] },
	104	'dec(3,3)' => { data_type => 'decimal', size => [3,3] },
	105	'numeric(3,3)' => { data_type => 'decimal', size => [3,3] },
	106	'fixed(3,3)' => { data_type => 'decimal', size => [3,3] },
	107
98857177	108	# Date and Time Types
58333f16	109	'date' => { data_type => 'date', datetime_undef_if_invalid => 1 },
58333f16	110	'datetime' => { data_type => 'datetime', datetime_undef_if_invalid => 1 },
6e566cc4	111	'timestamp default current_timestamp'
58333f16	112	=> { data_type => 'timestamp', default_value => \'current_timestamp', datetime_undef_if_invalid => 1 },
26334ec1	113	'time' => { data_type => 'time' },
	114	'year' => { data_type => 'year' },
	115	'year(4)' => { data_type => 'year' },
	116	'year(2)' => { data_type => 'year', size => 2 },
	117
98857177	118	# String Types
26334ec1	119	'char' => { data_type => 'char', size => 1 },
	120	'char(11)' => { data_type => 'char', size => 11 },
	121	'varchar(20)' => { data_type => 'varchar', size => 20 },
	122	'binary' => { data_type => 'binary', size => 1 },
	123	'binary(11)' => { data_type => 'binary', size => 11 },
	124	'varbinary(20)'=> { data_type => 'varbinary', size => 20 },
	125
	126	'tinyblob' => { data_type => 'tinyblob' },
	127	'tinytext' => { data_type => 'tinytext' },
	128	'blob' => { data_type => 'blob' },
	129
	130	# text(M) types will map to the appropriate type, length is not stored
	131	'text' => { data_type => 'text' },
	132
	133	'mediumblob' => { data_type => 'mediumblob' },
	134	'mediumtext' => { data_type => 'mediumtext' },
	135	'longblob' => { data_type => 'longblob' },
	136	'longtext' => { data_type => 'longtext' },
	137
33aa3462	138	"enum('foo','bar','baz')"
26334ec1	139	=> { data_type => 'enum', extra => { list => [qw/foo bar baz/] } },
e00d61ac	140	"enum('foo \\'bar\\' baz', 'foo ''bar'' quux')"
	141	=> { data_type => 'enum', extra => { list => [q{foo 'bar' baz}, q{foo 'bar' quux}] } },
	142	"set('foo \\'bar\\' baz', 'foo ''bar'' quux')"
	143	=> { data_type => 'set', extra => { list => [q{foo 'bar' baz}, q{foo 'bar' quux}] } },
33aa3462	144	"set('foo','bar','baz')"
26334ec1	145	=> { data_type => 'set', extra => { list => [qw/foo bar baz/] } },
698c11d8	146
	147	# RT#68717
	148	"enum('11,10 (<500)/0 DUN','4,90 (<120)/0 EUR') NOT NULL default '11,10 (<500)/0 DUN'"
	149	=> { data_type => 'enum', extra => { list => ['11,10 (<500)/0 DUN', '4,90 (<120)/0 EUR'] }, default_value => '11,10 (<500)/0 DUN' },
	150	"set('11_10 (<500)/0 DUN','4_90 (<120)/0 EUR') NOT NULL default '11_10 (<500)/0 DUN'"
	151	=> { data_type => 'set', extra => { list => ['11_10 (<500)/0 DUN', '4_90 (<120)/0 EUR'] }, default_value => '11_10 (<500)/0 DUN' },
0da287c8	152	"enum('19,90 (<500)/0 EUR','4,90 (<120)/0 EUR','7,90 (<200)/0 CHF','300 (<6000)/0 CZK','4,90 (<100)/0 EUR','39 (<900)/0 DKK','299 (<5000)/0 EEK','9,90 (<250)/0 EUR','3,90 (<100)/0 GBP','3000 (<70000)/0 HUF','4000 (<70000)/0 JPY','13,90 (<200)/0 LVL','99 (<2500)/0 NOK','39 (<1000)/0 PLN','1000 (<20000)/0 RUB','49 (<2500)/0 SEK','29 (<600)/0 USD','19,90 (<600)/0 EUR','0 EUR','0 CHF') NOT NULL default '19,90 (<500)/0 EUR'"
0da287c8	153	=> { data_type => 'enum', extra => { list => ['19,90 (<500)/0 EUR','4,90 (<120)/0 EUR','7,90 (<200)/0 CHF','300 (<6000)/0 CZK','4,90 (<100)/0 EUR','39 (<900)/0 DKK','299 (<5000)/0 EEK','9,90 (<250)/0 EUR','3,90 (<100)/0 GBP','3000 (<70000)/0 HUF','4000 (<70000)/0 JPY','13,90 (<200)/0 LVL','99 (<2500)/0 NOK','39 (<1000)/0 PLN','1000 (<20000)/0 RUB','49 (<2500)/0 SEK','29 (<600)/0 USD','19,90 (<600)/0 EUR','0 EUR','0 CHF'] }, default_value => '19,90 (<500)/0 EUR' },
98857177	154	},
3de915bc	155	extra => {
3de915bc	156	create => [
e00d61ac	157	qq{
6ebd0f33	158	CREATE TABLE `mysql_loader-test1` (
5c06aa08	159	id INT AUTO_INCREMENT PRIMARY KEY COMMENT 'The\15\12Column',
3de915bc	160	value varchar(100)
5c06aa08	161	) $innodb COMMENT 'The\15\12Table'
3de915bc	162	},
3de915bc	163	q{
6ebd0f33	164	CREATE VIEW mysql_loader_test2 AS SELECT * FROM `mysql_loader-test1`
3de915bc	165	},
e00d61ac	166	# RT#68717
	167	qq{
	168	CREATE TABLE `mysql_loader_test3` (
	169	`ISO3_code` char(3) NOT NULL default '',
	170	`lang_pref` enum('de','en','fr','nl','dk','es','se') NOT NULL,
	171	`vat` decimal(4,2) default '16.00',
	172	`price_group` enum('EUR_DEFAULT','GBP_GBR','EUR_AUT_BEL_FRA_IRL_NLD','EUR_DNK_SWE','EUR_AUT','EUR_BEL','EUR_FIN','EUR_FRA','EUR_IRL','EUR_NLD','EUR_DNK','EUR_POL','EUR_PRT','EUR_SWE','CHF_CHE','DKK_DNK','SEK_SWE','NOK_NOR','USD_USA','CZK_CZE','PLN_POL','RUB_RUS','HUF_HUN','SKK_SVK','JPY_JPN','LVL_LVA','ROL_ROU','EEK_EST') NOT NULL default 'EUR_DEFAULT',
	173	`del_group` enum('19,90 (<500)/0 EUR','4,90 (<120)/0 EUR','7,90 (<200)/0 CHF','300 (<6000)/0 CZK','4,90 (<100)/0 EUR','39 (<900)/0 DKK','299 (<5000)/0 EEK','9,90 (<250)/0 EUR','3,90 (<100)/0 GBP','3000 (<70000)/0 HUF','4000 (<70000)/0 JPY','13,90 (<200)/0 LVL','99 (<2500)/0 NOK','39 (<1000)/0 PLN','1000 (<20000)/0 RUB','49 (<2500)/0 SEK','29 (<600)/0 USD','19,90 (<600)/0 EUR','0 EUR','0 CHF') NOT NULL default '19,90 (<500)/0 EUR',
	174	`express_del_group` enum('NO','39 EUR (EXPRESS)','59 EUR (EXPRESS)','79 CHF (EXPRESS)','49 EUR (EXPRESS)','990 CZK (EXPRESS)','19,9 EUR (EXPRESS)','290 DKK (EXPRESS)','990 EEK (EXPRESS)','39 GBP (EXPRESS)','14000 HUF (EXPRESS)','49 LVL (EXPRESS)','590 NOK (EXPRESS)','250 PLN (EXPRESS)','490 SEK (EXPRESS)') NOT NULL default 'NO',
	175	`pmethod` varchar(255) NOT NULL default 'VISA,MASTER',
	176	`delivery_time` varchar(5) default NULL,
	177	`express_delivery_time` varchar(5) default NULL,
	178	`eu` int(1) default '0',
	179	`cod_costs` varchar(12) default NULL,
	180	PRIMARY KEY (`ISO3_code`)
	181	) $innodb
	182	},
3de915bc	183	],
3de915bc	184	pre_drop_ddl => [ 'DROP VIEW mysql_loader_test2', ],
e00d61ac	185	drop => [ 'mysql_loader-test1', 'mysql_loader_test3' ],
5975bbe6	186	count => 5 + 30 * 2,
3de915bc	187	run => sub {
c4a69b87	188	my ($monikers, $classes);
c4a69b87	189	($schema, $monikers, $classes) = @_;
3de915bc	190
6ebd0f33	191	is $monikers->{'mysql_loader-test1'}, 'MysqlLoaderTest1',
	192	'table with dash correctly monikerized';
	193
e00d61ac	194	my $rsrc = $schema->source('MysqlLoaderTest2');
3de915bc	195
	196	is $rsrc->column_info('value')->{data_type}, 'varchar',
	197	'view introspected successfully';
e00d61ac	198
	199	$rsrc = $schema->source('MysqlLoaderTest3');
	200
	201	is_deeply $rsrc->column_info('del_group')->{extra}{list}, ['19,90 (<500)/0 EUR','4,90 (<120)/0 EUR','7,90 (<200)/0 CHF','300 (<6000)/0 CZK','4,90 (<100)/0 EUR','39 (<900)/0 DKK','299 (<5000)/0 EEK','9,90 (<250)/0 EUR','3,90 (<100)/0 GBP','3000 (<70000)/0 HUF','4000 (<70000)/0 JPY','13,90 (<200)/0 LVL','99 (<2500)/0 NOK','39 (<1000)/0 PLN','1000 (<20000)/0 RUB','49 (<2500)/0 SEK','29 (<600)/0 USD','19,90 (<600)/0 EUR','0 EUR','0 CHF'],
	202	'hairy enum introspected correctly';
5c06aa08	203
5c06aa08	204	my $class = $classes->{'mysql_loader-test1'};
ea998e8e	205	my $filename = $schema->loader->get_dump_filename($class);
5c06aa08	206
ea998e8e	207	my $code = slurp_file $filename;
5c06aa08	208
	209	like $code, qr/^=head1 NAME\n\n^$class - The\nTable\n\n^=cut\n/m,
	210	'table comment';
	211
	212	like $code, qr/^=head2 id\n\n(.+:.+\n)+\nThe\nColumn\n\n/m,
	213	'column comment and attrs';
	214
c4a69b87	215	SKIP: {
	216	my $dbh = $schema->storage->dbh;
	217
	218	try {
	219	$dbh->do('CREATE DATABASE `dbicsl-test`');
	220	}
	221	catch {
4c2e2ce9	222	diag "CREATE DATABASE returned error: '$_'";
5975bbe6	223	skip "no CREATE DATABASE privileges", 30 * 2;
c4a69b87	224	};
	225
	226	$dbh->do(<<"EOF");
	227	CREATE TABLE `dbicsl-test`.mysql_loader_test4 (
	228	id INT AUTO_INCREMENT PRIMARY KEY,
	229	value VARCHAR(100)
	230	) $innodb
	231	EOF
	232	$dbh->do(<<"EOF");
	233	CREATE TABLE `dbicsl-test`.mysql_loader_test5 (
	234	id INT AUTO_INCREMENT PRIMARY KEY,
	235	value VARCHAR(100),
5975bbe6	236	four_id INTEGER,
5975bbe6	237	CONSTRAINT loader_test5_uniq UNIQUE (four_id),
c4a69b87	238	FOREIGN KEY (four_id) REFERENCES `dbicsl-test`.mysql_loader_test4 (id)
	239	) $innodb
	240	EOF
5975bbe6	241
c4a69b87	242	$dbh->do('CREATE DATABASE `dbicsl.test`');
5975bbe6	243
	244	# Test that keys are correctly cached by naming the primary and
	245	# unique keys in this table with the same name as a table in
	246	# the `dbicsl-test` schema differently.
	247	$dbh->do(<<"EOF");
	248	CREATE TABLE `dbicsl.test`.mysql_loader_test5 (
	249	pk INT AUTO_INCREMENT PRIMARY KEY,
	250	value VARCHAR(100),
	251	four_id INTEGER,
	252	CONSTRAINT loader_test5_uniq UNIQUE (four_id),
	253	FOREIGN KEY (four_id) REFERENCES `dbicsl-test`.mysql_loader_test4 (id)
	254	) $innodb
	255	EOF
	256
c4a69b87	257	$dbh->do(<<"EOF");
	258	CREATE TABLE `dbicsl.test`.mysql_loader_test6 (
	259	id INT AUTO_INCREMENT PRIMARY KEY,
	260	value VARCHAR(100),
	261	mysql_loader_test4_id INTEGER,
	262	FOREIGN KEY (mysql_loader_test4_id) REFERENCES `dbicsl-test`.mysql_loader_test4 (id)
	263	) $innodb
	264	EOF
	265	$dbh->do(<<"EOF");
	266	CREATE TABLE `dbicsl.test`.mysql_loader_test7 (
	267	id INT AUTO_INCREMENT PRIMARY KEY,
	268	value VARCHAR(100),
	269	six_id INTEGER UNIQUE,
	270	FOREIGN KEY (six_id) REFERENCES `dbicsl.test`.mysql_loader_test6 (id)
	271	) $innodb
	272	EOF
	273	$dbh->do(<<"EOF");
	274	CREATE TABLE `dbicsl-test`.mysql_loader_test8 (
	275	id INT AUTO_INCREMENT PRIMARY KEY,
	276	value VARCHAR(100),
	277	mysql_loader_test7_id INTEGER,
	278	FOREIGN KEY (mysql_loader_test7_id) REFERENCES `dbicsl.test`.mysql_loader_test7 (id)
	279	) $innodb
	280	EOF
2fa86d8b	281	# Test dumping a rel to a table that's not part of the dump.
	282	$dbh->do('CREATE DATABASE `dbicsl_test_ignored`');
	283	$dbh->do(<<"EOF");
	284	CREATE TABLE `dbicsl_test_ignored`.mysql_loader_test9 (
	285	id INT AUTO_INCREMENT PRIMARY KEY,
	286	value VARCHAR(100)
	287	) $innodb
	288	EOF
	289	$dbh->do(<<"EOF");
	290	CREATE TABLE `dbicsl-test`.mysql_loader_test10 (
	291	id INT AUTO_INCREMENT PRIMARY KEY,
	292	value VARCHAR(100),
	293	mysql_loader_test9_id INTEGER,
	294	FOREIGN KEY (mysql_loader_test9_id) REFERENCES `dbicsl_test_ignored`.mysql_loader_test9 (id)
	295	) $innodb
	296	EOF
c4a69b87	297
	298	$databases_created = 1;
	299
	300	SKIP: foreach my $db_schema (['dbicsl-test', 'dbicsl.test'], '%') {
	301	if ($db_schema eq '%') {
	302	try {
	303	$dbh->selectall_arrayref('SHOW DATABASES');
	304	}
	305	catch {
	306	skip 'no SHOW DATABASES privileges', 28;
	307	}
	308	}
	309
	310	lives_and {
	311	rmtree EXTRA_DUMP_DIR;
	312
	313	my @warns;
	314	local $SIG{__WARN__} = sub {
	315	push @warns, $_[0] unless $_[0] =~ /\bcollides\b/;
	316	};
	317
	318	make_schema_at(
	319	'MySQLMultiSchema',
	320	{
	321	naming => 'current',
	322	db_schema => $db_schema,
	323	dump_directory => EXTRA_DUMP_DIR,
	324	quiet => 1,
	325	},
	326	[ $dsn, $user, $password ],
	327	);
	328
	329	diag join "\n", @warns if @warns;
	330
	331	is @warns, 0;
	332	} 'dumped schema for "dbicsl-test" and "dbicsl.test" databases with no warnings';
	333
	334	my ($test_schema, $rsrc, $rs, $row, %uniqs, $rel_info);
	335
	336	lives_and {
	337	ok $test_schema = MySQLMultiSchema->connect($dsn, $user, $password);
	338	} 'connected test schema';
	339
	340	lives_and {
4c2e2ce9	341	ok $rsrc = $test_schema->source('MysqlLoaderTest4');
c4a69b87	342	} 'got source for table in database name with dash';
	343
	344	is try { $rsrc->column_info('id')->{is_auto_increment} }, 1,
	345	'column in database name with dash';
	346
	347	is try { $rsrc->column_info('value')->{data_type} }, 'varchar',
	348	'column in database name with dash';
	349
	350	is try { $rsrc->column_info('value')->{size} }, 100,
	351	'column in database name with dash';
	352
	353	lives_and {
4c2e2ce9	354	ok $rs = $test_schema->resultset('MysqlLoaderTest4');
c4a69b87	355	} 'got resultset for table in database name with dash';
	356
	357	lives_and {
	358	ok $row = $rs->create({ value => 'foo' });
	359	} 'executed SQL on table in database name with dash';
	360
	361	SKIP: {
	362	skip 'set the environment variable DBICTEST_MYSQL_INNODB=1 to test relationships', 3 unless $test_innodb;
	363
5975bbe6	364	$rel_info = try { $rsrc->relationship_info('dbicsl_dash_test_mysql_loader_test5') };
c4a69b87	365
	366	is_deeply $rel_info->{cond}, {
	367	'foreign.four_id' => 'self.id'
	368	}, 'relationship in database name with dash';
	369
	370	is $rel_info->{attrs}{accessor}, 'single',
	371	'relationship in database name with dash';
	372
	373	is $rel_info->{attrs}{join_type}, 'LEFT',
	374	'relationship in database name with dash';
	375	}
	376
	377	lives_and {
5975bbe6	378	ok $rsrc = $test_schema->source('DbicslDashTestMysqlLoaderTest5');
c4a69b87	379	} 'got source for table in database name with dash';
	380
	381	%uniqs = try { $rsrc->unique_constraints };
	382
	383	is keys %uniqs, 2,
	384	'got unique and primary constraint in database name with dash';
	385
5975bbe6	386	delete $uniqs{primary};
	387
	388	is_deeply ((values %uniqs)[0], ['four_id'],
	389	'unique constraint is correct in database name with dash');
	390
c4a69b87	391	lives_and {
4c2e2ce9	392	ok $rsrc = $test_schema->source('MysqlLoaderTest6');
c4a69b87	393	} 'got source for table in database name with dot';
	394
	395	is try { $rsrc->column_info('id')->{is_auto_increment} }, 1,
	396	'column in database name with dot introspected correctly';
	397
	398	is try { $rsrc->column_info('value')->{data_type} }, 'varchar',
	399	'column in database name with dot introspected correctly';
	400
	401	is try { $rsrc->column_info('value')->{size} }, 100,
	402	'column in database name with dot introspected correctly';
	403
	404	lives_and {
4c2e2ce9	405	ok $rs = $test_schema->resultset('MysqlLoaderTest6');
c4a69b87	406	} 'got resultset for table in database name with dot';
	407
	408	lives_and {
	409	ok $row = $rs->create({ value => 'foo' });
	410	} 'executed SQL on table in database name with dot';
	411
	412	SKIP: {
	413	skip 'set the environment variable DBICTEST_MYSQL_INNODB=1 to test relationships', 3 unless $test_innodb;
	414
	415	$rel_info = try { $rsrc->relationship_info('mysql_loader_test7') };
	416
	417	is_deeply $rel_info->{cond}, {
	418	'foreign.six_id' => 'self.id'
	419	}, 'relationship in database name with dot';
	420
	421	is $rel_info->{attrs}{accessor}, 'single',
	422	'relationship in database name with dot';
	423
	424	is $rel_info->{attrs}{join_type}, 'LEFT',
	425	'relationship in database name with dot';
	426	}
	427
	428	lives_and {
4c2e2ce9	429	ok $rsrc = $test_schema->source('MysqlLoaderTest7');
c4a69b87	430	} 'got source for table in database name with dot';
	431
	432	%uniqs = try { $rsrc->unique_constraints };
	433
	434	is keys %uniqs, 2,
	435	'got unique and primary constraint in database name with dot';
	436
5975bbe6	437	delete $uniqs{primary};
	438
	439	is_deeply ((values %uniqs)[0], ['six_id'],
	440	'unique constraint is correct in database name with dot');
	441
c4a69b87	442	SKIP: {
	443	skip 'set the environment variable DBICTEST_MYSQL_INNODB=1 to test relationships', 4 unless $test_innodb;
	444
	445	lives_and {
4c2e2ce9	446	ok $test_schema->source('MysqlLoaderTest6')
c4a69b87	447	->has_relationship('mysql_loader_test4');
	448	} 'cross-database relationship in multi-db_schema';
	449
	450	lives_and {
4c2e2ce9	451	ok $test_schema->source('MysqlLoaderTest4')
c4a69b87	452	->has_relationship('mysql_loader_test6s');
	453	} 'cross-database relationship in multi-db_schema';
	454
	455	lives_and {
4c2e2ce9	456	ok $test_schema->source('MysqlLoaderTest8')
c4a69b87	457	->has_relationship('mysql_loader_test7');
	458	} 'cross-database relationship in multi-db_schema';
	459
	460	lives_and {
4c2e2ce9	461	ok $test_schema->source('MysqlLoaderTest7')
c4a69b87	462	->has_relationship('mysql_loader_test8s');
	463	} 'cross-database relationship in multi-db_schema';
	464	}
	465	}
	466	}
3de915bc	467	},
3de915bc	468	},
a78e3fed	469	);
a78e3fed	470
9e978a19	471	if( !$dsn \|\| !$user ) {
5c06aa08	472	$tester->skip_tests('You need to set the DBICTEST_MYSQL_DSN, DBICTEST_MYSQL_USER, and DBICTEST_MYSQL_PASS environment variables');
a78e3fed	473	}
a78e3fed	474	else {
26334ec1	475	diag $skip_rels_msg if not $test_innodb;
a78e3fed	476	$tester->run_tests();
a78e3fed	477	}
26334ec1	478
c4a69b87	479	END {
	480	if (not $ENV{SCHEMA_LOADER_TESTS_NOCLEANUP}) {
	481	if ($databases_created && (my $dbh = try { $schema->storage->dbh })) {
2fa86d8b	482	foreach my $table ('`dbicsl-test`.mysql_loader_test10',
	483	'dbicsl_test_ignored.mysql_loader_test9',
	484	'`dbicsl-test`.mysql_loader_test8',
c4a69b87	485	'`dbicsl.test`.mysql_loader_test7',
c4a69b87	486	'`dbicsl.test`.mysql_loader_test6',
5975bbe6	487	'`dbicsl.test`.mysql_loader_test5',
c4a69b87	488	'`dbicsl-test`.mysql_loader_test5',
	489	'`dbicsl-test`.mysql_loader_test4') {
	490	try {
	491	$dbh->do("DROP TABLE $table");
	492	}
	493	catch {
	494	diag "Error dropping table: $_";
	495	};
	496	}
	497
2fa86d8b	498	foreach my $db (qw/dbicsl-test dbicsl.test dbicsl_test_ignored/) {
c4a69b87	499	try {
	500	$dbh->do("DROP DATABASE `$db`");
	501	}
	502	catch {
	503	diag "Error dropping test database $db: $_";
	504	};
	505	}
	506	}
	507	rmtree EXTRA_DUMP_DIR;
	508	}
	509	}
26334ec1	510	# vim:et sts=4 sw=4 tw=0: