t/10_10informix_common.t

   1 use strict;
   2 use warnings;
   3 use Test::More;
   4 use Test::Exception;
   5 use Try::Tiny;
   6 use File::Path 'rmtree';
   7 use DBIx::Class::Schema::Loader 'make_schema_at';
   8 use DBIx::Class::Schema::Loader::Utils 'split_name';
   9 use String::ToIdentifier::EN::Unicode 'to_identifier';
  10 use namespace::clean;
  11
  12 use lib qw(t/lib);
  13
  14 use dbixcsl_common_tests ();
  15 use dbixcsl_test_dir '$tdir';
  16
  17 use constant EXTRA_DUMP_DIR => "$tdir/informix_extra_dump";
  18
  19 # to support " quoted identifiers
  20 BEGIN { $ENV{DELIMIDENT} = 'y' }
  21
  22 # This test doesn't run over a shared memory connection, because of the single connection limit.
  23
  24 my $dsn      = $ENV{DBICTEST_INFORMIX_DSN} || '';
  25 my $user     = $ENV{DBICTEST_INFORMIX_USER} || '';
  26 my $password = $ENV{DBICTEST_INFORMIX_PASS} || '';
  27
  28 my ($schema, $extra_schema); # for cleanup in END for extra tests
  29
  30 my $tester = dbixcsl_common_tests->new(
  31     vendor         => 'Informix',
  32     auto_inc_pk    => 'serial primary key',
  33     null           => '',
  34     default_function     => 'current year to fraction(5)',
  35     default_function_def => 'datetime year to fraction(5) default current year to fraction(5)',
  36     dsn            => $dsn,
  37     user           => $user,
  38     password       => $password,
  39     loader_options => { preserve_case => 1 },
  40     quote_char     => '"',
  41     data_types => {
  42         # http://publib.boulder.ibm.com/infocenter/idshelp/v115/index.jsp?topic=/com.ibm.sqlr.doc/ids_sqr_094.htm
  43
  44         # Numeric Types
  45         'int'              => { data_type => 'integer' },
  46         integer            => { data_type => 'integer' },
  47         int8               => { data_type => 'bigint' },
  48         bigint             => { data_type => 'bigint' },
  49         serial             => { data_type => 'integer', is_auto_increment => 1 },
  50         bigserial          => { data_type => 'bigint',  is_auto_increment => 1 },
  51         serial8            => { data_type => 'bigint',  is_auto_increment => 1 },
  52         smallint           => { data_type => 'smallint' },
  53         real               => { data_type => 'real' },
  54         smallfloat         => { data_type => 'real' },
  55         # just 'double' is a syntax error
  56         'double precision' => { data_type => 'double precision' },
  57         float              => { data_type => 'double precision' },
  58         'float(1)'         => { data_type => 'double precision' },
  59         'float(5)'         => { data_type => 'double precision' },
  60         'float(10)'        => { data_type => 'double precision' },
  61         'float(15)'        => { data_type => 'double precision' },
  62         'float(16)'        => { data_type => 'double precision' },
  63         numeric            => { data_type => 'numeric' },
  64         decimal            => { data_type => 'numeric' },
  65         dec                => { data_type => 'numeric' },
  66         'numeric(6,3)'     => { data_type => 'numeric', size => [6,3] },
  67         'decimal(6,3)'     => { data_type => 'numeric', size => [6,3] },
  68         'dec(6,3)'         => { data_type => 'numeric', size => [6,3] },
  69
  70         # Boolean Type
  71         # XXX this should map to 'boolean'
  72         boolean            => { data_type => 'smallint' },
  73
  74         # Money Type
  75         money              => { data_type => 'money' },
  76         'money(3,3)'       => { data_type => 'numeric', size => [3,3] },
  77
  78         # Byte Type
  79         byte               => { data_type => 'bytea', original => { data_type => 'byte' } },
  80
  81         # Character String Types
  82         char               => { data_type => 'char', size => 1 },
  83         'char(3)'          => { data_type => 'char', size => 3 },
  84         character          => { data_type => 'char', size => 1 },
  85         'character(3)'     => { data_type => 'char', size => 3 },
  86         'varchar(3)'       => { data_type => 'varchar', size => 3 },
  87         'character varying(3)'
  88                            => { data_type => 'varchar', size => 3 },
  89         # XXX min size not supported, colmin from syscolumns is NULL
  90         'varchar(3,2)'     => { data_type => 'varchar', size => 3 },
  91         'character varying(3,2)'
  92                            => { data_type => 'varchar', size => 3 },
  93         nchar              => { data_type => 'nchar', size => 1 },
  94         'nchar(3)'         => { data_type => 'nchar', size => 3 },
  95         'nvarchar(3)'      => { data_type => 'nvarchar', size => 3 },
  96         'nvarchar(3,2)'    => { data_type => 'nvarchar', size => 3 },
  97         'lvarchar(3)'      => { data_type => 'lvarchar', size => 3 },
  98         'lvarchar(33)'     => { data_type => 'lvarchar', size => 33 },
  99         text               => { data_type => 'text' },
 100
 101         # DateTime Types
 102         date               => { data_type => 'date' },
 103         'date default today'
 104                            => { data_type => 'date', default_value => \'today' },
 105         # XXX support all precisions
 106         'datetime year to fraction(5)',
 107                            => { data_type => 'datetime year to fraction(5)' },
 108         'datetime year to fraction(5) default current year to fraction(5)',
 109                            => { data_type => 'datetime year to fraction(5)', default_value => \'current year to fraction(5)' },
 110         # XXX do interval
 111
 112         # Blob Types
 113         # XXX no way to distinguish opaque types boolean, blob and clob
 114         blob               => { data_type => 'blob' },
 115         clob               => { data_type => 'blob' },
 116
 117         # IDSSECURITYLABEL Type
 118         #
 119         # This requires the DBSECADM privilege and a security policy on the
 120         # table, things I know nothing about.
 121 #        idssecuritylabel   => { data_type => 'idssecuritylabel' },
 122
 123         # List Types
 124         # XXX need to introspect element type too
 125         'list(varchar(20) not null)'
 126                            => { data_type => 'list' },
 127         'multiset(varchar(20) not null)'
 128                            => { data_type => 'multiset' },
 129         'set(varchar(20) not null)'
 130                            => { data_type => 'set' },
 131     },
 132     extra => {
 133         count => 26 * 2,
 134         run   => sub {
 135             ($schema) = @_;
 136
 137             SKIP: {
 138                 skip 'Set the DBICTEST_INFORMIX_EXTRADB_DSN, _USER and _PASS environment variables to run the multi-database tests', 26 * 2
 139                     unless $ENV{DBICTEST_INFORMIX_EXTRADB_DSN};
 140
 141                 $extra_schema = $schema->clone;
 142                 $extra_schema->connection(@ENV{map "DBICTEST_INFORMIX_EXTRADB_$_",
 143                     qw/DSN USER PASS/
 144                 });
 145
 146                 my $dbh1 = $schema->storage->dbh;
 147
 148                 $dbh1->do(<<'EOF');
 149                     CREATE TABLE informix_loader_test4 (
 150                         id SERIAL PRIMARY KEY,
 151                         value VARCHAR(100)
 152                     )
 153 EOF
 154                 $dbh1->do(<<'EOF');
 155                     CREATE TABLE informix_loader_test5 (
 156                         id SERIAL PRIMARY KEY,
 157                         value VARCHAR(100),
 158                         four_id INTEGER REFERENCES informix_loader_test4 (id)
 159                     )
 160 EOF
 161                 $dbh1->do(<<'EOF');
 162 ALTER TABLE informix_loader_test5 ADD CONSTRAINT UNIQUE (four_id) CONSTRAINT loader_test5_uniq
 163 EOF
 164
 165                 my $db1 = db_name($schema);
 166
 167                 $dbh1->disconnect;
 168
 169                 my $dbh2 = $extra_schema->storage->dbh;
 170
 171                 $dbh2->do(<<'EOF');
 172                     CREATE TABLE informix_loader_test5 (
 173                         pk SERIAL PRIMARY KEY,
 174                         value VARCHAR(100),
 175                         four_id INTEGER
 176                     )
 177 EOF
 178                 $dbh2->do(<<'EOF');
 179 ALTER TABLE informix_loader_test5 ADD CONSTRAINT UNIQUE (four_id) CONSTRAINT loader_test5_uniq
 180 EOF
 181                 $dbh2->do(<<"EOF");
 182                     CREATE TABLE informix_loader_test6 (
 183                         id SERIAL PRIMARY KEY,
 184                         value VARCHAR(100)
 185                     )
 186 EOF
 187                 $dbh2->do(<<"EOF");
 188                     CREATE TABLE informix_loader_test7 (
 189                         id SERIAL PRIMARY KEY,
 190                         value VARCHAR(100),
 191                         six_id INTEGER UNIQUE REFERENCES informix_loader_test6 (id)
 192                     )
 193 EOF
 194
 195                 my $db2 = db_name($extra_schema);
 196
 197                 $dbh2->disconnect;
 198
 199                 my $db1_moniker = join '', map ucfirst lc, split_name to_identifier $db1;
 200                 my $db2_moniker = join '', map ucfirst lc, split_name to_identifier $db2;
 201
 202                 foreach my $db_schema ({ $db1 => '%', $db2 => '%' }, { '%' => '%' }) {
 203                     lives_and {
 204                         my @warns;
 205                         local $SIG{__WARN__} = sub {
 206                             push @warns, $_[0] unless $_[0] =~ /\bcollides\b/
 207                                 || $_[0] =~ /unreferencable/;
 208                         };
 209
 210                         make_schema_at(
 211                             'InformixMultiDatabase',
 212                             {
 213                                 naming => 'current',
 214                                 db_schema => $db_schema,
 215                                 dump_directory => EXTRA_DUMP_DIR,
 216                                 quiet => 1,
 217                             },
 218                             [ $dsn, $user, $password ],
 219                         );
 220
 221                         InformixMultiDatabase->storage->disconnect;
 222
 223                         diag join "\n", @warns if @warns;
 224
 225                         is @warns, 0;
 226                     } "dumped schema for databases $db1 and $db2 with no warnings";
 227
 228                     my $test_schema;
 229
 230                     lives_and {
 231                         ok $test_schema = InformixMultiDatabase->connect($dsn, $user, $password);
 232                     } 'connected test schema';
 233
 234                     my ($rsrc, $rs, $row, $rel_info, %uniqs);
 235
 236                     lives_and {
 237                         ok $rsrc = $test_schema->source("InformixLoaderTest4");
 238                     } 'got source for table in database one';
 239
 240                     is try { $rsrc->column_info('id')->{is_auto_increment} }, 1,
 241                         'column in database one';
 242
 243                     is try { $rsrc->column_info('value')->{data_type} }, 'varchar',
 244                         'column in database one';
 245
 246                     is try { $rsrc->column_info('value')->{size} }, 100,
 247                         'column in database one';
 248
 249                     lives_and {
 250                         ok $rs = $test_schema->resultset("InformixLoaderTest4");
 251                     } 'got resultset for table in database one';
 252
 253                     lives_and {
 254                         ok $row = $rs->create({ value => 'foo' });
 255                     } 'executed SQL on table in database one';
 256
 257                     $rel_info = try { $rsrc->relationship_info("informix_loader_test5") };
 258
 259                     is_deeply $rel_info->{cond}, {
 260                         'foreign.four_id' => 'self.id'
 261                     }, 'relationship in database one';
 262
 263                     is $rel_info->{attrs}{accessor}, 'single',
 264                         'relationship in database one';
 265
 266                     is $rel_info->{attrs}{join_type}, 'LEFT',
 267                         'relationship in database one';
 268
 269                     lives_and {
 270                         ok $rsrc = $test_schema->source("${db1_moniker}InformixLoaderTest5");
 271                     } 'got source for table in database one';
 272
 273                     %uniqs = try { $rsrc->unique_constraints };
 274
 275                     is keys %uniqs, 2,
 276                         'got unique and primary constraint in database one';
 277
 278                     delete $uniqs{primary};
 279
 280                     is_deeply ((values %uniqs)[0], ['four_id'],
 281                         'correct unique constraint in database one');
 282
 283                     lives_and {
 284                         ok $rsrc = $test_schema->source("InformixLoaderTest6");
 285                     } 'got source for table in database two';
 286
 287                     is try { $rsrc->column_info('id')->{is_auto_increment} }, 1,
 288                         'column in database two introspected correctly';
 289
 290                     is try { $rsrc->column_info('value')->{data_type} }, 'varchar',
 291                         'column in database two introspected correctly';
 292
 293                     is try { $rsrc->column_info('value')->{size} }, 100,
 294                         'column in database two introspected correctly';
 295
 296                     lives_and {
 297                         ok $rs = $test_schema->resultset("InformixLoaderTest6");
 298                     } 'got resultset for table in database two';
 299
 300                     lives_and {
 301                         ok $row = $rs->create({ value => 'foo' });
 302                     } 'executed SQL on table in database two';
 303
 304                     $rel_info = try { $rsrc->relationship_info('informix_loader_test7') };
 305
 306                     is_deeply $rel_info->{cond}, {
 307                         'foreign.six_id' => 'self.id'
 308                     }, 'relationship in database two';
 309
 310                     is $rel_info->{attrs}{accessor}, 'single',
 311                         'relationship in database two';
 312
 313                     is $rel_info->{attrs}{join_type}, 'LEFT',
 314                         'relationship in database two';
 315
 316                     lives_and {
 317                         ok $rsrc = $test_schema->source("InformixLoaderTest7");
 318                     } 'got source for table in database two';
 319
 320                     %uniqs = try { $rsrc->unique_constraints };
 321
 322                     is keys %uniqs, 2,
 323                         'got unique and primary constraint in database two';
 324
 325                     delete $uniqs{primary};
 326
 327                     is_deeply ((values %uniqs)[0], ['six_id'],
 328                         'correct unique constraint in database two');
 329                 }
 330             }
 331         },
 332     },
 333 );
 334
 335 if( !$dsn ) {
 336     $tester->skip_tests('You need to set the DBICTEST_INFORMIX_DSN, _USER, and _PASS environment variables');
 337 }
 338 else {
 339     $tester->run_tests();
 340 }
 341
 342 sub db_name {
 343     my $schema = shift;
 344
 345     # When we clone the schema, it still references the original loader, which
 346     # references the original schema.
 347     local $schema->loader->{schema} = $schema;
 348
 349     return $schema->loader->_current_db;
 350
 351     $schema->storage->disconnect;
 352 }
 353
 354 END {
 355     if (not $ENV{SCHEMA_LOADER_TESTS_NOCLEANUP}) {
 356         if (my $dbh2 = try { $extra_schema->storage->dbh }) {
 357
 358             try {
 359                 $dbh2->do('DROP TABLE informix_loader_test7');
 360                 $dbh2->do('DROP TABLE informix_loader_test6');
 361                 $dbh2->do('DROP TABLE informix_loader_test5');
 362             }
 363             catch {
 364                 die "Error dropping test tables: $_";
 365             };
 366
 367             $dbh2->disconnect;
 368         }
 369
 370         if (my $dbh1 = try { $schema->storage->dbh }) {
 371
 372             try {
 373                 $dbh1->do('DROP TABLE informix_loader_test5');
 374                 $dbh1->do('DROP TABLE informix_loader_test4');
 375             }
 376             catch {
 377                 die "Error dropping test tables: $_";
 378             };
 379
 380             $dbh1->disconnect;
 381         }
 382
 383         rmtree EXTRA_DUMP_DIR;
 384     }
 385 }
 386 # vim:et sts=4 sw=4 tw=0: