X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=t%2F74mssql.t;h=c51e9de011de8461e39eed94f4b7fecb0548482f;hb=4282b6f8db080b849df4a9d30c8c79aaaabc7838;hp=172c78dfbb329b2fd76a69a319c58285c561fb24;hpb=8a0720e2d4a3914c84ac2ce1dd5913d5931709a1;p=dbsrgits%2FDBIx-Class.git diff --git a/t/74mssql.t b/t/74mssql.t index 172c78d..c51e9de 100644 --- a/t/74mssql.t +++ b/t/74mssql.t @@ -18,10 +18,6 @@ my ($dsn, $user, $pass) = @ENV{map { "DBICTEST_MSSQL_${_}" } qw/DSN USER PASS/}; plan skip_all => 'Set $ENV{DBICTEST_MSSQL_DSN}, _USER and _PASS to run this test' unless ($dsn); -my $TESTS = 15; - -plan tests => $TESTS * 2; - my @storage_types = ( 'DBI::Sybase::Microsoft_SQL_Server', 'DBI::Sybase::Microsoft_SQL_Server::NoBindVars', @@ -29,34 +25,45 @@ my @storage_types = ( my $storage_idx = -1; my $schema; +my $NUMBER_OF_TESTS_IN_BLOCK = 18; for my $storage_type (@storage_types) { $storage_idx++; $schema = DBICTest::Schema->clone; - if ($storage_idx != 0) { # autodetect - $schema->storage_type("::$storage_type"); - } - $schema->connection($dsn, $user, $pass); - $schema->storage->ensure_connected; + if ($storage_idx != 0) { # autodetect + no warnings 'redefine'; + local *DBIx::Class::Storage::DBI::_typeless_placeholders_supported = + sub { 0 }; +# $schema->storage_type("::$storage_type"); + $schema->storage->ensure_connected; + } + else { + $schema->storage->ensure_connected; + } if ($storage_idx == 0 && ref($schema->storage) =~ /NoBindVars\z/) { my $tb = Test::More->builder; - $tb->skip('no placeholders') for 1..$TESTS; + $tb->skip('no placeholders') for 1..$NUMBER_OF_TESTS_IN_BLOCK; next; } isa_ok($schema->storage, "DBIx::Class::Storage::$storage_type"); -# start disconnected to test reconnection - $schema->storage->_dbh->disconnect; + SKIP: { + skip 'This version of DBD::Sybase segfaults on disconnect', 1 if DBD::Sybase->VERSION < 1.08; + + # start disconnected to test _ping + $schema->storage->_dbh->disconnect; - my $dbh; - lives_ok (sub { - $dbh = $schema->storage->dbh; - }, 'reconnect works'); + lives_ok { + $schema->storage->dbh_do(sub { $_[1]->do('select 1') }) + } '_ping works'; + } + + my $dbh = $schema->storage->dbh; $dbh->do("IF OBJECT_ID('artist', 'U') IS NOT NULL DROP TABLE artist"); @@ -145,17 +152,77 @@ SQL $rs->reset; } 'multiple active statements'; - # test multiple active statements in a transaction - TODO: { - local $TODO = 'needs similar FreeTDS fixes to the ones in Sybase.pm'; - lives_ok { - $schema->txn_do(sub { - $rs->create({ amount => 400 }); - }); - } 'simple transaction'; + $rs->delete; + + # test simple transaction with commit + lives_ok { + $schema->txn_do(sub { + $rs->create({ amount => 400 }); + }); + } 'simple transaction'; + + cmp_ok $rs->first->amount, '==', 400, 'committed'; + $rs->reset; + + $rs->delete; + + # test rollback + throws_ok { + $schema->txn_do(sub { + $rs->create({ amount => 400 }); + die 'mtfnpy'; + }); + } qr/mtfnpy/, 'simple failed txn'; + + is $rs->first, undef, 'rolled back'; + $rs->reset; + + # test RNO detection when version detection fails + SKIP: { + my $storage = $schema->storage; + my $version = $storage->_server_info->{normalized_dbms_version}; + + skip 'could not detect SQL Server version', 1 if not defined $version; + + my $have_rno = $version >= 9 ? 1 : 0; + + local $storage->{_sql_maker} = undef; + local $storage->{_sql_maker_opts} = undef; + + local $storage->{_server_info_hash} = { %{ $storage->_server_info_hash } }; # clone + delete @{$storage->{_server_info_hash}}{qw/dbms_version normalized_dbms_version/}; + + $storage->sql_maker; + + my $rno_detected = + ($storage->{_sql_maker_opts}{limit_dialect} eq 'RowNumberOver') ? 1 : 0; + + ok (($have_rno == $rno_detected), + 'row_number() over support detected correctly'); + } + + { + my $schema = DBICTest::Schema->clone; + $schema->connection($dsn, $user, $pass); + + like $schema->storage->sql_maker->{limit_dialect}, + qr/^(?:Top|RowNumberOver)\z/, + 'sql_maker is correct on unconnected schema'; } } +# test op-induced autoconnect +lives_ok (sub { + + my $schema = DBICTest::Schema->clone; + $schema->connection($dsn, $user, $pass); + + my $artist = $schema->resultset ('Artist')->search ({}, { order_by => 'artistid' })->next; + is ($artist->id, 1, 'Artist retrieved successfully'); +}, 'Query-induced autoconnect works'); + +done_testing; + # clean up our mess END { if (my $dbh = eval { $schema->storage->dbh }) {