X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=lib%2FDBIx%2FClass%2FStorage%2FDBI%2FSybase.pm;h=385ac30eb2118e10016089db534097a45cea915c;hb=70f524e6b39efe4fb16e2fd75132c118f050df25;hp=0c18d6b96464791816d07acb40f789e53fa8cfd8;hpb=d29565e0c545871399b0732e7781ea445e7d5b8c;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 0c18d6b..385ac30 100644 --- a/lib/DBIx/Class/Storage/DBI/Sybase.pm +++ b/lib/DBIx/Class/Storage/DBI/Sybase.pm @@ -3,27 +3,102 @@ package DBIx::Class::Storage::DBI::Sybase; use strict; use warnings; -use base qw/DBIx::Class::Storage::DBI::NoBindVars/; +use Class::C3; +use base qw/DBIx::Class::Storage::DBI/; + +use Carp::Clan qw/^DBIx::Class/; sub _rebless { - my $self = shift; + my $self = shift; + + if (ref($self) eq 'DBIx::Class::Storage::DBI::Sybase') { + my $dbtype = eval { + @{$self->dbh->selectrow_arrayref(qq{sp_server_info \@attribute_id=1})}[2] + } || ''; + + my $exception = $@; + $dbtype =~ s/\W/_/gi; + my $subclass = "DBIx::Class::Storage::DBI::Sybase::${dbtype}"; + + if (!$exception && $dbtype && $self->load_optional_class($subclass)) { + bless $self, $subclass; + $self->_rebless; + } else { + # real Sybase + if (not $self->dbh->{syb_dynamic_supported}) { + bless $self, 'DBIx::Class::Storage:DBI::Sybase::NoBindVars'; + $self->_rebless; + } + $self->_init_date_fmt; + } + } +} - my $dbtype = eval { @{$self->dbh->selectrow_arrayref(qq{sp_server_info \@attribute_id=1})}[2] }; - unless ( $@ ) { - $dbtype =~ s/\W/_/gi; - my $subclass = "DBIx::Class::Storage::DBI::Sybase::${dbtype}"; - if ($self->load_optional_class($subclass) && !$self->isa($subclass)) { - bless $self, $subclass; - $self->_rebless; - } +sub _populate_dbh { + my $self = shift; + $self->next::method(@_); + $self->_init_date_fmt; + 1; +} + +{ + my $old_dbd_warned = 0; + + sub _init_date_fmt { + my $self = shift; + my $dbh = $self->_dbh; + + if ($dbh->can('syb_date_fmt')) { + $dbh->syb_date_fmt('ISO_strict'); + } elsif (not $old_dbd_warned) { + carp "Your DBD::Sybase is too old to support ". + "DBIx::Class::InflateColumn::DateTime, please upgrade!"; + $old_dbd_warned = 1; } + + $dbh->do('set dateformat mdy'); + + 1; + } } sub _dbh_last_insert_id { - my $self = shift; - ($self->_dbh->selectrow_array('select @@identity'))[0]; + my ($self, $dbh, $source, $col) = @_; + + # sorry, there's no other way! + my $sth = $dbh->prepare_cached("select max($col) from ".$source->from); + return ($dbh->selectrow_array($sth))[0]; } +sub count { + my $self = shift; + my ($source, $attrs) = @_; + + if (not exists $attrs->{rows}) { + return $self->next::method(@_); + } + + my $offset = $attrs->{offset} || 0; + my $total = $attrs->{rows} + $offset; + + my $new_attrs = $self->_trim_attributes_for_count($source, $attrs); + $new_attrs->{select} = '1'; + $new_attrs->{as} = ['dummy']; + + my $tmp_rs = $source->resultset_class->new($source, $new_attrs); + + $self->dbh->{syb_rowcount} = $total; + + my $count = 0; + $count++ while $tmp_rs->cursor->next; + + $self->dbh->{syb_rowcount} = 0; + + return $count - $offset; +} + +sub datetime_parser_type { "DBIx::Class::Storage::DBI::Sybase::DateTime" } + 1; =head1 NAME @@ -32,27 +107,40 @@ DBIx::Class::Storage::DBI::Sybase - Storage::DBI subclass for Sybase =head1 SYNOPSIS -This subclass supports L for real Sybase databases. If -you are using an MSSQL database via L, see -L. +This subclass supports L for real Sybase databases. If you are +using an MSSQL database via L, your storage will be reblessed to +L. -=head1 CAVEATS +=head1 DESCRIPTION -This storage driver uses L as a base. -This means that bind variables will be interpolated (properly quoted of course) -into the SQL query itself, without using bind placeholders. +If your version of Sybase does not support placeholders, then your storage +will be reblessed to L. You can +also enable that driver explicitly, see the documentation for more details. -More importantly this means that caching of prepared statements is explicitly -disabled, as the interpolation renders it useless. +With this driver there is unfortunately no way to get the C +without doing a C