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=bedf113686a0c8e1fa15e5a70fe04cc74989c4f8;hb=e46df41a7023dc31ac5eba4bc81c050d7964d3be;hp=03053c6cb87b353eaf5236567ff013d9db075f38;hpb=384b8bce2c9e4081cb131bba591627fda2672a5a;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 03053c6..bedf113 100644 --- a/lib/DBIx/Class/Storage/DBI/ODBC/Microsoft_SQL_Server.pm +++ b/lib/DBIx/Class/Storage/DBI/ODBC/Microsoft_SQL_Server.pm @@ -6,7 +6,7 @@ use base qw/DBIx::Class::Storage::DBI::MSSQL/; use mro 'c3'; use Scalar::Util 'reftype'; use Try::Tiny; -use Carp::Clan qw/^DBIx::Class/; +use DBIx::Class::Carp; use namespace::clean; __PACKAGE__->mk_group_accessors(simple => qw/ @@ -27,6 +27,48 @@ MSSQL back-end. Most of the functionality is provided from the superclass L. +=head1 USAGE NOTES + +=head2 Basic Linux Setup (Debian) + + sudo aptitude install tdsodbc libdbd-odbc-perl unixodbc + +In case it is not already there put the following in C: + + [FreeTDS] + Description = FreeTDS + Driver = /usr/lib/odbc/libtdsodbc.so + Setup = /usr/lib/odbc/libtdsS.so + UsageCount = 1 + +Set your C<$dsn> in L as follows: + + dbi:ODBC:server=;port=1433;driver=FreeTDS;tds_version=8.0 + +If you use the EasySoft driver (L): + + dbi:ODBC:server=;port=1433;driver=Easysoft ODBC-SQL Server + +=head2 Basic Windows Setup + +Use the following C<$dsn> for the Microsoft ODBC driver: + + dbi:ODBC:driver={SQL Server};server=SERVER\SQL_SERVER_INSTANCE_NAME + +And for the Native Client: + + dbi:ODBC:driver={SQL Server Native Client 10.0};server=SERVER\SQL_SERVER_INSTANCE_NAME + +Go into Control Panel -> System and Security -> Administrative Tools -> Data +Sources (ODBC) to check driver names and to set up data sources. + +Use System DSNs, not User DSNs if you want to use DSNs. + +If you set up a DSN, use the following C<$dsn> for +L: + + dbi:ODBC:dsn=MY_DSN + =head1 MULTIPLE ACTIVE STATEMENTS The following options are alternative ways to enable concurrent executing @@ -37,11 +79,11 @@ In order of preference, they are: =over 8 -=item * L +=item * L -=item * L +=item * L -=item * L +=item * L =back @@ -53,6 +95,15 @@ Use as: on_connect_call => 'use_mars' +in your connection info, or alternatively specify it directly: + + Your::Schema->connect ( + $original_dsn . '; MARS_Connection=Yes', + $user, + $pass, + \%attrs, + ) + Use to enable a feature of SQL Server 2005 and later, "Multiple Active Result Sets". See L for more information. @@ -84,8 +135,9 @@ sub connect_call_use_mars { } if (my ($data_source) = $dsn =~ /^dbi:ODBC:([\w-]+)\z/i) { # prefix with DSN - warn "Bare DSN in ODBC connect string, rewriting to DSN=$data_source\n"; - $dsn = "dbi:ODBC:DSN=$data_source"; + warn "Bare DSN in ODBC connect string, rewriting as 'dsn=$data_source'" + ." for MARS\n"; + $dsn = "dbi:ODBC:dsn=$data_source"; } $self->_dbi_connect_info->[0] = "$dsn;MARS_Connection=Yes"; @@ -106,84 +158,86 @@ Use as: on_connect_call => 'use_dynamic_cursors' -in your L as one way to enable multiple -concurrent statements. +Which will add C<< odbc_cursortype => 2 >> to your DBI connection +attributes, or alternatively specify the necessary flag directly: -Will add C<< odbc_cursortype => 2 >> to your DBI connection attributes. See -L for more information. + Your::Schema->connect (@dsn, { ... odbc_cursortype => 2 }) -Alternatively, you can add it yourself and dynamic cursor support will be -automatically enabled. +See L for more information. If you're using FreeTDS, C must be set to at least C<8.0>. This will not work with CODE ref connect_info's. -B this will break C, and C will be used instead, which on SQL +Server 2005 and later will return erroneous results on tables which have an on +insert trigger that inserts into another table with an C column. =cut sub connect_call_use_dynamic_cursors { my $self = shift; - if (ref($self->_dbi_connect_info->[0]) eq 'CODE') { - $self->throw_exception ('Cannot set DBI attributes on a CODE ref connect_info'); - } + my $conn_info = $self->_dbi_connect_info; - my $dbi_attrs = $self->_dbi_connect_info->[-1]; - - unless (ref $dbi_attrs eq 'HASH') { - $dbi_attrs = {}; - push @{ $self->_dbi_connect_info }, $dbi_attrs; + if (ref($conn_info->[0]) eq 'CODE') { + $self->throw_exception ('Cannot set DBI attributes on a CODE ref connect_info'); } - if (not exists $dbi_attrs->{odbc_cursortype}) { - # turn on support for multiple concurrent statements, unless overridden - $dbi_attrs->{odbc_cursortype} = 2; + if ( + ref($conn_info->[-1]) ne 'HASH' + or + ($conn_info->[-1]{odbc_cursortype}||0) < 2 + ) { + # reenter connection information with the attribute re-set + $self->connect_info( + @{$conn_info}[0,1,2], + { %{$self->_dbix_connect_attributes}, odbc_cursortype => 2 }, + ); $self->disconnect; # resetting dbi attrs, so have to reconnect $self->ensure_connected; - $self->_set_dynamic_cursors; } } -sub _set_dynamic_cursors { - my $self = shift; - my $dbh = $self->_get_dbh; - - try { - local $dbh->{RaiseError} = 1; - local $dbh->{PrintError} = 0; - $dbh->do('SELECT @@IDENTITY'); - } 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'); -} - -sub _init { +sub _run_connection_actions { my $self = shift; + # keep the dynamic_cursors_support and driver-state in sync + # on every reconnect + my $use_dyncursors = ($self->_dbic_connect_attributes->{odbc_cursortype} || 0) > 1; if ( - ref($self->_dbi_connect_info->[0]) ne 'CODE' - && - ref ($self->_dbi_connect_info->[-1]) eq 'HASH' - && - ($self->_dbi_connect_info->[-1]{odbc_cursortype} || 0) > 1 + $use_dyncursors + xor + !!$self->_using_dynamic_cursors ) { - $self->_set_dynamic_cursors; - } - else { - $self->_using_dynamic_cursors(0); + if ($use_dyncursors) { + try { + my $dbh = $self->_dbh; + local $dbh->{RaiseError} = 1; + local $dbh->{PrintError} = 0; + $dbh->do('SELECT @@IDENTITY'); + } catch { + $self->throw_exception ( + 'Your drivers do not seem to support dynamic cursors (odbc_cursortype => 2).' + . ( + $self->using_freetds + ? ' If you are using FreeTDS, make sure to set tds_version to 8.0 or greater.' + : '' + ) + ); + }; + + $self->_using_dynamic_cursors(1); + $self->_identity_method('@@identity'); + } + else { + $self->_using_dynamic_cursors(0); + $self->_identity_method(undef); + } } + + $self->next::method (@_); } =head2 connect_call_use_server_cursors @@ -232,10 +286,8 @@ sub using_freetds { $dsn = '' if ref $dsn eq 'CODE'; - my $dbh = $self->_get_dbh; - return 1 if $dsn =~ /driver=FreeTDS/i - || (try { $dbh->get_info(6) }||'') =~ /tdsodbc/i; + || ($self->_dbh_get_info(6)||'') =~ /tdsodbc/i; return 0; }