X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=lib%2FDBIx%2FClass%2FStorage%2FDBI%2FSybase.pm;h=901cf0ae9dd0a2c0e54add36bc275671d7f91662;hb=9ffaf8a3d9eede54f95134bd62af2bcc6e650bba;hp=3fe093001230914d2bb82efb814eec1e7d4fdec4;hpb=9780718f9c36738245f90b1f036998c3b076cffc;p=dbsrgits%2FDBIx-Class-Historic.git diff --git a/lib/DBIx/Class/Storage/DBI/Sybase.pm b/lib/DBIx/Class/Storage/DBI/Sybase.pm index 3fe0930..901cf0a 100644 --- a/lib/DBIx/Class/Storage/DBI/Sybase.pm +++ b/lib/DBIx/Class/Storage/DBI/Sybase.pm @@ -3,6 +3,7 @@ package DBIx::Class::Storage::DBI::Sybase; use strict; use warnings; use Try::Tiny; +use namespace::clean; use base qw/DBIx::Class::Storage::DBI/; @@ -44,6 +45,31 @@ sub _rebless { } } +sub _init { + # once the driver is determined see if we need to insert the DBD::Sybase w/ FreeTDS fixups + # this is a dirty version of "instance role application", \o/ DO WANT Moo \o/ + my $self = shift; + if (! $self->isa('DBIx::Class::Storage::DBI::Sybase::FreeTDS') and $self->using_freetds) { + require DBIx::Class::Storage::DBI::Sybase::FreeTDS; + + my @isa = @{mro::get_linear_isa(ref $self)}; + my $class = shift @isa; # this is our current ref + + my $trait_class = $class . '::FreeTDS'; + mro::set_mro ($trait_class, 'c3'); + no strict 'refs'; + @{"${trait_class}::ISA"} = ($class, 'DBIx::Class::Storage::DBI::Sybase::FreeTDS', @isa); + + bless ($self, $trait_class); + + Class::C3->reinitialize() if DBIx::Class::_ENV_::OLD_MRO; + + $self->_init(@_); + } + + $self->next::method(@_); +} + sub _ping { my $self = shift; @@ -52,23 +78,27 @@ sub _ping { local $dbh->{RaiseError} = 1; local $dbh->{PrintError} = 0; +# FIXME if the main connection goes stale, does opening another for this statement +# really determine anything? + if ($dbh->{syb_no_child_con}) { -# if extra connections are not allowed, then ->ping is reliable - my $alive; - try { $alive = $dbh->ping } catch { $alive = 0 }; - return $alive; + return try { + $self->_connect(@{$self->_dbi_connect_info || [] }) + ->do('select 1'); + 1; + } + catch { + 0; + }; } - my $rc = 1; - try { -# XXX if the main connection goes stale, does opening another for this statement -# really determine anything? + return try { $dbh->do('select 1'); - } catch { - $rc = 0; + 1; + } + catch { + 0; }; - - return $rc; } sub _set_max_connect { @@ -97,34 +127,7 @@ the Sybase OpenClient libraries were used. sub using_freetds { my $self = shift; - return $self->_get_dbh->{syb_oc_version} =~ /freetds/i; -} - -=head2 set_textsize - -When using FreeTDS and/or MSSQL, C<< $dbh->{LongReadLen} >> is not available, -use this function instead. It does: - - $dbh->do("SET TEXTSIZE $bytes"); - -Takes the number of bytes, or uses the C value from your -L if omitted, lastly falls -back to the C<32768> which is the L default. - -=cut - -sub set_textsize { - my $self = shift; - my $text_size = - shift - || - try { $self->_dbi_connect_info->[-1]->{LongReadLen} } - || - 32768; # the DBD::Sybase default - - return unless defined $text_size; - - $self->_dbh->do("SET TEXTSIZE $text_size"); + return ($self->_get_dbh->{syb_oc_version}||'') =~ /freetds/i; } 1;