X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=lib%2FDBIx%2FClass%2FStorage%2FDBI%2FODBC%2FMicrosoft_SQL_Server.pm;h=b2db13f5facb085c6dfd56b1162718ca91de2d70;hb=6298a324307439b76419d0f5db453b0d10f10517;hp=8519ee5bced7b441e22ee60da9df3d3e5d1efe3e;hpb=37b17a93efef4652db90e299b247e55ab1145b0b;p=dbsrgits%2FDBIx-Class.git diff --git a/lib/DBIx/Class/Storage/DBI/ODBC/Microsoft_SQL_Server.pm b/lib/DBIx/Class/Storage/DBI/ODBC/Microsoft_SQL_Server.pm index 8519ee5..b2db13f 100644 --- a/lib/DBIx/Class/Storage/DBI/ODBC/Microsoft_SQL_Server.pm +++ b/lib/DBIx/Class/Storage/DBI/ODBC/Microsoft_SQL_Server.pm @@ -4,10 +4,9 @@ use warnings; use base qw/DBIx::Class::Storage::DBI::MSSQL/; use mro 'c3'; - -use Carp::Clan qw/^DBIx::Class/; -use List::Util(); -use Scalar::Util (); +use Scalar::Util 'reftype'; +use Try::Tiny; +use namespace::clean; __PACKAGE__->mk_group_accessors(simple => qw/ _using_dynamic_cursors @@ -38,7 +37,7 @@ Use as: on_connect_call => 'use_dynamic_cursors' -in your L as one way to enable multiple +in your L as one way to enable multiple concurrent statements. Will add C<< odbc_cursortype => 2 >> to your DBI connection attributes. See @@ -62,12 +61,12 @@ sub connect_call_use_dynamic_cursors { my $self = shift; if (ref($self->_dbi_connect_info->[0]) eq 'CODE') { - croak 'cannot set DBI attributes on a CODE ref connect_info'; + $self->throw_exception ('Cannot set DBI attributes on a CODE ref connect_info'); } my $dbi_attrs = $self->_dbi_connect_info->[-1]; - unless (ref($dbi_attrs) && Scalar::Util::reftype($dbi_attrs) eq 'HASH') { + unless (ref($dbi_attrs) && reftype $dbi_attrs eq 'HASH') { $dbi_attrs = {}; push @{ $self->_dbi_connect_info }, $dbi_attrs; } @@ -85,18 +84,17 @@ sub _set_dynamic_cursors { my $self = shift; my $dbh = $self->_get_dbh; - eval { + try { local $dbh->{RaiseError} = 1; local $dbh->{PrintError} = 0; $dbh->do('SELECT @@IDENTITY'); - }; - if ($@) { - croak <<'EOF'; + } catch { + $self->throw_exception (<<'EOF'); Your drivers do not seem to support dynamic cursors (odbc_cursortype => 2), if you're using FreeTDS, make sure to set tds_version to 8.0 or greater. EOF - } + }; $self->_using_dynamic_cursors(1); $self->_identity_method('@@identity'); @@ -105,8 +103,15 @@ EOF sub _init { my $self = shift; - if (ref($self->_dbi_connect_info->[0]) ne 'CODE' && - eval { $self->_dbi_connect_info->[-1]{odbc_cursortype} } == 2) { + no warnings qw/uninitialized/; + + if ( + ref($self->_dbi_connect_info->[0]) ne 'CODE' + && + ref ($self->_dbi_connect_info->[-1]) eq 'HASH' + && + $self->_dbi_connect_info->[-1]{odbc_cursortype} == 2 + ) { $self->_set_dynamic_cursors; return; } @@ -158,7 +163,7 @@ sub connect_call_use_MARS { my $dsn = $self->_dbi_connect_info->[0]; if (ref($dsn) eq 'CODE') { - croak 'cannot change the DBI DSN on a CODE ref connect_info'; + $self->throw_exception('cannot change the DBI DSN on a CODE ref connect_info'); } if ($dsn !~ /MARS_Connection=/) {