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

use strict;
use warnings;
use utf8;
use DBIx::Class::Schema::Loader 'make_schema_at';
use DBIx::Class::Schema::Loader::Utils qw/no_warnings slurp_file/;
use Test::More;
use Test::Exception;
use Try::Tiny;
use File::Path 'rmtree';
use namespace::clean;

use lib qw(t/lib);
use dbixcsl_common_tests ();
use dbixcsl_test_dir '$tdir';

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

my $dsn      = $ENV{DBICTEST_PG_DSN} || '';
my $user     = $ENV{DBICTEST_PG_USER} || '';
my $password = $ENV{DBICTEST_PG_PASS} || '';

my $tester = dbixcsl_common_tests->new(
    vendor      => 'Pg',
    auto_inc_pk => 'SERIAL NOT NULL PRIMARY KEY',
    dsn         => $dsn,
    user        => $user,
    password    => $password,
    loader_options  => { preserve_case => 1 },
    connect_info_opts => {
        pg_enable_utf8 => 1,
        on_connect_do  => [ 'SET client_min_messages=WARNING' ],
    },
    quote_char  => '"',
    data_types  => {
        # http://www.postgresql.org/docs/7.4/interactive/datatype.html
        #
        # Numeric Types
	boolean     => { data_type => 'boolean' },
	bool        => { data_type => 'boolean' },
        'bool default false'
                    => { data_type => 'boolean', default_value => \'false' },
        'bool default true'
                    => { data_type => 'boolean', default_value => \'true' },
        'bool default 0::bool'
                    => { data_type => 'boolean', default_value => \'false' },
        'bool default 1::bool'
                    => { data_type => 'boolean', default_value => \'true' },

	bigint      => { data_type => 'bigint' },
	int8        => { data_type => 'bigint' },
	bigserial   => { data_type => 'bigint', is_auto_increment => 1 },
	serial8     => { data_type => 'bigint', is_auto_increment => 1 },
	integer     => { data_type => 'integer' },
	int         => { data_type => 'integer' },
	int4        => { data_type => 'integer' },
	serial      => { data_type => 'integer', is_auto_increment => 1 },
	serial4     => { data_type => 'integer', is_auto_increment => 1 },
	smallint    => { data_type => 'smallint' },
	int2        => { data_type => 'smallint' },

	money       => { data_type => 'money' },

	'double precision' => { data_type => 'double precision' },
	float8             => { data_type => 'double precision' },
	real               => { data_type => 'real' },
	float4             => { data_type => 'real' },
        'float(24)'        => { data_type => 'real' },
        'float(25)'        => { data_type => 'double precision' },
        'float(53)'        => { data_type => 'double precision' },
        float              => { data_type => 'double precision' },

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

        # Bit String Types
	'bit varying(2)' => { data_type => 'varbit', size => 2 },
	'varbit(2)'      => { data_type => 'varbit', size => 2 },
	'varbit'         => { data_type => 'varbit' },
	bit              => { data_type => 'bit', size => 1 },
	'bit(3)'         => { data_type => 'bit', size => 3 },

        # Network Types
	inet    => { data_type => 'inet' },
	cidr    => { data_type => 'cidr' },
	macaddr => { data_type => 'macaddr' },

        # Geometric Types
	point   => { data_type => 'point' },
	line    => { data_type => 'line' },
	lseg    => { data_type => 'lseg' },
	box     => { data_type => 'box' },
	path    => { data_type => 'path' },
	polygon => { data_type => 'polygon' },
	circle  => { data_type => 'circle' },

        # Character Types
	'character varying(2)'           => { data_type => 'varchar', size => 2 },
	'varchar(2)'                     => { data_type => 'varchar', size => 2 },
	'character(2)'                   => { data_type => 'char', size => 2 },
	'char(2)'                        => { data_type => 'char', size => 2 },
	'character'                      => { data_type => 'char', size => 1 },
	'char'                           => { data_type => 'char', size => 1 },
	text                             => { data_type => 'text' },
        # varchar with no size has unlimited size, we rewrite to 'text'
	varchar                          => { data_type => 'text',
                                              original => { data_type => 'varchar' } },
        # check that default NULL is correctly rewritten
        'varchar(3) default NULL'        => { data_type => 'varchar', size => 3,
                                              default_value => \'null' },

        # Datetime Types
	date                             => { data_type => 'date' },
	interval                         => { data_type => 'interval' },
	'interval(2)'                    => { data_type => 'interval', size => 2 },
	time                             => { data_type => 'time' },
	'time(2)'                        => { data_type => 'time', size => 2 },
	'time without time zone'         => { data_type => 'time' },
	'time(2) without time zone'      => { data_type => 'time', size => 2 },
	'time with time zone'            => { data_type => 'time with time zone' },
	'time(2) with time zone'         => { data_type => 'time with time zone', size => 2 },
	timestamp                        => { data_type => 'timestamp' },
        'timestamp default now()'
                                         => { data_type => 'timestamp', default_value => \'current_timestamp',
                                              original => { default_value => \'now()' } },
	'timestamp(2)'                   => { data_type => 'timestamp', size => 2 },
	'timestamp without time zone'    => { data_type => 'timestamp' },
	'timestamp(2) without time zone' => { data_type => 'timestamp', size => 2 },

	'timestamp with time zone'       => { data_type => 'timestamp with time zone' },
	'timestamp(2) with time zone'    => { data_type => 'timestamp with time zone', size => 2 },

        # Blob Types
	bytea => { data_type => 'bytea' },

        # Enum Types
        pg_loader_test_enum => { data_type => 'enum', extra => { custom_type_name => 'pg_loader_test_enum',
                                                                 list => [ qw/foo bar baz/] } },
    },
    pre_create => [
        q{
            CREATE TYPE pg_loader_test_enum AS ENUM (
                'foo', 'bar', 'baz'
            )
        },
    ],
    extra       => {
        create => [
            q{
                CREATE SCHEMA dbicsl_test
            },
            q{
                CREATE SEQUENCE dbicsl_test.myseq
            },
            q{
                CREATE TABLE pg_loader_test1 (
                    id INTEGER NOT NULL DEFAULT nextval('dbicsl_test.myseq') PRIMARY KEY,
                    value VARCHAR(100)
                )
            },
            qq{
                COMMENT ON TABLE pg_loader_test1 IS 'The\15\12Table ∑'
            },
            qq{
                COMMENT ON COLUMN pg_loader_test1.value IS 'The\15\12Column'
            },
            q{
                CREATE TABLE pg_loader_test2 (
                    id SERIAL PRIMARY KEY,
                    value VARCHAR(100)
                )
            },
            q{
                COMMENT ON TABLE pg_loader_test2 IS 'very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very long comment'
            },
            q{
                CREATE SCHEMA "dbicsl-test"
            },
            q{
                CREATE TABLE "dbicsl-test".pg_loader_test4 (
                    id SERIAL PRIMARY KEY,
                    value VARCHAR(100)
                )
            },
            q{
                CREATE TABLE "dbicsl-test".pg_loader_test5 (
                    id SERIAL PRIMARY KEY,
                    value VARCHAR(100),
                    four_id INTEGER UNIQUE REFERENCES "dbicsl-test".pg_loader_test4 (id)
                )
            },
            q{
                CREATE SCHEMA "dbicsl.test"
            },
            q{
                CREATE TABLE "dbicsl.test".pg_loader_test6 (
                    id SERIAL PRIMARY KEY,
                    value VARCHAR(100),
                    pg_loader_test4_id INTEGER REFERENCES "dbicsl-test".pg_loader_test4 (id)
                )
            },
            q{
                CREATE TABLE "dbicsl.test".pg_loader_test7 (
                    id SERIAL PRIMARY KEY,
                    value VARCHAR(100),
                    six_id INTEGER UNIQUE REFERENCES "dbicsl.test".pg_loader_test6 (id)
                )
            },
            q{
                CREATE TABLE "dbicsl-test".pg_loader_test8 (
                    id SERIAL PRIMARY KEY,
                    value VARCHAR(100),
                    pg_loader_test7_id INTEGER REFERENCES "dbicsl.test".pg_loader_test7 (id)
                )
            },
        ],
        pre_drop_ddl => [
            'DROP SCHEMA dbicsl_test CASCADE',
            'DROP SCHEMA "dbicsl-test" CASCADE',
            'DROP SCHEMA "dbicsl.test" CASCADE',
            'DROP TYPE pg_loader_test_enum',
        ],
        drop  => [ qw/ pg_loader_test1 pg_loader_test2 / ],
        count => 4 + 28 * 2,
        run   => sub {
            my ($schema, $monikers, $classes) = @_;

            is $schema->source($monikers->{pg_loader_test1})->column_info('id')->{sequence},
                'dbicsl_test.myseq',
                'qualified sequence detected';

            my $class    = $classes->{pg_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 value\n\n(.+:.+\n)+\nThe\nColumn\n\n/m,
                'column comment and attrs';

            $class    = $classes->{pg_loader_test2};
            $filename = $schema->loader->get_dump_filename($class);

            $code = slurp_file $filename;

            like $code, qr/^=head1 NAME\n\n^$class\n\n=head1 DESCRIPTION\n\n^very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very long comment\n\n^=cut\n/m,
                'long table comment is in DESCRIPTION';

            foreach my $db_schema (['dbicsl-test', 'dbicsl.test'], '%') {
                lives_and {
                    rmtree EXTRA_DUMP_DIR;

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

                    make_schema_at(
                        'PGMultiSchema',
                        {
                            naming => 'current',
                            db_schema => $db_schema,
                            preserve_case => 1,
                            dump_directory => EXTRA_DUMP_DIR,
                            quiet => 1,
                        },
                        [ $dsn, $user, $password, {
                            on_connect_do  => [ 'SET client_min_messages=WARNING' ],
                        } ],
                    );

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

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

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

                lives_and {
                    ok $test_schema = PGMultiSchema->connect($dsn, $user, $password, {
                        on_connect_do  => [ 'SET client_min_messages=WARNING' ],
                    });
                } 'connected test schema';

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

                lives_and {
                    ok $test_schema->source('PgLoaderTest6')
                        ->has_relationship('pg_loader_test4');
                } 'cross-schema relationship in multi-db_schema';

                lives_and {
                    ok $test_schema->source('PgLoaderTest4')
                        ->has_relationship('pg_loader_test6s');
                } 'cross-schema relationship in multi-db_schema';

                lives_and {
                    ok $test_schema->source('PgLoaderTest8')
                        ->has_relationship('pg_loader_test7');
                } 'cross-schema relationship in multi-db_schema';

                lives_and {
                    ok $test_schema->source('PgLoaderTest7')
                        ->has_relationship('pg_loader_test8s');
                } 'cross-schema relationship in multi-db_schema';
            }
        },
    },
);

if( !$dsn || !$user ) {
    $tester->skip_tests('You need to set the DBICTEST_PG_DSN, _USER, and _PASS environment variables');
}
else {
    $tester->run_tests();
}

END {
    rmtree EXTRA_DUMP_DIR unless $ENV{SCHEMA_LOADER_TESTS_NOCLEANUP};
}
# vim:et sw=4 sts=4 tw=0:
Commit	Line	Data
a78e3fed	1	use strict;
fcf328c7	2	use warnings;
fcf328c7	3	use utf8;
12b86f07	4	use DBIx::Class::Schema::Loader 'make_schema_at';
fcf328c7	5	use DBIx::Class::Schema::Loader::Utils qw/no_warnings slurp_file/;
fdd8ff16	6	use Test::More;
12b86f07	7	use Test::Exception;
12b86f07	8	use Try::Tiny;
c4a69b87	9	use File::Path 'rmtree';
fcf328c7	10	use namespace::clean;
c4a69b87	11
fcf328c7	12	use lib qw(t/lib);
fcf328c7	13	use dbixcsl_common_tests ();
c4a69b87	14	use dbixcsl_test_dir '$tdir';
	15
	16	use constant EXTRA_DUMP_DIR => "$tdir/pg_extra_dump";
a78e3fed	17
9e978a19	18	my $dsn = $ENV{DBICTEST_PG_DSN} \|\| '';
	19	my $user = $ENV{DBICTEST_PG_USER} \|\| '';
	20	my $password = $ENV{DBICTEST_PG_PASS} \|\| '';
a78e3fed	21
fbd83464	22	my $tester = dbixcsl_common_tests->new(
a78e3fed	23	vendor => 'Pg',
a78e3fed	24	auto_inc_pk => 'SERIAL NOT NULL PRIMARY KEY',
9e978a19	25	dsn => $dsn,
a78e3fed	26	user => $user,
a78e3fed	27	password => $password,
c930f78b	28	loader_options => { preserve_case => 1 },
c38ec663	29	connect_info_opts => {
af15ea33	30	pg_enable_utf8 => 1,
af15ea33	31	on_connect_do => [ 'SET client_min_messages=WARNING' ],
c38ec663	32	},
c930f78b	33	quote_char => '"',
ee07e280	34	data_types => {
760fd65c	35	# http://www.postgresql.org/docs/7.4/interactive/datatype.html
	36	#
	37	# Numeric Types
	38	boolean => { data_type => 'boolean' },
	39	bool => { data_type => 'boolean' },
45321eda	40	'bool default false'
45321eda	41	=> { data_type => 'boolean', default_value => \'false' },
96336646	42	'bool default true'
	43	=> { data_type => 'boolean', default_value => \'true' },
	44	'bool default 0::bool'
	45	=> { data_type => 'boolean', default_value => \'false' },
	46	'bool default 1::bool'
	47	=> { data_type => 'boolean', default_value => \'true' },
760fd65c	48
	49	bigint => { data_type => 'bigint' },
	50	int8 => { data_type => 'bigint' },
	51	bigserial => { data_type => 'bigint', is_auto_increment => 1 },
	52	serial8 => { data_type => 'bigint', is_auto_increment => 1 },
5163dc4a	53	integer => { data_type => 'integer' },
	54	int => { data_type => 'integer' },
	55	int4 => { data_type => 'integer' },
5163dc4a	56	serial => { data_type => 'integer', is_auto_increment => 1 },
5163dc4a	57	serial4 => { data_type => 'integer', is_auto_increment => 1 },
760fd65c	58	smallint => { data_type => 'smallint' },
	59	int2 => { data_type => 'smallint' },
	60
	61	money => { data_type => 'money' },
	62
	63	'double precision' => { data_type => 'double precision' },
	64	float8 => { data_type => 'double precision' },
	65	real => { data_type => 'real' },
	66	float4 => { data_type => 'real' },
	67	'float(24)' => { data_type => 'real' },
	68	'float(25)' => { data_type => 'double precision' },
	69	'float(53)' => { data_type => 'double precision' },
	70	float => { data_type => 'double precision' },
	71
	72	numeric => { data_type => 'numeric' },
	73	decimal => { data_type => 'numeric' },
f80b0ea7	74	'numeric(6,3)' => { data_type => 'numeric', size => [6,3] },
f80b0ea7	75	'decimal(6,3)' => { data_type => 'numeric', size => [6,3] },
760fd65c	76
760fd65c	77	# Bit String Types
f80b0ea7	78	'bit varying(2)' => { data_type => 'varbit', size => 2 },
	79	'varbit(2)' => { data_type => 'varbit', size => 2 },
	80	'varbit' => { data_type => 'varbit' },
	81	bit => { data_type => 'bit', size => 1 },
	82	'bit(3)' => { data_type => 'bit', size => 3 },
760fd65c	83
	84	# Network Types
	85	inet => { data_type => 'inet' },
	86	cidr => { data_type => 'cidr' },
	87	macaddr => { data_type => 'macaddr' },
	88
	89	# Geometric Types
	90	point => { data_type => 'point' },
	91	line => { data_type => 'line' },
	92	lseg => { data_type => 'lseg' },
	93	box => { data_type => 'box' },
	94	path => { data_type => 'path' },
	95	polygon => { data_type => 'polygon' },
	96	circle => { data_type => 'circle' },
	97
	98	# Character Types
f80b0ea7	99	'character varying(2)' => { data_type => 'varchar', size => 2 },
	100	'varchar(2)' => { data_type => 'varchar', size => 2 },
	101	'character(2)' => { data_type => 'char', size => 2 },
	102	'char(2)' => { data_type => 'char', size => 2 },
	103	'character' => { data_type => 'char', size => 1 },
	104	'char' => { data_type => 'char', size => 1 },
760fd65c	105	text => { data_type => 'text' },
f80b0ea7	106	# varchar with no size has unlimited size, we rewrite to 'text'
8e030521	107	varchar => { data_type => 'text',
8e030521	108	original => { data_type => 'varchar' } },
96336646	109	# check that default NULL is correctly rewritten
	110	'varchar(3) default NULL' => { data_type => 'varchar', size => 3,
	111	default_value => \'null' },
760fd65c	112
	113	# Datetime Types
	114	date => { data_type => 'date' },
	115	interval => { data_type => 'interval' },
f80b0ea7	116	'interval(2)' => { data_type => 'interval', size => 2 },
8e030521	117	time => { data_type => 'time' },
	118	'time(2)' => { data_type => 'time', size => 2 },
	119	'time without time zone' => { data_type => 'time' },
	120	'time(2) without time zone' => { data_type => 'time', size => 2 },
df956aad	121	'time with time zone' => { data_type => 'time with time zone' },
f80b0ea7	122	'time(2) with time zone' => { data_type => 'time with time zone', size => 2 },
f80b0ea7	123	timestamp => { data_type => 'timestamp' },
701cd3e3	124	'timestamp default now()'
	125	=> { data_type => 'timestamp', default_value => \'current_timestamp',
	126	original => { default_value => \'now()' } },
f80b0ea7	127	'timestamp(2)' => { data_type => 'timestamp', size => 2 },
	128	'timestamp without time zone' => { data_type => 'timestamp' },
	129	'timestamp(2) without time zone' => { data_type => 'timestamp', size => 2 },
760fd65c	130
df956aad	131	'timestamp with time zone' => { data_type => 'timestamp with time zone' },
f80b0ea7	132	'timestamp(2) with time zone' => { data_type => 'timestamp with time zone', size => 2 },
760fd65c	133
	134	# Blob Types
	135	bytea => { data_type => 'bytea' },
12333562	136
12333562	137	# Enum Types
b8ae4518	138	pg_loader_test_enum => { data_type => 'enum', extra => { custom_type_name => 'pg_loader_test_enum',
463c86fb	139	list => [ qw/foo bar baz/] } },
ee07e280	140	},
12333562	141	pre_create => [
	142	q{
	143	CREATE TYPE pg_loader_test_enum AS ENUM (
	144	'foo', 'bar', 'baz'
	145	)
	146	},
	147	],
fdd8ff16	148	extra => {
	149	create => [
	150	q{
7b868481	151	CREATE SCHEMA dbicsl_test
	152	},
	153	q{
	154	CREATE SEQUENCE dbicsl_test.myseq
	155	},
	156	q{
fdd8ff16	157	CREATE TABLE pg_loader_test1 (
7b868481	158	id INTEGER NOT NULL DEFAULT nextval('dbicsl_test.myseq') PRIMARY KEY,
fdd8ff16	159	value VARCHAR(100)
	160	)
	161	},
fd97abca	162	qq{
af15ea33	163	COMMENT ON TABLE pg_loader_test1 IS 'The\15\12Table ∑'
fdd8ff16	164	},
fd97abca	165	qq{
fd97abca	166	COMMENT ON COLUMN pg_loader_test1.value IS 'The\15\12Column'
fdd8ff16	167	},
4b9fb838	168	q{
4b9fb838	169	CREATE TABLE pg_loader_test2 (
12b86f07	170	id SERIAL PRIMARY KEY,
4b9fb838	171	value VARCHAR(100)
	172	)
	173	},
	174	q{
	175	COMMENT ON TABLE pg_loader_test2 IS 'very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very long comment'
	176	},
12b86f07	177	q{
	178	CREATE SCHEMA "dbicsl-test"
	179	},
	180	q{
c4a69b87	181	CREATE TABLE "dbicsl-test".pg_loader_test4 (
12b86f07	182	id SERIAL PRIMARY KEY,
	183	value VARCHAR(100)
	184	)
	185	},
	186	q{
c4a69b87	187	CREATE TABLE "dbicsl-test".pg_loader_test5 (
12b86f07	188	id SERIAL PRIMARY KEY,
12b86f07	189	value VARCHAR(100),
c4a69b87	190	four_id INTEGER UNIQUE REFERENCES "dbicsl-test".pg_loader_test4 (id)
12b86f07	191	)
	192	},
	193	q{
	194	CREATE SCHEMA "dbicsl.test"
	195	},
	196	q{
c4a69b87	197	CREATE TABLE "dbicsl.test".pg_loader_test6 (
12b86f07	198	id SERIAL PRIMARY KEY,
c4a69b87	199	value VARCHAR(100),
c4a69b87	200	pg_loader_test4_id INTEGER REFERENCES "dbicsl-test".pg_loader_test4 (id)
12b86f07	201	)
	202	},
	203	q{
c4a69b87	204	CREATE TABLE "dbicsl.test".pg_loader_test7 (
	205	id SERIAL PRIMARY KEY,
	206	value VARCHAR(100),
	207	six_id INTEGER UNIQUE REFERENCES "dbicsl.test".pg_loader_test6 (id)
	208	)
	209	},
	210	q{
	211	CREATE TABLE "dbicsl-test".pg_loader_test8 (
12b86f07	212	id SERIAL PRIMARY KEY,
12b86f07	213	value VARCHAR(100),
c4a69b87	214	pg_loader_test7_id INTEGER REFERENCES "dbicsl.test".pg_loader_test7 (id)
12b86f07	215	)
12b86f07	216	},
fdd8ff16	217	],
7b868481	218	pre_drop_ddl => [
7b868481	219	'DROP SCHEMA dbicsl_test CASCADE',
12b86f07	220	'DROP SCHEMA "dbicsl-test" CASCADE',
12b86f07	221	'DROP SCHEMA "dbicsl.test" CASCADE',
12333562	222	'DROP TYPE pg_loader_test_enum',
7b868481	223	],
9065de34	224	drop => [ qw/ pg_loader_test1 pg_loader_test2 / ],
c4a69b87	225	count => 4 + 28 * 2,
fdd8ff16	226	run => sub {
	227	my ($schema, $monikers, $classes) = @_;
	228
7b868481	229	is $schema->source($monikers->{pg_loader_test1})->column_info('id')->{sequence},
	230	'dbicsl_test.myseq',
	231	'qualified sequence detected';
	232
fdd8ff16	233	my $class = $classes->{pg_loader_test1};
c4a69b87	234	my $filename = $schema->loader->get_dump_filename($class);
fdd8ff16	235
fcf328c7	236	my $code = slurp_file $filename;
fdd8ff16	237
af15ea33	238	like $code, qr/^=head1 NAME\n\n^$class - The\nTable ∑\n\n^=cut\n/m,
fdd8ff16	239	'table comment';
fdd8ff16	240
fd97abca	241	like $code, qr/^=head2 value\n\n(.+:.+\n)+\nThe\nColumn\n\n/m,
79a00530	242	'column comment and attrs';
baff904e	243
4b9fb838	244	$class = $classes->{pg_loader_test2};
c4a69b87	245	$filename = $schema->loader->get_dump_filename($class);
4b9fb838	246
fcf328c7	247	$code = slurp_file $filename;
4b9fb838	248
	249	like $code, qr/^=head1 NAME\n\n^$class\n\n=head1 DESCRIPTION\n\n^very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very very long comment\n\n^=cut\n/m,
	250	'long table comment is in DESCRIPTION';
12b86f07	251
c4a69b87	252	foreach my $db_schema (['dbicsl-test', 'dbicsl.test'], '%') {
	253	lives_and {
	254	rmtree EXTRA_DUMP_DIR;
	255
	256	my @warns;
	257	local $SIG{__WARN__} = sub {
	258	push @warns, $_[0] unless $_[0] =~ /\bcollides\b/;
	259	};
	260
12b86f07	261	make_schema_at(
c4a69b87	262	'PGMultiSchema',
12b86f07	263	{
12b86f07	264	naming => 'current',
c4a69b87	265	db_schema => $db_schema,
12b86f07	266	preserve_case => 1,
c4a69b87	267	dump_directory => EXTRA_DUMP_DIR,
c4a69b87	268	quiet => 1,
12b86f07	269	},
	270	[ $dsn, $user, $password, {
	271	on_connect_do => [ 'SET client_min_messages=WARNING' ],
	272	} ],
	273	);
12b86f07	274
c4a69b87	275	diag join "\n", @warns if @warns;
12b86f07	276
c4a69b87	277	is @warns, 0;
c4a69b87	278	} 'dumped schema for "dbicsl-test" and "dbicsl.test" schemas with no warnings';
12b86f07	279
c4a69b87	280	my ($test_schema, $rsrc, $rs, $row, %uniqs, $rel_info);
12b86f07	281
c4a69b87	282	lives_and {
	283	ok $test_schema = PGMultiSchema->connect($dsn, $user, $password, {
	284	on_connect_do => [ 'SET client_min_messages=WARNING' ],
	285	});
	286	} 'connected test schema';
12b86f07	287
c4a69b87	288	lives_and {
	289	ok $rsrc = $test_schema->source('PgLoaderTest4');
	290	} 'got source for table in schema name with dash';
12b86f07	291
c4a69b87	292	is try { $rsrc->column_info('id')->{is_auto_increment} }, 1,
c4a69b87	293	'column in schema name with dash';
12b86f07	294
c4a69b87	295	is try { $rsrc->column_info('value')->{data_type} }, 'varchar',
c4a69b87	296	'column in schema name with dash';
12b86f07	297
c4a69b87	298	is try { $rsrc->column_info('value')->{size} }, 100,
c4a69b87	299	'column in schema name with dash';
12b86f07	300
c4a69b87	301	lives_and {
	302	ok $rs = $test_schema->resultset('PgLoaderTest4');
	303	} 'got resultset for table in schema name with dash';
12b86f07	304
c4a69b87	305	lives_and {
	306	ok $row = $rs->create({ value => 'foo' });
	307	} 'executed SQL on table in schema name with dash';
12b86f07	308
c4a69b87	309	$rel_info = try { $rsrc->relationship_info('pg_loader_test5') };
12b86f07	310
c4a69b87	311	is_deeply $rel_info->{cond}, {
	312	'foreign.four_id' => 'self.id'
	313	}, 'relationship in schema name with dash';
12b86f07	314
c4a69b87	315	is $rel_info->{attrs}{accessor}, 'single',
	316	'relationship in schema name with dash';
	317
	318	is $rel_info->{attrs}{join_type}, 'LEFT',
	319	'relationship in schema name with dash';
	320
	321	lives_and {
	322	ok $rsrc = $test_schema->source('PgLoaderTest5');
	323	} 'got source for table in schema name with dash';
	324
	325	%uniqs = try { $rsrc->unique_constraints };
12b86f07	326
c4a69b87	327	is keys %uniqs, 2,
c4a69b87	328	'got unique and primary constraint in schema name with dash';
12b86f07	329
c4a69b87	330	lives_and {
	331	ok $rsrc = $test_schema->source('PgLoaderTest6');
	332	} 'got source for table in schema name with dot';
12b86f07	333
c4a69b87	334	is try { $rsrc->column_info('id')->{is_auto_increment} }, 1,
c4a69b87	335	'column in schema name with dot introspected correctly';
12b86f07	336
c4a69b87	337	is try { $rsrc->column_info('value')->{data_type} }, 'varchar',
c4a69b87	338	'column in schema name with dot introspected correctly';
12b86f07	339
c4a69b87	340	is try { $rsrc->column_info('value')->{size} }, 100,
c4a69b87	341	'column in schema name with dot introspected correctly';
12b86f07	342
c4a69b87	343	lives_and {
	344	ok $rs = $test_schema->resultset('PgLoaderTest6');
	345	} 'got resultset for table in schema name with dot';
12b86f07	346
c4a69b87	347	lives_and {
	348	ok $row = $rs->create({ value => 'foo' });
	349	} 'executed SQL on table in schema name with dot';
12b86f07	350
c4a69b87	351	$rel_info = try { $rsrc->relationship_info('pg_loader_test7') };
12b86f07	352
c4a69b87	353	is_deeply $rel_info->{cond}, {
	354	'foreign.six_id' => 'self.id'
	355	}, 'relationship in schema name with dot';
12b86f07	356
c4a69b87	357	is $rel_info->{attrs}{accessor}, 'single',
c4a69b87	358	'relationship in schema name with dot';
12b86f07	359
c4a69b87	360	is $rel_info->{attrs}{join_type}, 'LEFT',
c4a69b87	361	'relationship in schema name with dot';
12b86f07	362
c4a69b87	363	lives_and {
	364	ok $rsrc = $test_schema->source('PgLoaderTest7');
	365	} 'got source for table in schema name with dot';
	366
	367	%uniqs = try { $rsrc->unique_constraints };
	368
	369	is keys %uniqs, 2,
	370	'got unique and primary constraint in schema name with dot';
	371
	372	lives_and {
	373	ok $test_schema->source('PgLoaderTest6')
	374	->has_relationship('pg_loader_test4');
	375	} 'cross-schema relationship in multi-db_schema';
	376
	377	lives_and {
	378	ok $test_schema->source('PgLoaderTest4')
	379	->has_relationship('pg_loader_test6s');
	380	} 'cross-schema relationship in multi-db_schema';
	381
	382	lives_and {
	383	ok $test_schema->source('PgLoaderTest8')
	384	->has_relationship('pg_loader_test7');
	385	} 'cross-schema relationship in multi-db_schema';
	386
	387	lives_and {
	388	ok $test_schema->source('PgLoaderTest7')
	389	->has_relationship('pg_loader_test8s');
	390	} 'cross-schema relationship in multi-db_schema';
	391	}
fdd8ff16	392	},
fdd8ff16	393	},
a78e3fed	394	);
a78e3fed	395
9e978a19	396	if( !$dsn \|\| !$user ) {
9e978a19	397	$tester->skip_tests('You need to set the DBICTEST_PG_DSN, _USER, and _PASS environment variables');
a78e3fed	398	}
	399	else {
	400	$tester->run_tests();
	401	}
c4a69b87	402
	403	END {
	404	rmtree EXTRA_DUMP_DIR unless $ENV{SCHEMA_LOADER_TESTS_NOCLEANUP};
	405	}
8e64075f	406	# vim:et sw=4 sts=4 tw=0: