X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=lib%2FDBIx%2FClass%2FStorage%2FDBI%2FSybase.pm;h=d92a60e2e8ad11b3cb1d98f84350d595c9d14a91;hb=9041a97a57cd2831d20e3b25772b29f9af3d8ef9;hp=2fe0b83562ce3565686810b7ab6e3273b0338af4;hpb=98464041fda64549ac43bb13393bf4f9a53e30cb;p=dbsrgits%2FDBIx-Class.git diff --git a/lib/DBIx/Class/Storage/DBI/Sybase.pm b/lib/DBIx/Class/Storage/DBI/Sybase.pm index 2fe0b83..d92a60e 100644 --- a/lib/DBIx/Class/Storage/DBI/Sybase.pm +++ b/lib/DBIx/Class/Storage/DBI/Sybase.pm @@ -3,20 +3,151 @@ 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; + + 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->connect_call_datetime_setup; + $self->connect_call_blob_setup; + } + } +} + +sub _populate_dbh { + my $self = shift; + $self->next::method(@_); + $self->connect_call_datetime_setup; + $self->connect_call_blob_setup; + 1; +} + +=head2 connect_call_blob_setup + +Used as: + + on_connect_call => 'blob_setup' + +Does C<< $dbh->{syb_binary_images} = 1; >> to return C data as raw binary +instead of as a hex string. + +Recommended. + +=cut + +sub connect_call_blob_setup { + my $self = shift; + my $dbh = $self->_dbh; + $dbh->{syb_binary_images} = 1; +} + +=head2 connect_call_datetime_setup + +Used as: + + on_connect_call => 'datetime_setup' + +In L to set: + + $dbh->syb_date_fmt('ISO_strict'); # output fmt: 2004-08-21T14:36:48.080Z + $dbh->do('set dateformat mdy'); # input fmt: 08/13/1979 18:08:55.080 + +On connection for use with L, using +L, which you will need to install. + +This works for both C and C columns, although +C columns only have minute precision. + +=cut + +{ + my $old_dbd_warned = 0; + + sub connect_call_datetime_setup { my $self = shift; + my $dbh = $self->_dbh; - 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; - } + 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 datetime_parser_type { "DateTime::Format::Sybase" } + +sub _dbh_last_insert_id { + 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]; +} + +=head2 count + +Counts for limited queries are emulated by executing select queries and +returning the number of successful executions minus the offset. + +This is necessary due to the limitations of Sybase. + +=cut + +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->_copy_attributes_for_count($source, $attrs); + + my $first_pk = ($source->primary_columns)[0]; + + $new_attrs->{select} = $first_pk ? "me.$first_pk" : 1; + + 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; } 1; @@ -27,18 +158,45 @@ 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 AUTHORS +=head1 DESCRIPTION + +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. + +With this driver there is unfortunately no way to get the C +without doing a C