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

use strict;
use lib qw(t/lib);
use DBIx::Class::Schema::Loader 'make_schema_at';
use DBIx::Class::Schema::Loader::Utils 'no_warnings';
use dbixcsl_common_tests;
use Test::More;
use Test::Exception;
use File::Slurp 'slurp';
use utf8;
use Encode 'decode';
use Try::Tiny;

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' },

	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' } },

        # 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_test3 (
                    id SERIAL PRIMARY KEY,
                    value VARCHAR(100)
                )
            },
            q{
                CREATE TABLE "dbicsl-test".pg_loader_test4 (
                    id SERIAL PRIMARY KEY,
                    value VARCHAR(100),
                    three_id INTEGER UNIQUE REFERENCES "dbicsl-test".pg_loader_test3 (id)
                )
            },
            q{
                CREATE SCHEMA "dbicsl.test"
            },
            q{
                CREATE TABLE "dbicsl.test".pg_loader_test5 (
                    id SERIAL PRIMARY KEY,
                    value VARCHAR(100),
                    pg_loader_test3_id INTEGER NOT NULL REFERENCES "dbicsl-test".pg_loader_test3 (id)
                )
            },
            q{
                CREATE TABLE "dbicsl.test".pg_loader_test6 (
                    id SERIAL PRIMARY KEY,
                    value VARCHAR(100),
                    five_id INTEGER UNIQUE REFERENCES "dbicsl.test".pg_loader_test5 (id)
                )
            },
            q{
                CREATE TABLE "dbicsl-test".pg_loader_test7 (
                    id SERIAL PRIMARY KEY,
                    value VARCHAR(100),
                    pg_loader_test6_id INTEGER NOT NULL REFERENCES "dbicsl.test".pg_loader_test6 (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 + 21 * 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 = decode('UTF-8', scalar slurp $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 = decode('UTF-8', scalar slurp $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 {
                    no_warnings {
                        make_schema_at(
                            'PGMultiSchema',
                            {
                                naming => 'current',
                                preserve_case => 1,
                                db_schema => $db_schema,
                            },
                            [ $dsn, $user, $password, {
                                on_connect_do  => [ 'SET client_min_messages=WARNING' ],
                            } ],
                        );
                    };
                }
    'created dynamic schema for "dbicsl-test" and "dbicsl.test" schemas with no warnings';

                my ($rsrc, %uniqs, $rel_info);

                lives_and {
                    ok $rsrc = PGMultiSchema->source('PgLoaderTest3');
                } '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';

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

                is_deeply $rel_info->{cond}, {
                    'foreign.three_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 = PGMultiSchema->source('PgLoaderTest4');
                } '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 = PGMultiSchema->source('PgLoaderTest5');
                } '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 dash introspected correctly';

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

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

                is_deeply $rel_info->{cond}, {
                    'foreign.five_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 = PGMultiSchema->source('PgLoaderTest6');
                } '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 PGMultiSchema->source('PgLoaderTest5')
                        ->has_relationship('pg_loader_test3');
                } 'cross-schema relationship in multi-db_schema';

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