t/10_08sqlanywhere_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::Optional::Dependencies;
   8 use DBIx::Class::Schema::Loader 'make_schema_at';
   9 use Scope::Guard ();
  10
  11 use lib qw(t/lib);
  12
  13 use dbixcsl_common_tests;
  14 use dbixcsl_test_dir '$tdir';
  15
  16 use constant EXTRA_DUMP_DIR => "$tdir/sqlanywhere_extra_dump";
  17
  18 # The default max_cursor_count and max_statement_count settings of 50 are too
  19 # low to run this test.
  20 #
  21 # Setting them to zero is preferred.
  22
  23 my %env2optdep = map { $_ => lc "test_rdbms_$_" } qw(SQLANYWHERE SQLANYWHERE_ODBC);
  24
  25 plan skip_all => 'requirements not satisfied:  ' . (join '  OR  ', map
  26     { "[ @{[ DBIx::Class::Schema::Loader::Optional::Dependencies->req_missing_for( $_ ) ]} ]" }
  27     values %env2optdep
  28 ) unless scalar grep
  29     { DBIx::Class::Schema::Loader::Optional::Dependencies->req_ok_for( $_ ) }
  30     values %env2optdep
  31 ;
  32
  33 my %dsns;
  34 for my $type (keys %env2optdep) {
  35     my %conninfo;
  36     @conninfo{qw(dsn user password)} = map { $ENV{"DBICTEST_${type}_$_"} } qw(DSN USER PASS);
  37     next unless $conninfo{dsn};
  38
  39     my $dep_group = $env2optdep{$type};
  40     if (!DBIx::Class::Schema::Loader::Optional::Dependencies->req_ok_for($dep_group)) {
  41         diag "Testing with DBICTEST_${type}_DSN needs " . DBIx::Class::Schema::Loader::Optional::Dependencies->req_missing_for($dep_group);
  42         next;
  43     }
  44
  45     $dsns{$type} = \%conninfo;
  46 }
  47
  48 my ($schema, $schemas_created); # for cleanup in END for extra tests
  49
  50 my $tester = dbixcsl_common_tests->new(
  51     vendor      => 'SQLAnywhere',
  52     auto_inc_pk => 'INTEGER IDENTITY NOT NULL PRIMARY KEY',
  53     connect_info => [ map { $dsns{$_} } sort keys %dsns ],
  54     loader_options => { preserve_case => 1 },
  55     default_is_deferrable => 1,
  56     default_on_clause => 'RESTRICT',
  57     data_types  => {
  58         # http://infocenter.sybase.com/help/topic/com.sybase.help.sqlanywhere.11.0.1/dbreference_en11/rf-datatypes.html
  59         #
  60         # Numeric types
  61         'bit'         => { data_type => 'bit' },
  62         'tinyint'     => { data_type => 'tinyint' },
  63         'smallint'    => { data_type => 'smallint' },
  64         'int'         => { data_type => 'integer' },
  65         'integer'     => { data_type => 'integer' },
  66         'bigint'      => { data_type => 'bigint' },
  67         'float'       => { data_type => 'real' },
  68         'real'        => { data_type => 'real' },
  69         'double'      => { data_type => 'double precision' },
  70         'double precision' =>
  71                          { data_type => 'double precision' },
  72
  73         'float(2)'    => { data_type => 'real' },
  74         'float(24)'   => { data_type => 'real' },
  75         'float(25)'   => { data_type => 'double precision' },
  76         'float(53)'   => { data_type => 'double precision' },
  77
  78         # This test only works with the default precision and scale options.
  79         #
  80         # They are preserved even for the default values, because the defaults
  81         # can be changed.
  82         'decimal'     => { data_type => 'decimal', size => [30,6] },
  83         'dec'         => { data_type => 'decimal', size => [30,6] },
  84         'numeric'     => { data_type => 'numeric', size => [30,6] },
  85
  86         'decimal(3)'   => { data_type => 'decimal', size => [3,0] },
  87         'dec(3)'       => { data_type => 'decimal', size => [3,0] },
  88         'numeric(3)'   => { data_type => 'numeric', size => [3,0] },
  89
  90         'decimal(3,3)' => { data_type => 'decimal', size => [3,3] },
  91         'dec(3,3)'     => { data_type => 'decimal', size => [3,3] },
  92         'numeric(3,3)' => { data_type => 'numeric', size => [3,3] },
  93
  94         'decimal(18,18)' => { data_type => 'decimal', size => [18,18] },
  95         'dec(18,18)'     => { data_type => 'decimal', size => [18,18] },
  96         'numeric(18,18)' => { data_type => 'numeric', size => [18,18] },
  97
  98         # money types
  99         'money'        => { data_type => 'money' },
 100         'smallmoney'   => { data_type => 'smallmoney' },
 101
 102         # bit arrays
 103         'long varbit'  => { data_type => 'long varbit' },
 104         'long bit varying'
 105                        => { data_type => 'long varbit' },
 106         'varbit'       => { data_type => 'varbit', size => 1 },
 107         'varbit(20)'   => { data_type => 'varbit', size => 20 },
 108         'bit varying'  => { data_type => 'varbit', size => 1 },
 109         'bit varying(20)'
 110                        => { data_type => 'varbit', size => 20 },
 111
 112         # Date and Time Types
 113         'date'        => { data_type => 'date' },
 114         'datetime'    => { data_type => 'datetime' },
 115         'smalldatetime'
 116                       => { data_type => 'smalldatetime' },
 117         'timestamp'   => { data_type => 'timestamp' },
 118         # rewrite 'current timestamp' as 'current_timestamp'
 119         'timestamp default current timestamp'
 120                       => { data_type => 'timestamp', default_value => \'current_timestamp',
 121                            original => { default_value => \'current timestamp' } },
 122         'time'        => { data_type => 'time' },
 123
 124         # String Types
 125         'char'         => { data_type => 'char',      size => 1  },
 126         'char(11)'     => { data_type => 'char',      size => 11 },
 127         'nchar'        => { data_type => 'nchar',     size => 1  },
 128         'nchar(11)'    => { data_type => 'nchar',     size => 11 },
 129         'varchar'      => { data_type => 'varchar',   size => 1  },
 130         'varchar(20)'  => { data_type => 'varchar',   size => 20 },
 131         'char varying(20)'
 132                        => { data_type => 'varchar',   size => 20 },
 133         'character varying(20)'
 134                        => { data_type => 'varchar',   size => 20 },
 135         'nvarchar(20)' => { data_type => 'nvarchar',  size => 20 },
 136         'xml'          => { data_type => 'xml' },
 137         'uniqueidentifierstr'
 138                        => { data_type => 'uniqueidentifierstr' },
 139
 140         # Binary types
 141         'binary'       => { data_type => 'binary', size => 1 },
 142         'binary(20)'   => { data_type => 'binary', size => 20 },
 143         'varbinary'    => { data_type => 'varbinary', size => 1 },
 144         'varbinary(20)'=> { data_type => 'varbinary', size => 20 },
 145         'uniqueidentifier'
 146                        => { data_type => 'uniqueidentifier' },
 147
 148         # Blob types
 149         'long binary'  => { data_type => 'long binary' },
 150         'image'        => { data_type => 'image' },
 151         'long varchar' => { data_type => 'long varchar' },
 152         'text'         => { data_type => 'text' },
 153         'long nvarchar'=> { data_type => 'long nvarchar' },
 154         'ntext'        => { data_type => 'ntext' },
 155     },
 156     extra => {
 157         create => [
 158             # 4 through 8 are used for the multi-schema tests
 159             q{
 160                 create table sqlanywhere_loader_test9 (
 161                     id int identity not null primary key
 162                 )
 163             },
 164             q{
 165                 create table sqlanywhere_loader_test10 (
 166                     id int identity not null primary key,
 167                     nine_id int,
 168                     foreign key (nine_id) references sqlanywhere_loader_test9(id)
 169                         on delete cascade on update set null
 170                 )
 171             },
 172         ],
 173         drop  => [ qw/sqlanywhere_loader_test9 sqlanywhere_loader_test10/ ],
 174         count => 4 + 30 * 2,
 175         run => sub {
 176             SKIP: {
 177                 $schema  = $_[0];
 178                 my $self = $_[3];
 179
 180                 # test on delete/update fk clause introspection
 181                 ok ((my $rel_info = $schema->source('SqlanywhereLoaderTest10')->relationship_info('nine')),
 182                     'got rel info');
 183
 184                 is $rel_info->{attrs}{on_delete}, 'CASCADE',
 185                     'ON DELETE clause introspected correctly';
 186
 187                 is $rel_info->{attrs}{on_update}, 'SET NULL',
 188                     'ON UPDATE clause introspected correctly';
 189
 190                 is $rel_info->{attrs}{is_deferrable}, 1,
 191                     'is_deferrable defaults to 1';
 192
 193                 my $connect_info = [@$self{qw/dsn user password/}];
 194
 195                 my $dbh = $schema->storage->dbh;
 196
 197                 try {
 198                     $dbh->do("CREATE USER dbicsl_test1 identified by 'dbicsl'");
 199                 }
 200                 catch {
 201                     $schemas_created = 0;
 202                     skip "no CREATE USER privileges", 30 * 2;
 203                 };
 204
 205                 $dbh->do(<<"EOF");
 206                     CREATE TABLE dbicsl_test1.sqlanywhere_loader_test4 (
 207                         id INT IDENTITY NOT NULL PRIMARY KEY,
 208                         value VARCHAR(100)
 209                     )
 210 EOF
 211                 $dbh->do(<<"EOF");
 212                     CREATE TABLE dbicsl_test1.sqlanywhere_loader_test5 (
 213                         id INT IDENTITY NOT NULL PRIMARY KEY,
 214                         value VARCHAR(100),
 215                         four_id INTEGER NOT NULL,
 216                         CONSTRAINT loader_test5_uniq UNIQUE (four_id),
 217                         FOREIGN KEY (four_id) REFERENCES dbicsl_test1.sqlanywhere_loader_test4 (id)
 218                     )
 219 EOF
 220                 $dbh->do("CREATE USER dbicsl_test2 identified by 'dbicsl'");
 221                 $dbh->do(<<"EOF");
 222                     CREATE TABLE dbicsl_test2.sqlanywhere_loader_test5 (
 223                         pk INT IDENTITY NOT NULL PRIMARY KEY,
 224                         value VARCHAR(100),
 225                         four_id INTEGER NOT NULL,
 226                         CONSTRAINT loader_test5_uniq UNIQUE (four_id),
 227                         FOREIGN KEY (four_id) REFERENCES dbicsl_test1.sqlanywhere_loader_test4 (id)
 228                     )
 229 EOF
 230                 $dbh->do(<<"EOF");
 231                     CREATE TABLE dbicsl_test2.sqlanywhere_loader_test6 (
 232                         id INT IDENTITY NOT NULL PRIMARY KEY,
 233                         value VARCHAR(100),
 234                         sqlanywhere_loader_test4_id INTEGER,
 235                         FOREIGN KEY (sqlanywhere_loader_test4_id) REFERENCES dbicsl_test1.sqlanywhere_loader_test4 (id)
 236                     )
 237 EOF
 238                 $dbh->do(<<"EOF");
 239                     CREATE TABLE dbicsl_test2.sqlanywhere_loader_test7 (
 240                         id INT IDENTITY NOT NULL PRIMARY KEY,
 241                         value VARCHAR(100),
 242                         six_id INTEGER NOT NULL UNIQUE,
 243                         FOREIGN KEY (six_id) REFERENCES dbicsl_test2.sqlanywhere_loader_test6 (id)
 244                     )
 245 EOF
 246                 $dbh->do(<<"EOF");
 247                     CREATE TABLE dbicsl_test1.sqlanywhere_loader_test8 (
 248                         id INT IDENTITY NOT NULL PRIMARY KEY,
 249                         value VARCHAR(100),
 250                         sqlanywhere_loader_test7_id INTEGER,
 251                         FOREIGN KEY (sqlanywhere_loader_test7_id) REFERENCES dbicsl_test2.sqlanywhere_loader_test7 (id)
 252                     )
 253 EOF
 254
 255                 $schemas_created = 1;
 256
 257                 my $guard = Scope::Guard->new(\&extra_cleanup);
 258
 259                 foreach my $db_schema (['dbicsl_test1', 'dbicsl_test2'], '%') {
 260                     lives_and {
 261                         rmtree EXTRA_DUMP_DIR;
 262
 263                         my @warns;
 264                         local $SIG{__WARN__} = sub {
 265                             push @warns, $_[0] unless $_[0] =~ /\bcollides\b/;
 266                         };
 267
 268                         make_schema_at(
 269                             'SQLAnywhereMultiSchema',
 270                             {
 271                                 naming => 'current',
 272                                 db_schema => $db_schema,
 273                                 dump_directory => EXTRA_DUMP_DIR,
 274                                 quiet => 1,
 275                             },
 276                             $connect_info,
 277                         );
 278
 279                         diag join "\n", @warns if @warns;
 280
 281                         is @warns, 0;
 282                     } 'dumped schema for dbicsl_test1 and dbicsl_test2 schemas with no warnings';
 283
 284                     my ($test_schema, $rsrc, $rs, $row, %uniqs, $rel_info);
 285
 286                     lives_and {
 287                         ok $test_schema = SQLAnywhereMultiSchema->connect(@$connect_info);
 288                     } 'connected test schema';
 289
 290                     lives_and {
 291                         ok $rsrc = $test_schema->source('SqlanywhereLoaderTest4');
 292                     } 'got source for table in schema one';
 293
 294                     is try { $rsrc->column_info('id')->{is_auto_increment} }, 1,
 295                         'column in schema one';
 296
 297                     is try { $rsrc->column_info('value')->{data_type} }, 'varchar',
 298                         'column in schema one';
 299
 300                     is try { $rsrc->column_info('value')->{size} }, 100,
 301                         'column in schema one';
 302
 303                     lives_and {
 304                         ok $rs = $test_schema->resultset('SqlanywhereLoaderTest4');
 305                     } 'got resultset for table in schema one';
 306
 307                     lives_and {
 308                         ok $row = $rs->create({ value => 'foo' });
 309                     } 'executed SQL on table in schema one';
 310
 311                     $rel_info = try { $rsrc->relationship_info('dbicsl_test1_sqlanywhere_loader_test5') };
 312
 313                     is_deeply $rel_info->{cond}, {
 314                         'foreign.four_id' => 'self.id'
 315                     }, 'relationship in schema one';
 316
 317                     is $rel_info->{attrs}{accessor}, 'single',
 318                         'relationship in schema one';
 319
 320                     is $rel_info->{attrs}{join_type}, 'LEFT',
 321                         'relationship in schema one';
 322
 323                     lives_and {
 324                         ok $rsrc = $test_schema->source('DbicslTest1SqlanywhereLoaderTest5');
 325                     } 'got source for table in schema one';
 326
 327                     %uniqs = try { $rsrc->unique_constraints };
 328
 329                     is keys %uniqs, 2,
 330                         'got unique and primary constraint in schema one';
 331
 332                     delete $uniqs{primary};
 333
 334                     is_deeply ((values %uniqs)[0], ['four_id'],
 335                         'correct unique constraint in schema one');
 336
 337                     lives_and {
 338                         ok $rsrc = $test_schema->source('SqlanywhereLoaderTest6');
 339                     } 'got source for table in schema two';
 340
 341                     is try { $rsrc->column_info('id')->{is_auto_increment} }, 1,
 342                         'column in schema two introspected correctly';
 343
 344                     is try { $rsrc->column_info('value')->{data_type} }, 'varchar',
 345                         'column in schema two introspected correctly';
 346
 347                     is try { $rsrc->column_info('value')->{size} }, 100,
 348                         'column in schema two introspected correctly';
 349
 350                     lives_and {
 351                         ok $rs = $test_schema->resultset('SqlanywhereLoaderTest6');
 352                     } 'got resultset for table in schema two';
 353
 354                     lives_and {
 355                         ok $row = $rs->create({ value => 'foo' });
 356                     } 'executed SQL on table in schema two';
 357
 358                     $rel_info = try { $rsrc->relationship_info('sqlanywhere_loader_test7') };
 359
 360                     is_deeply $rel_info->{cond}, {
 361                         'foreign.six_id' => 'self.id'
 362                     }, 'relationship in schema two';
 363
 364                     is $rel_info->{attrs}{accessor}, 'single',
 365                         'relationship in schema two';
 366
 367                     is $rel_info->{attrs}{join_type}, 'LEFT',
 368                         'relationship in schema two';
 369
 370                     lives_and {
 371                         ok $rsrc = $test_schema->source('SqlanywhereLoaderTest7');
 372                     } 'got source for table in schema two';
 373
 374                     %uniqs = try { $rsrc->unique_constraints };
 375
 376                     is keys %uniqs, 2,
 377                         'got unique and primary constraint in schema two';
 378
 379                     delete $uniqs{primary};
 380
 381                     is_deeply ((values %uniqs)[0], ['six_id'],
 382                         'correct unique constraint in schema two');
 383
 384                     lives_and {
 385                         ok $test_schema->source('SqlanywhereLoaderTest6')
 386                             ->has_relationship('sqlanywhere_loader_test4');
 387                     } 'cross-schema relationship in multi-db_schema';
 388
 389                     lives_and {
 390                         ok $test_schema->source('SqlanywhereLoaderTest4')
 391                             ->has_relationship('sqlanywhere_loader_test6s');
 392                     } 'cross-schema relationship in multi-db_schema';
 393
 394                     lives_and {
 395                         ok $test_schema->source('SqlanywhereLoaderTest8')
 396                             ->has_relationship('sqlanywhere_loader_test7');
 397                     } 'cross-schema relationship in multi-db_schema';
 398
 399                     lives_and {
 400                         ok $test_schema->source('SqlanywhereLoaderTest7')
 401                             ->has_relationship('sqlanywhere_loader_test8s');
 402                     } 'cross-schema relationship in multi-db_schema';
 403                 }
 404             }
 405         },
 406     },
 407 );
 408
 409 $tester->run_tests();
 410
 411 sub extra_cleanup {
 412     if (not $ENV{SCHEMA_LOADER_TESTS_NOCLEANUP}) {
 413         if ($schemas_created && (my $dbh = try { $schema->storage->dbh })) {
 414             foreach my $table ('dbicsl_test1.sqlanywhere_loader_test8',
 415                                'dbicsl_test2.sqlanywhere_loader_test7',
 416                                'dbicsl_test2.sqlanywhere_loader_test6',
 417                                'dbicsl_test2.sqlanywhere_loader_test5',
 418                                'dbicsl_test1.sqlanywhere_loader_test5',
 419                                'dbicsl_test1.sqlanywhere_loader_test4') {
 420                 try {
 421                     $dbh->do("DROP TABLE $table");
 422                 }
 423                 catch {
 424                     diag "Error dropping table: $_";
 425                 };
 426             }
 427
 428             foreach my $db_schema (qw/dbicsl_test1 dbicsl_test2/) {
 429                 try {
 430                     $dbh->do("DROP USER $db_schema");
 431                 }
 432                 catch {
 433                     diag "Error dropping test user $db_schema: $_";
 434                 };
 435             }
 436         }
 437         rmtree EXTRA_DUMP_DIR;
 438     }
 439 }
 440 # vim:et sts=4 sw=4 tw=0: