X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=t%2F72pg.t;h=40ba3d384eaa7c604fb8b87135ba322080bf211f;hb=bfa46eb523fff8ece9b37a48d17b90510f1c8c52;hp=951be49810dd71d897ee268a53cb8baa5d98f231;hpb=89869c75ac532068518bfc72e33468014bb68e43;p=dbsrgits%2FDBIx-Class.git diff --git a/t/72pg.t b/t/72pg.t index 951be49..40ba3d3 100644 --- a/t/72pg.t +++ b/t/72pg.t @@ -1,5 +1,5 @@ use strict; -use warnings; +use warnings; use Test::More; use Test::Exception; @@ -15,10 +15,15 @@ use DBICTest; __PACKAGE__->load_components(qw/Core/); __PACKAGE__->table('testschema.casecheck'); - __PACKAGE__->add_columns(qw/id name NAME uc_name/); + __PACKAGE__->add_columns(qw/id name NAME uc_name storecolumn/); __PACKAGE__->column_info_from_storage(1); __PACKAGE__->set_primary_key('id'); + sub store_column { + my ($self, $name, $value) = @_; + $value = '#'.$value if($name eq "storecolumn"); + $self->maybe::next::method($name, $value); + } } { @@ -38,20 +43,23 @@ use DBICTest; my ($dsn, $user, $pass) = @ENV{map { "DBICTEST_PG_${_}" } qw/DSN USER PASS/}; -#warn "$dsn $user $pass"; - plan skip_all => 'Set $ENV{DBICTEST_PG_DSN}, _USER and _PASS to run this test '. '(note: This test drops and creates tables called \'artist\', \'casecheck\', \'array_test\' and \'sequence_test\''. ' as well as following sequences: \'pkid1_seq\', \'pkid2_seq\' and \'nonpkid_seq\''. - ' as well as following schemas: \'testschema\'!)' - unless ($dsn && $user && $pass); + ' as well as following schemas: \'testschema\',\'anothertestschema\'!)' + unless ($dsn && $user); +DBICTest::Schema->load_classes( 'Casecheck', 'ArrayTest' ); -plan tests => 37; +# make sure sqlt_type overrides work (::Storage::DBI::Pg does this) +{ + my $schema = DBICTest::Schema->connect($dsn, $user, $pass); -DBICTest::Schema->load_classes( 'Casecheck', 'ArrayTest' ); -my $schema = DBICTest::Schema->connect($dsn, $user, $pass); + ok (!$schema->storage->_dbh, 'definitely not connected'); + is ($schema->storage->sqlt_type, 'PostgreSQL', 'sqlt_type correct pre-connection'); +} +my $schema = DBICTest::Schema->connect($dsn, $user, $pass); # Check that datetime_parser returns correctly before we explicitly connect. SKIP: { eval { require DateTime::Format::Pg }; @@ -69,26 +77,78 @@ $schema->source("Artist")->name("testschema.artist"); $schema->source("SequenceTest")->name("testschema.sequence_test"); { local $SIG{__WARN__} = sub {}; + _cleanup ($schema); + + my $artist_table_def = <do("CREATE SCHEMA testschema;"); - $dbh->do("CREATE TABLE testschema.artist (artistid serial PRIMARY KEY, name VARCHAR(100), rank INTEGER NOT NULL DEFAULT '13', charfield CHAR(10), arrayfield INTEGER[]);"); + $dbh->do("CREATE TABLE testschema.artist $artist_table_def;"); $dbh->do("CREATE TABLE testschema.sequence_test (pkid1 integer, pkid2 integer, nonpkid integer, name VARCHAR(100), CONSTRAINT pk PRIMARY KEY(pkid1, pkid2));"); $dbh->do("CREATE SEQUENCE pkid1_seq START 1 MAXVALUE 999999 MINVALUE 0"); $dbh->do("CREATE SEQUENCE pkid2_seq START 10 MAXVALUE 999999 MINVALUE 0"); $dbh->do("CREATE SEQUENCE nonpkid_seq START 20 MAXVALUE 999999 MINVALUE 0"); - ok ( $dbh->do('CREATE TABLE testschema.casecheck (id serial PRIMARY KEY, "name" VARCHAR(1), "NAME" VARCHAR(2), "UC_NAME" VARCHAR(3));'), 'Creation of casecheck table'); + ok ( $dbh->do('CREATE TABLE testschema.casecheck (id serial PRIMARY KEY, "name" VARCHAR(1), "NAME" VARCHAR(2), "UC_NAME" VARCHAR(3), "storecolumn" VARCHAR(10));'), 'Creation of casecheck table'); ok ( $dbh->do('CREATE TABLE testschema.array_test (id serial PRIMARY KEY, arrayfield INTEGER[]);'), 'Creation of array_test table'); + $dbh->do("CREATE SCHEMA anothertestschema;"); + $dbh->do("CREATE TABLE anothertestschema.artist $artist_table_def;"); + $dbh->do("CREATE SCHEMA yetanothertestschema;"); + $dbh->do("CREATE TABLE yetanothertestschema.artist $artist_table_def;"); + $dbh->do('set search_path=testschema,public'); } +# store_column is called once for create() for non sequence columns + +ok(my $storecolumn = $schema->resultset('Casecheck')->create({'storecolumn' => 'a'})); + +is($storecolumn->storecolumn, '#a'); # was '##a' + + # This is in Core now, but it's here just to test that it doesn't break $schema->class('Artist')->load_components('PK::Auto'); +cmp_ok( $schema->resultset('Artist')->count, '==', 0, 'this should start with an empty artist table'); + +{ # test that auto-pk also works with the defined search path by + # un-schema-qualifying the table name + my $artist_name_save = $schema->source("Artist")->name; + $schema->source("Artist")->name("artist"); + + my $unq_new; + lives_ok { + $unq_new = $schema->resultset('Artist')->create({ name => 'baz' }); + } 'insert into unqualified, shadowed table succeeds'; + + is($unq_new && $unq_new->artistid, 1, "and got correct artistid"); + + #test with anothertestschema + $schema->source('Artist')->name('anothertestschema.artist'); + my $another_new = $schema->resultset('Artist')->create({ name => 'ribasushi'}); + is( $another_new->artistid,1, 'got correct artistid for yetanotherschema'); + + #test with yetanothertestschema + $schema->source('Artist')->name('yetanothertestschema.artist'); + my $yetanother_new = $schema->resultset('Artist')->create({ name => 'ribasushi'}); + is( $yetanother_new->artistid,1, 'got correct artistid for yetanotherschema'); + is( $yetanother_new->artistid,1, 'got correct artistid for yetanotherschema'); + + $schema->source("Artist")->name($artist_name_save); +} + my $new = $schema->resultset('Artist')->create({ name => 'foo' }); -is($new->artistid, 1, "Auto-PK worked"); +is($new->artistid, 2, "Auto-PK worked"); $new = $schema->resultset('Artist')->create({ name => 'bar' }); -is($new->artistid, 2, "Auto-PK worked"); +is($new->artistid, 3, "Auto-PK worked"); + my $test_type_info = { 'artistid' => { @@ -133,8 +193,7 @@ is_deeply($type_info, $test_type_info, 'columns_info_for - column data types'); SKIP: { - skip "SQL::Abstract < 1.49 does not pass through arrayrefs", 3 - if $SQL::Abstract::VERSION < 1.49; + skip "Need DBD::Pg 2.9.2 or newer for array tests", 4 if $DBD::Pg::VERSION < 2.009002; lives_ok { $schema->resultset('ArrayTest')->create({ @@ -155,7 +214,7 @@ SKIP: { my $count; lives_ok { $count = $schema->resultset('ArrayTest')->search({ - arrayfield => \[ '= ?' => [3, 4] ], #TODO anything less ugly than this? + arrayfield => \[ '= ?' => [arrayfield => [3, 4]] ], #Todo anything less ugly than this? })->count; } 'comparing arrayref to pg array data does not blow up'; is($count, 1, 'comparing arrayref to pg array data gives correct result'); @@ -248,30 +307,31 @@ SKIP: { }); } -SKIP: { - skip "Oracle Auto-PK tests are broken", 16; - - # test auto increment using sequences WITHOUT triggers - for (1..5) { +for (1..5) { my $st = $schema->resultset('SequenceTest')->create({ name => 'foo' }); is($st->pkid1, $_, "Oracle Auto-PK without trigger: First primary key"); is($st->pkid2, $_ + 9, "Oracle Auto-PK without trigger: Second primary key"); is($st->nonpkid, $_ + 19, "Oracle Auto-PK without trigger: Non-primary key"); +} +my $st = $schema->resultset('SequenceTest')->create({ name => 'foo', pkid1 => 55 }); +is($st->pkid1, 55, "Oracle Auto-PK without trigger: First primary key set manually"); + +sub _cleanup { + my $schema = shift or return; + local $SIG{__WARN__} = sub {}; + + for my $stat ( + 'DROP SCHEMA testschema CASCADE', + 'DROP SCHEMA anothertestschema CASCADE', + 'DROP SCHEMA yetanothertestschema CASCADE', + 'DROP SEQUENCE pkid1_seq', + 'DROP SEQUENCE pkid2_seq', + 'DROP SEQUENCE nonpkid_seq', + ) { + eval { $schema->storage->_do_query ($stat) }; } - my $st = $schema->resultset('SequenceTest')->create({ name => 'foo', pkid1 => 55 }); - is($st->pkid1, 55, "Oracle Auto-PK without trigger: First primary key set manually"); } -END { - if($dbh) { - $dbh->do("DROP TABLE testschema.artist;"); - $dbh->do("DROP TABLE testschema.casecheck;"); - $dbh->do("DROP TABLE testschema.sequence_test;"); - $dbh->do("DROP TABLE testschema.array_test;"); - $dbh->do("DROP SEQUENCE pkid1_seq"); - $dbh->do("DROP SEQUENCE pkid2_seq"); - $dbh->do("DROP SEQUENCE nonpkid_seq"); - $dbh->do("DROP SCHEMA testschema;"); - } -} +done_testing; +END { _cleanup($schema) }